apache / flink-connector-aws
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 4% | 30% | 27% | 36%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 4% | 31% | 27% | 36%
py0% | 0% | 0% | 68% | 31%
in0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-aws0% | 5% | 31% | 27% | 35%
flink-connector-aws-base0% | 0% | 37% | 33% | 29%
flink-python0% | 0% | 0% | 63% | 36%
flink-formats-aws0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
KinesisDataFetcher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 929 44
KinesisProxy.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 476 14
KinesisConfigUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 448 15
FanOutShardSubscriber.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 402 30
AWSGeneralUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
 355 23
KinesisStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 350 22
DynamoDbTypeInformedElementConverter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 315 14
FanOutRecordPublisherConfiguration.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 315 29
FlinkKinesisConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
 313 17
FlinkKinesisProducer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
 310 17
DynamoDbStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 297 20
KinesisStreamsSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
 281 11
SplitTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
 253 22
FanOutKinesisShardSubscription.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 252 11
DynamoDbSinkWriter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 223 9
KinesisStreamsSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
 223 8
StreamConsumerRegistrar.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 215 15
KinesisStreamsConnectorSinkOptionsUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util
 213 12
KinesisShardSplitReaderBase.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
 213 16
FanOutRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 206 6
PollingDynamoDbStreamsShardSplitReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
 204 13
KinesisDynamicSource.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 200 11
SqsDynamicSink.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
 199 15
KinesisDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 198 16
kinesis.py
in flink-python/pyflink/datastream/connectors
 194 42
KinesisFirehoseSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
 190 7
AWSUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 188 8
DynamoDbStreamsSource.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source
 187 6
KinesisDynamicSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 184 11
DynamoDbStreamsProxy.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy
 180 7
SqsSinkWriter.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink
 176 6
RecordEmitter.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 175 13
StreamShardMetadata.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model
 172 23
AWSClientUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
 168 9
ConsumerConfigConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config
 166 2
KinesisStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
 166 10
DynamoDbSerializationUtil.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util
 164 7
ShardConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 151 7
DynamoDbDynamicSink.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 147 14
AWSConfigOptions.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config
 147 -
JobManagerWatermarkTracker.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 146 8
KinesisProxySyncV2.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 146 9
RowDataFieldsKinesisPartitionKeyGenerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 145 8
KinesisFirehoseDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table
 133 11
KinesisShardSplitSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 129 2
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 126 4
DynamoDbStreamsSourceReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
 125 10
PollingRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling
 123 6
KinesisStreamsSourceEnumeratorStateSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 123 3
StreamConsumerRegistrar.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 117 4
Files With Most Units (Top 50)
File# lines# units
KinesisDataFetcher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 929 44
kinesis.py
in flink-python/pyflink/datastream/connectors
 194 42
FanOutShardSubscriber.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 402 30
FanOutRecordPublisherConfiguration.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 315 29
StreamShardMetadata.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model
 172 23
AWSGeneralUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
 355 23
SplitTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
 253 22
KinesisStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 350 22
DynamoDbStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 297 20
FlinkKinesisProducer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
 310 17
FlinkKinesisConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
 313 17
KinesisDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 198 16
KinesisShardSplitReaderBase.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
 213 16
KinesisConfigUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 448 15
StreamConsumerRegistrar.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 215 15
SqsDynamicSink.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
 199 15
DynamoDbDynamicSink.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 147 14
DynamoDbTypeInformedElementConverter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 315 14
KinesisProxy.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 476 14
PollingDynamoDbStreamsShardSplitReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
 204 13
RecordEmitter.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 175 13
KinesisStreamsSourceBuilder.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
 86 13
KinesisStreamsConnectorSinkOptionsUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util
 213 12
KinesisFirehoseDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table
 133 11
DynamoDbStreamsShardSplit.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
 93 11
PollingRecordPublisherMetricsReporter.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics
 54 11
KinesisDynamicSource.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 200 11
KinesisDynamicSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 184 11
KinesisStreamsSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
 281 11
KinesisShardSplit.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 108 11
FanOutKinesisShardSubscription.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 252 11
AWSConfigConstants.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config
 71 11
ListShardsResult.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util
 65 10
DynamoDbStreamsSourceReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
 125 10
ShardConsumerMetricsReporter.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics
 57 10
KinesisStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
 166 10
SplitTracker.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/tracker
 87 10
