apache / flink-connector-aws
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 230 files with 19,085 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 5 files changed 6-20 times (1,426 lines of code)
    • 225 files changed 1-5 times (17,659 lines of code)
0% | 0% | 0% | 7% | 92%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 230 files with 19,085 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 2 files changed by 6-10 contributors (636 lines of code)
    • 50 files changed by 2-5 contributors (6,081 lines of code)
    • 178 files changed by 1 contributor (12,368 lines of code)
0% | 0% | 3% | 31% | 64%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, properties, xml, md, yaml, sql, py, avsc, txt, sh, in, ini, gitignore, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 7% | 92%
py0% | 0% | 0% | 0% | 100%
in0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
flink-connector-aws0% | 0% | 0% | 6% | 93%
flink-connector-aws-base0% | 0% | 0% | 37% | 62%
flink-formats-aws0% | 0% | 0% | 0% | 100%
flink-python0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KinesisStreamsSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
 281 11 2023-06-30 2025-04-03 10 7 liangtl@amazon.com leekeiabstraction@gmail.com
AWSGeneralUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
 355 23 2022-12-02 2024-09-27 7 6 dannycranmer@apache.org etoringe@amazon.co.uk
DynamoDbStreamsSource.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source
 187 6 2024-06-20 2025-02-18 6 2 gguptp@amazon.com gguptp@amazon.com
SplitTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
 253 22 2024-07-18 2025-03-24 6 1 gguptp@amazon.com gguptp@amazon.com
KinesisStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 350 22 2023-06-30 2024-09-16 6 3 liangtl@amazon.com burakoz@amazon.co.uk
KinesisStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
 166 10 2023-06-30 2024-10-31 5 4 liangtl@amazon.com etoringe@amazon.co.uk
DynamoDbStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 297 20 2024-06-20 2025-03-24 5 1 gguptp@amazon.com gguptp@amazon.com
StreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
 26 - 2023-06-30 2024-09-16 4 3 liangtl@amazon.com burakoz@amazon.co.uk
KinesisStreamsSourceConfigUtil.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
 70 3 2023-06-30 2024-09-24 4 3 liangtl@amazon.com burakoz@amazon.co.uk
KinesisStreamsSourceReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
 77 8 2023-06-30 2024-09-05 4 3 liangtl@amazon.com liangtl@amazon.com
KinesisStreamsSourceBuilder.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
 86 13 2023-06-30 2024-09-16 4 3 liangtl@amazon.com burakoz@amazon.co.uk
KinesisSourceConfigOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
 100 - 2024-09-12 2025-04-03 4 3 liangtl@amazon.com leekeiabstraction@gmail.com
KinesisShardSplit.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 108 11 2023-06-30 2024-09-04 4 3 liangtl@amazon.com liangtl@amazon.com
DynamoDbStreamsSourceReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
 125 10 2024-06-20 2025-03-24 4 2 gguptp@amazon.com gguptp@amazon.com
PollingDynamoDbStreamsShardSplitReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
 204 13 2024-06-20 2025-02-18 4 2 gguptp@amazon.com gguptp@amazon.com
suppressions.xml
in tools/maven
 15 - 2022-09-09 2023-02-08 3 2 dannycranmer@apache.org liangtl@amazon.com
DynamoDbStreamsSourceEnumeratorState.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 21 3 2024-06-20 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
ShardUtils.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util
 30 4 2024-07-18 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
PollingKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling
 41 3 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
KinesisShardSplitState.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 42 9 2023-06-30 2024-09-04 3 2 liangtl@amazon.com liangtl@amazon.com
KinesisConsumerOptionsUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 57 5 2023-06-30 2024-09-24 3 3 liangtl@amazon.com burakoz@amazon.co.uk
FanOutKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 64 4 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
DynamodbStreamsSourceConfigConstants.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config
 64 - 2024-06-20 2025-02-18 3 1 gguptp@amazon.com gguptp@amazon.com
SplitGraphInconsistencyTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
 69 8 2024-07-18 2024-09-09 3 1 gguptp@amazon.com gguptp@amazon.com
AWSConfigConstants.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config
 71 11 2022-12-02 2023-04-13 3 2 dannycranmer@apache.org kartoi@amazon.co.uk
DynamoDbStreamsSourceEnumeratorStateSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 87 3 2024-06-20 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardSplitSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
 90 2 2024-06-20 2025-03-24 3 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardSplit.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
 93 11 2024-06-20 2025-03-24 3 1 gguptp@amazon.com gguptp@amazon.com
KinesisShardSplitSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 129 2 2023-06-30 2024-09-04 3 2 liangtl@amazon.com liangtl@amazon.com
AWSClientUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
 168 9 2023-01-17 2024-09-04 3 3 darenwkt@amazon.co.uk gguptp@amazon.com
KinesisShardSplitReaderBase.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
 213 16 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
FlinkKinesisConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
 313 17 2023-06-30 2024-04-17 3 3 liangtl@amazon.com pilipa@amazon.co.uk
PartitionKeyGenerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
 7 - 2023-06-30 2024-10-12 2 2 liangtl@amazon.com jorick.caberio@gmail.com
StreamProxy.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy
 13 - 2024-06-20 2024-07-18 2 1 gguptp@amazon.com gguptp@amazon.com
GlueSchemaRegistryJsonSchemaCoderProvider.java
in flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry
 18 2 2023-02-08 2024-01-29 2 2 liangtl@amazon.com z3d1kk@gmail.com
KinesisStreamsSourceEnumeratorState.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 20 3 2023-06-30 2024-06-27 2 2 liangtl@amazon.com z3d1kk@gmail.com
UniformShardAssigner.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner
 30 1 2023-06-30 2024-09-04 2 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbConnectorOptions.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 32 1 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
UniformShardAssigner.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner
 37 1 2024-06-20 2025-03-24 2 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbConfiguration.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 38 6 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
DynamoDbBeanElementConverter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 39 5 2023-06-30 2024-04-08 2 2 liangtl@amazon.com ahmed.hamdy@ververica.com
DynamoDbStreamsShardSplitState.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
 40 9 2024-06-20 2024-07-18 2 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbAsyncClientProvider.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client
 43 5 2023-06-30 2023-10-31 2 2 liangtl@amazon.com dannycranmer@apache.org
DynamoDbDynamicSinkFactory.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 47 2 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
RowDataElementConverter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 49 3 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
AWSOptionUtils.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util
 57 5 2022-12-02 2024-09-24 2 2 dannycranmer@apache.org burakoz@amazon.co.uk
AwsV2Util.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 57 6 2023-06-30 2024-08-04 2 2 liangtl@amazon.com z3d1kk@gmail.com
KinesisFirehoseSinkElementConverter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
 64 6 2023-06-30 2024-04-08 2 2 liangtl@amazon.com ahmed.hamdy@ververica.com
KinesisConnectorOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 70 - 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 70 2 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KinesisStreamsSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
 281 11 2023-06-30 2025-04-03 10 7 liangtl@amazon.com leekeiabstraction@gmail.com
AWSGeneralUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
 355 23 2022-12-02 2024-09-27 7 6 dannycranmer@apache.org etoringe@amazon.co.uk
KinesisStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
 166 10 2023-06-30 2024-10-31 5 4 liangtl@amazon.com etoringe@amazon.co.uk
KinesisStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 350 22 2023-06-30 2024-09-16 6 3 liangtl@amazon.com burakoz@amazon.co.uk
KinesisSourceConfigOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
 100 - 2024-09-12 2025-04-03 4 3 liangtl@amazon.com leekeiabstraction@gmail.com
KinesisStreamsSourceConfigUtil.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
 70 3 2023-06-30 2024-09-24 4 3 liangtl@amazon.com burakoz@amazon.co.uk
StreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
 26 - 2023-06-30 2024-09-16 4 3 liangtl@amazon.com burakoz@amazon.co.uk
