File age measurements show the distribution of file ages (days since the first commit) and the recency of file updates (days since the latest commit).
File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
---|---|---|---|---|---|
KinesisDataFetcher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
796 | 44 | 287 | 287 | 1 |
KinesisConfigUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
347 | 13 | 287 | 287 | 1 |
KinesisProxy.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
341 | 12 | 287 | 287 | 1 |
FanOutShardSubscriber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
318 | 27 | 183 | 287 | 2 |
FlinkKinesisConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
248 | 17 | 287 | 287 | 1 |
FlinkKinesisProducer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
247 | 16 | 231 | 287 | 2 |
FanOutRecordPublisherConfiguration.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
221 | 27 | 287 | 287 | 1 |
AwsV2Util.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
218 | 15 | 183 | 287 | 2 |
StreamConsumerRegistrar.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
176 | 15 | 287 | 287 | 1 |
AWSUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
172 | 9 | 287 | 287 | 1 |
RecordEmitter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
169 | 13 | 287 | 287 | 1 |
RowDataFieldsKinesisPartitioner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
168 | 9 | 287 | 287 | 1 |
KinesisOptions.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
165 | 8 | 287 | 287 | 1 |
FanOutRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
160 | 5 | 183 | 287 | 2 |
StreamShardMetadata.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
156 | 23 | 287 | 287 | 1 |
KinesisProxyV2.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
145 | 10 | 287 | 287 | 1 |
ConsumerConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
134 | 2 | 183 | 287 | 2 |
ShardConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
134 | 7 | 174 | 287 | 2 |
JobManagerWatermarkTracker.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
130 | 8 | 287 | 287 | 1 |
PollingRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
114 | 6 | 287 | 287 | 1 |
File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
---|---|---|---|---|---|
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 |
DynamoDBStreamsSchema.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization |
18 | 2 | 287 | 287 | 1 |
RandomKinesisPartitioner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
18 | 3 | 287 | 287 | 1 |
KinesisProxyV2Interface.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
21 | 1 | 287 | 287 | 1 |
TimeoutLatch.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
21 | 2 | 287 | 287 | 1 |
DynamoDBStreamsShardHandle.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
23 | 3 | 287 | 287 | 1 |
SentinelSequenceNumber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
26 | 2 | 287 | 287 | 1 |
PollingRecordPublisherConfiguration.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
30 | 4 | 287 | 287 | 1 |
KinesisDeserializationSchemaWrapper.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization |
37 | 4 | 287 | 287 | 1 |
RowDataKinesisDeserializationSchema.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
39 | 4 | 287 | 287 | 1 |
File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
---|---|---|---|---|---|
KinesisDataFetcher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
796 | 44 | 287 | 287 | 1 |
KinesisConfigUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
347 | 13 | 287 | 287 | 1 |
KinesisProxy.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
341 | 12 | 287 | 287 | 1 |
FanOutShardSubscriber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
318 | 27 | 183 | 287 | 2 |
FlinkKinesisConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
248 | 17 | 287 | 287 | 1 |
FlinkKinesisProducer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
247 | 16 | 231 | 287 | 2 |
FanOutRecordPublisherConfiguration.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
221 | 27 | 287 | 287 | 1 |
AwsV2Util.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
218 | 15 | 183 | 287 | 2 |
StreamConsumerRegistrar.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
176 | 15 | 287 | 287 | 1 |
AWSUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
172 | 9 | 287 | 287 | 1 |
RecordEmitter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
169 | 13 | 287 | 287 | 1 |
RowDataFieldsKinesisPartitioner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
168 | 9 | 287 | 287 | 1 |
KinesisOptions.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
165 | 8 | 287 | 287 | 1 |
FanOutRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
160 | 5 | 183 | 287 | 2 |
StreamShardMetadata.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
156 | 23 | 287 | 287 | 1 |
KinesisProxyV2.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
145 | 10 | 287 | 287 | 1 |
ConsumerConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
134 | 2 | 183 | 287 | 2 |
ShardConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
134 | 7 | 174 | 287 | 2 |
JobManagerWatermarkTracker.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
130 | 8 | 287 | 287 | 1 |
PollingRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
114 | 6 | 287 | 287 | 1 |
File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
---|---|---|---|---|---|
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 |
ShardConsumerMetricsReporter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics |
49 | 10 | 174 | 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 |
AwsV2Util.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
218 | 15 | 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 |
ConsumerConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
134 | 2 | 183 | 287 | 2 |
KinesisProxyV2Factory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
30 | 2 | 183 | 287 | 2 |
FlinkKinesisProducer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
247 | 16 | 231 | 287 | 2 |
KinesisDataFetcher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
796 | 44 | 287 | 287 | 1 |
KinesisConfigUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
347 | 13 | 287 | 287 | 1 |
KinesisProxy.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
341 | 12 | 287 | 287 | 1 |
FlinkKinesisConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
248 | 17 | 287 | 287 | 1 |
FanOutRecordPublisherConfiguration.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
221 | 27 | 287 | 287 | 1 |
StreamConsumerRegistrar.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
176 | 15 | 287 | 287 | 1 |
AWSUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
172 | 9 | 287 | 287 | 1 |
RecordEmitter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
169 | 13 | 287 | 287 | 1 |
RowDataFieldsKinesisPartitioner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
168 | 9 | 287 | 287 | 1 |
KinesisOptions.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
165 | 8 | 287 | 287 | 1 |
StreamShardMetadata.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
156 | 23 | 287 | 287 | 1 |