DynamoDbSinkWriter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 223 9
DynamoDbStreamsShardSplitState.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
 40 9
StartingPosition.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model
 64 9
StreamConsumerRegistrarUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 108 9
KinesisProxySyncV2.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 146 9
KinesisShardSplitState.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 42 9
AWSClientUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
 168 9
DynamoDbSinkBuilder.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 73 8
DynamoDbWriteRequest.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 48 8
SplitGraphInconsistencyTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
 69 8
StartingPosition.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
 58 8
KinesisStreamShard.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model
 83 8
SequenceNumber.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model
 54 8
Files With Long Lines (Top 36)

There are 36 files with lines longer than 120 characters. In total, there are 135 long lines.

File# lines# units# long lines
KinesisConfigUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 448 15 35
FanOutRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 206 6 8
DynamoDbStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 297 20 6
DynamoDbStreamsSource.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source
 187 6 5
SqsSinkWriter.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink
 176 6 5
KinesisSourceConfigOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
 100 - 5
KinesisStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 350 22 5
DynamoDbSinkWriter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 223 9 4
DynamoDbStreamsProxy.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy
 180 7 4
KinesisConnectorOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 70 - 4
KinesisStreamsSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
 223 8 4
AWSConfigOptions.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config
 147 - 4
KinesisFirehoseSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
 190 7 3
DynamodbStreamsSourceConfigConstants.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config
 64 - 3
PollingRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling
 123 6 3
FanOutShardSubscriber.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 402 30 3
KinesisStreamsSourceConfigUtil.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
 70 3 3
KinesisStreamsSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
 281 11 3
StreamConsumerRegistrar.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 117 4 3
DynamoDbConnectorOptions.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 32 1 2
SplitTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
 253 22 2
AwsV2Util.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 57 6 2
KinesisDataFetcher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 929 44 2
ShardConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 151 7 2
KinesisProxy.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 476 14 2
KinesisStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
 166 10 2
StartingPositionUtil.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 36 1 2
KinesisFirehoseDynamicTableFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table
 56 2 1
AWSFirehoseExceptionClassifiers.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
 34 3 1
DynamoDbStreamsSourceEnumeratorStateSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 87 3 1
SplitGraphInconsistencyTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
 69 8 1
FlinkKinesisProducer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
 310 17 1
AWSUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 188 8 1
SqsExceptionClassifiers.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink
 34 3 1
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 126 4 1
FanOutKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 64 4 1
Correlations

File Size vs. Commits (all time): 230 points

flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 12 commits (all time) y: 281 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java x: 4 commits (all time) y: 100 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisShardSplitReaderBase.java x: 3 commits (all time) y: 213 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReader.java x: 3 commits (all time) y: 64 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.java x: 3 commits (all time) y: 41 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java x: 5 commits (all time) y: 297 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner/UniformShardAssigner.java x: 2 commits (all time) y: 37 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java x: 6 commits (all time) y: 253 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsSourceReader.java x: 4 commits (all time) y: 125 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplit.java x: 3 commits (all time) y: 93 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplitSerializer.java x: 3 commits (all time) y: 90 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSource.java x: 6 commits (all time) y: 187 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java x: 4 commits (all time) y: 204 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsConnectorOptions.java x: 1 commits (all time) y: 28 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicSink.java x: 1 commits (all time) y: 199 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicTableFactory.java x: 1 commits (all time) y: 108 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSourceBuilder.java x: 4 commits (all time) y: 86 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java x: 6 commits (all time) y: 350 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/AsyncStreamProxy.java x: 1 commits (all time) y: 14 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisAsyncStreamProxy.java x: 1 commits (all time) y: 39 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisStreamProxy.java x: 5 commits (all time) y: 166 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/StreamProxy.java x: 4 commits (all time) y: 26 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSubscription.java x: 1 commits (all time) y: 252 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/StreamConsumerRegistrar.java x: 1 commits (all time) y: 117 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPositionUtil.java x: 1 commits (all time) y: 36 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util/AWSOptionUtils.java x: 2 commits (all time) y: 57 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisStreamsSourceConfigUtil.java x: 4 commits (all time) y: 70 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisConnectorOptions.java x: 2 commits (all time) y: 70 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSink.java x: 2 commits (all time) y: 198 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSource.java x: 1 commits (all time) y: 184 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicTableFactory.java x: 1 commits (all time) y: 126 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorSinkOptionsUtils.java x: 1 commits (all time) y: 213 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorSourceOptionsUtils.java x: 1 commits (all time) y: 42 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisConsumerOptionsUtil.java x: 3 commits (all time) y: 57 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConnectorOptions.java x: 2 commits (all time) y: 32 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSink.java x: 2 commits (all time) y: 147 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java x: 2 commits (all time) y: 47 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataElementConverter.java x: 2 commits (all time) y: 49 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataToAttributeValueConverter.java x: 2 commits (all time) y: 76 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumeratorState.java x: 3 commits (all time) y: 21 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumeratorStateSerializer.java x: 3 commits (all time) y: 87 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util/ShardUtils.java x: 3 commits (all time) y: 30 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java x: 2 commits (all time) y: 7 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java x: 7 commits (all time) y: 355 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java x: 1 commits (all time) y: 147 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitGraphInconsistencyTracker.java x: 3 commits (all time) y: 69 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisStreamsSourceReader.java x: 4 commits (all time) y: 77 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java x: 4 commits (all time) y: 108 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitSerializer.java x: 3 commits (all time) y: 129 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java x: 3 commits (all time) y: 168 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDBStreamsShardSplitWithAssignmentStatus.java x: 1 commits (all time) y: 47 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/SplitAssignmentStatus.java x: 1 commits (all time) y: 23 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/metrics/DynamoDbStreamsShardMetrics.java x: 1 commits (all time) y: 51 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy/DynamoDbStreamsProxy.java x: 2 commits (all time) y: 180 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy/StreamProxy.java x: 2 commits (all time) y: 13 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util/ListShardsResult.java x: 1 commits (all time) y: 65 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsConfigConstants.java x: 1 commits (all time) y: 17 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSink.java x: 1 commits (all time) y: 111 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkBuilder.java x: 1 commits (all time) y: 72 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkElementConverter.java x: 1 commits (all time) y: 52 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkWriter.java x: 1 commits (all time) y: 176 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/client/SdkClientProvider.java x: 1 commits (all time) y: 8 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorState.java x: 2 commits (all time) y: 20 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorStateSerializer.java x: 2 commits (all time) y: 123 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTracker.java x: 1 commits (all time) y: 87 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/StartingPosition.java x: 1 commits (all time) y: 58 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java x: 1 commits (all time) y: 315 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java x: 2 commits (all time) y: 190 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java x: 2 commits (all time) y: 223 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java x: 3 commits (all time) y: 313 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkElementConverter.java x: 2 commits (all time) y: 64 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkElementConverter.java x: 2 commits (all time) y: 81 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSink.java x: 2 commits (all time) y: 110 lines of code flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSchemaCoderProvider.java x: 2 commits (all time) y: 18 lines of code flink-python/MANIFEST.in x: 1 commits (all time) y: 19 lines of code flink-python/pyflink/datastream/connectors/kinesis.py x: 1 commits (all time) y: 194 lines of code flink-python/setup.py x: 1 commits (all time) y: 91 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java x: 2 commits (all time) y: 166 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/RecoverableErrorsConfig.java x: 1 commits (all time) y: 61 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisher.java x: 2 commits (all time) y: 206 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisherConfiguration.java x: 2 commits (all time) y: 315 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java x: 2 commits (all time) y: 402 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java x: 2 commits (all time) y: 448 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java x: 2 commits (all time) y: 43 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataKinesisDeserializationSchema.java x: 2 commits (all time) y: 100 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicSink.java x: 1 commits (all time) y: 133 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/RowDataFieldsKinesisPartitionKeyGenerator.java x: 1 commits (all time) y: 145 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java x: 1 commits (all time) y: 223 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtil.java x: 1 commits (all time) y: 164 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilder.java x: 1 commits (all time) y: 76 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java x: 1 commits (all time) y: 310 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java x: 1 commits (all time) y: 4 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/DynamoDBStreamsDataFetcher.java x: 1 commits (all time) y: 84 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java x: 1 commits (all time) y: 929 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java x: 1 commits (all time) y: 151 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/AdaptivePollingRecordPublisher.java x: 1 commits (all time) y: 79 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/PollingRecordPublisher.java x: 1 commits (all time) y: 123 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardMetadata.java x: 1 commits (all time) y: 172 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/DynamoDBStreamsProxy.java x: 1 commits (all time) y: 96 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java x: 1 commits (all time) y: 476 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java x: 1 commits (all time) y: 188 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigConstants.java x: 3 commits (all time) y: 71 lines of code flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSerializationSchema.java x: 1 commits (all time) y: 32 lines of code tools/maven/suppressions.xml x: 3 commits (all time) y: 15 lines of code
929.0
lines of code
  min: 4.0
  average: 82.98
  25th percentile: 22.0
  median: 49.5
  75th percentile: 100.0
  max: 929.0