KinesisStreamsSourceBuilder.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
 86 13 2023-06-30 2024-09-16 4 3 liangtl@amazon.com burakoz@amazon.co.uk
KinesisShardSplit.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 108 11 2023-06-30 2024-09-04 4 3 liangtl@amazon.com liangtl@amazon.com
KinesisStreamsSourceReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
 77 8 2023-06-30 2024-09-05 4 3 liangtl@amazon.com liangtl@amazon.com
FlinkKinesisConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
 313 17 2023-06-30 2024-04-17 3 3 liangtl@amazon.com pilipa@amazon.co.uk
KinesisConsumerOptionsUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 57 5 2023-06-30 2024-09-24 3 3 liangtl@amazon.com burakoz@amazon.co.uk
AWSClientUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
 168 9 2023-01-17 2024-09-04 3 3 darenwkt@amazon.co.uk gguptp@amazon.com
DynamoDbStreamsSource.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source
 187 6 2024-06-20 2025-02-18 6 2 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSourceReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
 125 10 2024-06-20 2025-03-24 4 2 gguptp@amazon.com gguptp@amazon.com
PollingDynamoDbStreamsShardSplitReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
 204 13 2024-06-20 2025-02-18 4 2 gguptp@amazon.com gguptp@amazon.com
suppressions.xml
in tools/maven
 15 - 2022-09-09 2023-02-08 3 2 dannycranmer@apache.org liangtl@amazon.com
KinesisShardSplitSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 129 2 2023-06-30 2024-09-04 3 2 liangtl@amazon.com liangtl@amazon.com
KinesisShardSplitState.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
 42 9 2023-06-30 2024-09-04 3 2 liangtl@amazon.com liangtl@amazon.com
PollingKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling
 41 3 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
FanOutKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 64 4 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
KinesisShardSplitReaderBase.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
 213 16 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
AWSConfigConstants.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config
 71 11 2022-12-02 2023-04-13 3 2 dannycranmer@apache.org kartoi@amazon.co.uk
KinesisFirehoseSinkElementConverter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
 64 6 2023-06-30 2024-04-08 2 2 liangtl@amazon.com ahmed.hamdy@ververica.com
KinesisFirehoseSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
 190 7 2023-06-30 2024-04-29 2 2 liangtl@amazon.com pilipa@amazon.co.uk
DynamoDbConfiguration.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 38 6 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
RowDataElementConverter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 49 3 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
DynamoDbDynamicSink.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 147 14 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
DynamoDbConnectorOptions.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 32 1 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
DynamoDbDynamicSinkFactory.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 47 2 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
RowDataToAttributeValueConverter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
 76 5 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
DynamoDbSink.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 110 4 2023-06-30 2024-01-29 2 2 liangtl@amazon.com z3d1kk@gmail.com
DynamoDbAsyncClientProvider.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client
 43 5 2023-06-30 2023-10-31 2 2 liangtl@amazon.com dannycranmer@apache.org
DynamoDbBeanElementConverter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 39 5 2023-06-30 2024-04-08 2 2 liangtl@amazon.com ahmed.hamdy@ververica.com
DynamoDbSinkBuilder.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 73 8 2023-06-30 2024-04-08 2 2 liangtl@amazon.com ahmed.hamdy@ververica.com
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 70 2 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
RowDataKinesisDeserializationSchema.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 100 7 2023-06-30 2023-10-02 2 2 liangtl@amazon.com pilipa@amazon.co.uk
ConsumerConfigConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config
 166 2 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
AwsV2Util.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 57 6 2023-06-30 2024-08-04 2 2 liangtl@amazon.com z3d1kk@gmail.com
KinesisConfigUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 448 15 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
FanOutRecordPublisherConfiguration.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 315 29 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
FanOutRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 206 6 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
FanOutShardSubscriber.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 402 30 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
KinesisDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 198 16 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
KinesisConnectorOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 70 - 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
PartitionKeyGenerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
 7 - 2023-06-30 2024-10-12 2 2 liangtl@amazon.com jorick.caberio@gmail.com
