File change frequency (churn) shows the distribution of file updates (days with at least one commit).
File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
---|---|---|---|---|---|
KinesisProxyV2Factory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
30 | 2 | 183 | 287 | 2 |
ShardConsumerMetricsReporter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics |
49 | 10 | 174 | 287 | 2 |
StreamConsumerRegistrarUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
101 | 9 | 116 | 287 | 2 |
ShardConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
134 | 7 | 174 | 287 | 2 |
ConsumerConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
134 | 2 | 183 | 287 | 2 |
FanOutRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
160 | 5 | 183 | 287 | 2 |
AwsV2Util.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
218 | 15 | 183 | 287 | 2 |
FlinkKinesisProducer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
247 | 16 | 231 | 287 | 2 |
FanOutShardSubscriber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
318 | 27 | 183 | 287 | 2 |
KinesisShardAssigner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
8 | - | 287 | 287 | 1 |
ProducerConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
9 | - | 287 | 287 | 1 |
KinesisProxyInterface.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
11 | - | 287 | 287 | 1 |
KinesisDeserializationSchema.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization |
12 | 1 | 287 | 287 | 1 |
KinesisSerializationSchema.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization |
12 | 1 | 287 | 287 | 1 |
KinesisPartitioner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
13 | 2 | 287 | 287 | 1 |
FullJitterBackoff.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
14 | 2 | 287 | 287 | 1 |
RecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher |
15 | - | 287 | 287 | 1 |
RecordPublisherFactory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher |
16 | 1 | 287 | 287 | 1 |
KinesisConsumerMetricConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics |
17 | - | 287 | 287 | 1 |
FlinkKinesisException.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
17 | 3 | 287 | 287 | 1 |