0 12.0
commits (all time)
min: 1.0 | average: 1.57 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 12.0

File Size vs. Contributors (all time): 230 points

flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 7 contributors (all time) y: 281 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java x: 3 contributors (all time) y: 100 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisShardSplitReaderBase.java x: 2 contributors (all time) y: 213 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReader.java x: 2 contributors (all time) y: 64 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.java x: 2 contributors (all time) y: 41 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java x: 1 contributors (all time) y: 297 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner/UniformShardAssigner.java x: 1 contributors (all time) y: 37 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java x: 1 contributors (all time) y: 253 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsSourceReader.java x: 2 contributors (all time) y: 125 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplit.java x: 1 contributors (all time) y: 93 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplitSerializer.java x: 1 contributors (all time) y: 90 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSource.java x: 2 contributors (all time) y: 187 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config/DynamodbStreamsSourceConfigConstants.java x: 1 contributors (all time) y: 64 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java x: 2 contributors (all time) y: 204 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsConnectorOptions.java x: 1 contributors (all time) y: 28 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicSink.java x: 1 contributors (all time) y: 199 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicTableFactory.java x: 1 contributors (all time) y: 108 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSourceBuilder.java x: 3 contributors (all time) y: 86 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java x: 3 contributors (all time) y: 350 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/AsyncStreamProxy.java x: 1 contributors (all time) y: 14 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisStreamProxy.java x: 4 contributors (all time) y: 166 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/StreamProxy.java x: 3 contributors (all time) y: 26 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSubscription.java x: 1 contributors (all time) y: 252 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/StreamConsumerRegistrar.java x: 1 contributors (all time) y: 117 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPositionUtil.java x: 1 contributors (all time) y: 36 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util/AWSOptionUtils.java x: 2 contributors (all time) y: 57 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisStreamsSourceConfigUtil.java x: 3 contributors (all time) y: 70 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisConnectorOptions.java x: 2 contributors (all time) y: 70 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSink.java x: 2 contributors (all time) y: 198 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSource.java x: 1 contributors (all time) y: 184 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicTableFactory.java x: 1 contributors (all time) y: 126 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorSinkOptionsUtils.java x: 1 contributors (all time) y: 213 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorSourceOptionsUtils.java x: 1 contributors (all time) y: 42 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisConsumerOptionsUtil.java x: 3 contributors (all time) y: 57 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConfiguration.java x: 2 contributors (all time) y: 38 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConnectorOptions.java x: 2 contributors (all time) y: 32 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSink.java x: 2 contributors (all time) y: 147 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java x: 2 contributors (all time) y: 47 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataElementConverter.java x: 2 contributors (all time) y: 49 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataToAttributeValueConverter.java x: 2 contributors (all time) y: 76 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumeratorState.java x: 1 contributors (all time) y: 21 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumeratorStateSerializer.java x: 1 contributors (all time) y: 87 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util/ShardUtils.java x: 1 contributors (all time) y: 30 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java x: 2 contributors (all time) y: 7 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java x: 6 contributors (all time) y: 355 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java x: 1 contributors (all time) y: 147 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitGraphInconsistencyTracker.java x: 1 contributors (all time) y: 69 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisStreamsSourceReader.java x: 3 contributors (all time) y: 77 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java x: 3 contributors (all time) y: 108 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitSerializer.java x: 2 contributors (all time) y: 129 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java x: 3 contributors (all time) y: 168 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDBStreamsShardSplitWithAssignmentStatus.java x: 1 contributors (all time) y: 47 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/SplitAssignmentStatus.java x: 1 contributors (all time) y: 23 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/metrics/DynamoDbStreamsShardMetrics.java x: 1 contributors (all time) y: 51 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy/DynamoDbStreamsProxy.java x: 1 contributors (all time) y: 180 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsConfigConstants.java x: 1 contributors (all time) y: 17 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSink.java x: 1 contributors (all time) y: 111 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkBuilder.java x: 1 contributors (all time) y: 72 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkElementConverter.java x: 1 contributors (all time) y: 52 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkWriter.java x: 1 contributors (all time) y: 176 lines of code flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/client/SdkClientProvider.java x: 1 contributors (all time) y: 8 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorState.java x: 2 contributors (all time) y: 20 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorStateSerializer.java x: 2 contributors (all time) y: 123 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/StartingPosition.java x: 1 contributors (all time) y: 58 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java x: 1 contributors (all time) y: 315 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java x: 2 contributors (all time) y: 223 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java x: 3 contributors (all time) y: 313 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkElementConverter.java x: 2 contributors (all time) y: 81 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSink.java x: 2 contributors (all time) y: 110 lines of code flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSchemaCoderProvider.java x: 2 contributors (all time) y: 18 lines of code flink-python/pyflink/datastream/connectors/kinesis.py x: 1 contributors (all time) y: 194 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java x: 2 contributors (all time) y: 166 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/RecoverableErrorsConfig.java x: 1 contributors (all time) y: 61 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisher.java x: 2 contributors (all time) y: 206 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisherConfiguration.java x: 2 contributors (all time) y: 315 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java x: 2 contributors (all time) y: 402 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java x: 2 contributors (all time) y: 448 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataKinesisDeserializationSchema.java x: 2 contributors (all time) y: 100 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicSink.java x: 1 contributors (all time) y: 133 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/RowDataFieldsKinesisPartitionKeyGenerator.java x: 1 contributors (all time) y: 145 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java x: 1 contributors (all time) y: 223 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtil.java x: 1 contributors (all time) y: 164 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilder.java x: 1 contributors (all time) y: 76 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java x: 1 contributors (all time) y: 310 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java x: 1 contributors (all time) y: 4 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/DynamoDBStreamsDataFetcher.java x: 1 contributors (all time) y: 84 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java x: 1 contributors (all time) y: 929 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java x: 1 contributors (all time) y: 151 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/AdaptivePollingRecordPublisher.java x: 1 contributors (all time) y: 79 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/PollingRecordPublisher.java x: 1 contributors (all time) y: 123 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardMetadata.java x: 1 contributors (all time) y: 172 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/DynamoDBStreamsProxy.java x: 1 contributors (all time) y: 96 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java x: 1 contributors (all time) y: 476 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java x: 1 contributors (all time) y: 188 lines of code
929.0
lines of code
  min: 4.0
  average: 82.98
  25th percentile: 22.0
  median: 49.5
  75th percentile: 100.0
  max: 929.0