KinesisStreamsSinkElementConverter.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
 81 7 2023-06-30 2024-04-08 2 2 liangtl@amazon.com ahmed.hamdy@ververica.com
KinesisStreamsSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
 223 8 2023-06-30 2024-04-29 2 2 liangtl@amazon.com pilipa@amazon.co.uk
KinesisStreamsSourceEnumeratorStateSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 123 3 2023-06-30 2024-06-27 2 2 liangtl@amazon.com z3d1kk@gmail.com
KinesisStreamsSourceEnumeratorState.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
 20 3 2023-06-30 2024-06-27 2 2 liangtl@amazon.com z3d1kk@gmail.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KinesisDataFetcher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 929 44 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxy.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 476 14 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbTypeInformedElementConverter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 315 14 2024-04-08 2024-04-08 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com
FlinkKinesisProducer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
 310 17 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 297 20 2024-06-20 2025-03-24 5 1 gguptp@amazon.com gguptp@amazon.com
SplitTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
 253 22 2024-07-18 2025-03-24 6 1 gguptp@amazon.com gguptp@amazon.com
FanOutKinesisShardSubscription.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 252 11 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbSinkWriter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
 223 9 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
StreamConsumerRegistrar.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
 215 15 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisStreamsConnectorSinkOptionsUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util
 213 12 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisDynamicSource.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 200 11 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
SqsDynamicSink.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
 199 15 2024-08-17 2024-08-17 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com
kinesis.py
in flink-python/pyflink/datastream/connectors
 194 42 2023-12-18 2023-12-18 1 1 dannycranmer@apache.org dannycranmer@apache.org
AWSUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 188 8 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisDynamicSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 184 11 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
DynamoDbStreamsProxy.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy
 180 7 2024-06-20 2024-07-18 2 1 gguptp@amazon.com gguptp@amazon.com
SqsSinkWriter.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink
 176 6 2024-05-10 2024-05-10 1 1 dhipriya@amazon.com dhipriya@amazon.com
RecordEmitter.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 175 13 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
StreamShardMetadata.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model
 172 23 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbSerializationUtil.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util
 164 7 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
ShardConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 151 7 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
AWSConfigOptions.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config
 147 - 2024-09-16 2024-09-16 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
JobManagerWatermarkTracker.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 146 8 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxySyncV2.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 146 9 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
RowDataFieldsKinesisPartitionKeyGenerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 145 8 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table
 133 11 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
 126 4 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
PollingRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling
 123 6 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
StreamConsumerRegistrar.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
 117 4 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
SqsSink.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink
 111 3 2024-05-10 2024-05-10 1 1 dhipriya@amazon.com dhipriya@amazon.com
StreamConsumerRegistrarUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 108 9 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
SqsDynamicTableFactory.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
 108 5 2024-08-17 2024-08-17 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com
KinesisStreamsSink.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
 107 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDBStreamsProxy.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 96 6 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbStreamsShardSplit.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
 93 11 2024-06-20 2025-03-24 3 1 gguptp@amazon.com gguptp@amazon.com
setup.py
in flink-python
 91 4 2023-12-18 2023-12-18 1 1 dannycranmer@apache.org dannycranmer@apache.org
DynamoDbStreamsShardSplitSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
 90 2 2024-06-20 2025-03-24 3 1 gguptp@amazon.com gguptp@amazon.com
KinesisFirehoseSink.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
 89 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbStreamsSourceEnumeratorStateSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
 87 3 2024-06-20 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
SplitTracker.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/tracker
 87 10 2024-06-27 2024-06-27 1 1 z3d1kk@gmail.com z3d1kk@gmail.com
DynamoDBStreamsDataFetcher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 84 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisStreamShard.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model
 83 8 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
AdaptivePollingRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling
 79 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryJsonSchemaCoder.java
in flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry
 79 3 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
PrimaryKeyBuilder.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util
 76 4 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
AsyncClientOptionsUtils.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util
 76 7 2022-12-02 2022-12-02 1 1 dannycranmer@apache.org dannycranmer@apache.org
KinesisStreamsSinkBuilder.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
 73 7 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
SqsSinkBuilder.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink
 72 6 2024-05-10 2024-05-10 1 1 dhipriya@amazon.com dhipriya@amazon.com
KinesisFirehoseSinkBuilder.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
 70 6 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxyV2Factory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
 70 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
Correlations

File Size vs. Number of Changes: 230 points

flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 281 lines of code y: 10 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java x: 100 lines of code y: 4 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisShardSplitReaderBase.java x: 213 lines of code y: 3 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReader.java x: 64 lines of code y: 3 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.java x: 41 lines of code y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java x: 297 lines of code y: 5 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner/UniformShardAssigner.java x: 37 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java x: 253 lines of code y: 6 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsSourceReader.java x: 125 lines of code y: 4 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplit.java x: 93 lines of code y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplitSerializer.java x: 90 lines of code y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSource.java x: 187 lines of code y: 6 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java x: 204 lines of code y: 4 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsConnectorOptions.java x: 28 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicSink.java x: 199 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicTableFactory.java x: 108 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSourceBuilder.java x: 86 lines of code y: 4 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java x: 350 lines of code y: 6 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/AsyncStreamProxy.java x: 14 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisAsyncStreamProxy.java x: 39 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisStreamProxy.java x: 166 lines of code y: 5 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/StreamProxy.java x: 26 lines of code y: 4 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSubscription.java x: 252 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/StreamConsumerRegistrar.java x: 117 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPositionUtil.java x: 36 lines of code y: 1 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util/AWSOptionUtils.java x: 57 lines of code y: 2 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisStreamsSourceConfigUtil.java x: 70 lines of code y: 4 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisConnectorOptions.java x: 70 lines of code y: 2 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSink.java x: 198 lines of code y: 2 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSource.java x: 184 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicTableFactory.java x: 126 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/RowMetadata.java x: 37 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorSinkOptionsUtils.java x: 213 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorSourceOptionsUtils.java x: 42 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisConsumerOptionsUtil.java x: 57 lines of code y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConnectorOptions.java x: 32 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSink.java x: 147 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java x: 47 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataElementConverter.java x: 49 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataToAttributeValueConverter.java x: 76 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumeratorState.java x: 21 lines of code y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumeratorStateSerializer.java x: 87 lines of code y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util/ShardUtils.java x: 30 lines of code y: 3 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java x: 7 lines of code y: 2 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java x: 355 lines of code y: 7 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java x: 147 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitGraphInconsistencyTracker.java x: 69 lines of code y: 3 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisStreamsSourceReader.java x: 77 lines of code y: 4 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/UniformShardAssigner.java x: 30 lines of code y: 2 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java x: 108 lines of code y: 4 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitSerializer.java x: 129 lines of code y: 3 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitState.java x: 42 lines of code y: 3 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java x: 168 lines of code y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDBStreamsShardSplitWithAssignmentStatus.java x: 47 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/SplitAssignmentStatus.java x: 23 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/metrics/DynamoDbStreamsShardMetrics.java x: 51 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/metrics/MetricConstants.java x: 11 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy/DynamoDbStreamsProxy.java x: 180 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy/StreamProxy.java x: 13 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplitState.java x: 40 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util/ListShardsResult.java x: 65 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsConfigConstants.java x: 17 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsExceptionClassifiers.java x: 34 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSink.java x: 111 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkBuilder.java x: 72 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkElementConverter.java x: 52 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkWriter.java x: 176 lines of code y: 1 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/client/SdkClientProvider.java x: 8 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisShardSplitWithAssignmentStatus.java x: 45 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorState.java x: 20 lines of code y: 2 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorStateSerializer.java x: 123 lines of code y: 2 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTracker.java x: 87 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/exception/DynamoDbStreamsSourceException.java x: 10 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/serialization/DynamoDbStreamsDeserializationSchema.java x: 16 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/StartingPosition.java x: 58 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkBuilder.java x: 73 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java x: 315 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/metrics/KinesisShardMetrics.java x: 50 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java x: 190 lines of code y: 2 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java x: 223 lines of code y: 2 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java x: 313 lines of code y: 3 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkElementConverter.java x: 64 lines of code y: 2 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkElementConverter.java x: 81 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSink.java x: 110 lines of code y: 2 # changes flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSchemaCoderProvider.java x: 18 lines of code y: 2 # changes flink-python/MANIFEST.in x: 19 lines of code y: 1 # changes flink-python/pyflink/datastream/connectors/kinesis.py x: 194 lines of code y: 1 # changes flink-python/setup.py x: 91 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java x: 166 lines of code y: 2 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/RecoverableErrorsConfig.java x: 61 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisher.java x: 206 lines of code y: 2 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisherConfiguration.java x: 315 lines of code y: 2 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java x: 402 lines of code y: 2 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java x: 448 lines of code y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java x: 43 lines of code y: 2 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataKinesisDeserializationSchema.java x: 100 lines of code y: 2 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisStateUtil.java x: 24 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseException.java x: 21 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSink.java x: 89 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkBuilder.java x: 70 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicSink.java x: 133 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicTableFactory.java x: 56 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSink.java x: 107 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkBuilder.java x: 73 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsStateSerializer.java x: 54 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisStreamsRecordEmitter.java x: 46 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPosition.java x: 59 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/RowDataFieldsKinesisPartitionKeyGenerator.java x: 145 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java x: 223 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtil.java x: 164 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilder.java x: 76 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java x: 310 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java x: 4 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/DynamoDBStreamsDataFetcher.java x: 84 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java x: 929 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java x: 151 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/StreamConsumerRegistrar.java x: 215 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/AdaptivePollingRecordPublisher.java x: 79 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/PollingRecordPublisher.java x: 123 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java x: 83 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShardState.java x: 63 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SentinelSequenceNumber.java x: 26 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardMetadata.java x: 172 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/DynamoDBStreamsProxy.java x: 96 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java x: 476 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicSource.java x: 200 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java x: 188 lines of code y: 1 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigConstants.java x: 71 lines of code y: 3 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/sink/throwable/AWSExceptionClassifierUtil.java x: 29 lines of code y: 1 # changes flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSerializationSchema.java x: 32 lines of code y: 1 # changes tools/maven/suppressions.xml x: 15 lines of code y: 3 # changes
10.0
# changes
  min: 1.0
  average: 1.57
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 10.0
0 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