0 7.0
contributors (all time)
min: 1.0 | average: 1.32 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 7.0

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 14 points

flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 1 commits (90d) y: 281 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java x: 1 commits (90d) y: 100 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisShardSplitReaderBase.java x: 1 commits (90d) y: 213 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReader.java x: 1 commits (90d) y: 64 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.java x: 1 commits (90d) y: 41 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java x: 1 commits (90d) y: 297 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner/UniformShardAssigner.java x: 1 commits (90d) y: 37 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java x: 1 commits (90d) y: 253 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsSourceReader.java x: 1 commits (90d) y: 125 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplit.java x: 1 commits (90d) y: 93 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplitSerializer.java x: 1 commits (90d) y: 90 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSource.java x: 1 commits (90d) y: 187 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java x: 1 commits (90d) y: 204 lines of code
297.0
lines of code
  min: 37.0
  average: 146.36
  25th percentile: 64.0
  median: 112.5
  75th percentile: 223.0
  max: 297.0
0 1.0
commits (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Contributors (90 days): 14 points

flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 1 contributors (90d) y: 281 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java x: 1 contributors (90d) y: 100 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisShardSplitReaderBase.java x: 1 contributors (90d) y: 213 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReader.java x: 1 contributors (90d) y: 64 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.java x: 1 contributors (90d) y: 41 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java x: 1 contributors (90d) y: 297 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner/UniformShardAssigner.java x: 1 contributors (90d) y: 37 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java x: 1 contributors (90d) y: 253 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsSourceReader.java x: 1 contributors (90d) y: 125 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplit.java x: 1 contributors (90d) y: 93 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplitSerializer.java x: 1 contributors (90d) y: 90 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSource.java x: 1 contributors (90d) y: 187 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java x: 1 contributors (90d) y: 204 lines of code
297.0
lines of code
  min: 37.0
  average: 146.36
  25th percentile: 64.0
  median: 112.5
  75th percentile: 223.0
  max: 297.0
0 1.0
contributors (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0