Number of Contributors vs. Number of Changes: 230 points

flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 7 # contributors y: 10 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java x: 3 # contributors y: 4 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisShardSplitReaderBase.java x: 2 # contributors y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java x: 1 # contributors y: 5 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner/UniformShardAssigner.java x: 1 # contributors y: 2 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java x: 1 # contributors y: 6 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsSourceReader.java x: 2 # contributors y: 4 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplit.java x: 1 # contributors y: 3 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSource.java x: 2 # contributors y: 6 # changes flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsConnectorOptions.java x: 1 # contributors y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java x: 3 # contributors y: 6 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisStreamProxy.java x: 4 # contributors y: 5 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util/AWSOptionUtils.java x: 2 # contributors y: 2 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisConsumerOptionsUtil.java x: 3 # contributors y: 3 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java x: 6 # contributors y: 7 # changes
10.0
# changes
  min: 1.0
  average: 1.57
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 10.0
0 7.0
# contributors
min: 1.0 | average: 1.32 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 7.0

Number of Contributors vs. File Size: 230 points

flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 7 # contributors 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 y: 36 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util/AWSOptionUtils.java x: 2 # contributors 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 y: 7 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java x: 6 # contributors y: 355 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java x: 1 # contributors 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 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 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 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 y: 129 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java x: 3 # contributors 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 y: 18 lines of code flink-python/pyflink/datastream/connectors/kinesis.py x: 1 # contributors 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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
min: 1.0 | average: 1.32 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 7.0