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 161 files with 13,041 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)
    • 0 files changed 6-20 times (0 lines of code)
    • 161 files changed 1-5 times (13,041 lines of code)
0% | 0% | 0% | 0% | 100%
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 161 files with 13,041 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)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 4 files changed by 2-5 contributors (576 lines of code)
    • 157 files changed by 1 contributor (12,465 lines of code)
0% | 0% | 0% | 4% | 95%
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, xml, properties, md, sql, yml, avsc, json, yaml, gitignore, txt, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 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% | 0% | 100%
flink-connector-aws-base0% | 0% | 0% | 0% | 100%
flink-formats-aws0% | 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
AWSGeneralUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
341 20 2022-12-02 2023-04-13 4 3 dannycranmer@apache.org kartoi@amazon.co.uk
suppressions.xml
in tools/maven
15 - 2022-09-09 2023-02-08 3 2 dannycranmer@apache.org liangtl@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
AWSClientUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
149 8 2023-01-17 2023-04-03 2 2 darenwkt@amazon.co.uk liangtl@amazon.com
AWSConfigConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config
4 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
PartitionKeyGenerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
7 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
SdkClientProvider.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client
8 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
InvalidRequestException.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
8 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
InvalidConfigurationException.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
8 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisDynamicShardAssignerFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
8 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisShardAssigner.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
8 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
ProducerConfigConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config
8 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisStreamsConfigConstants.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
9 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisStreamsSourceException.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/exception
9 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbConfigConstants.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
9 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseConfigConstants.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
9 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
ShardAssignerFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner
11 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisSerializationSchema.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization
11 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxyAsyncV2Interface.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
11 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
AWSAuthenticationException.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
11 2 2022-12-02 2022-12-02 1 1 dannycranmer@apache.org dannycranmer@apache.org
StreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
14 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxyInterface.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
15 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
FullJitterBackoff.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
15 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
UniformShardAssignerFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
16 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
RecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher
16 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisPartitioner.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
17 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DefaultShardAssignerFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
17 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
RecordPublisherFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher
17 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
FlinkKinesisException.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
17 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
AWSExceptionHandler.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/sink/throwable
17 3 2023-03-22 2023-03-22 1 1 siebenma@amazon.com siebenma@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 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisShardAssigner.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
18 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisDeserializationSchema.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/serialization
18 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisDeserializationSchema.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization
18 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
RandomKinesisPartitionKeyGenerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
19 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisStreamsException.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
19 4 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbSinkException.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
19 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisConsumerMetricConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics
19 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
UniformShardAssigner.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
20 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseConnectorOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table
20 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
AWSCredentialFatalExceptionClassifiers.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
20 2 2022-12-02 2022-12-02 1 1 dannycranmer@apache.org dannycranmer@apache.org
GlueSchemaRegistryAvroSchemaCoderProvider.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
21 3 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisStreamsSourceEnumeratorState.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
21 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
TimeoutLatch.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
21 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseException.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
21 4 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxySyncV2Interface.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
23 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDBStreamsShardHandle.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model
24 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDBStreamsSchema.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization
24 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbWriteRequestType.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
25 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbWriterStateSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
25 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
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
AWSGeneralUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
341 20 2022-12-02 2023-04-13 4 3 dannycranmer@apache.org kartoi@amazon.co.uk
suppressions.xml
in tools/maven
15 - 2022-09-09 2023-02-08 3 2 dannycranmer@apache.org liangtl@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
AWSClientUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
149 8 2023-01-17 2023-04-03 2 2 darenwkt@amazon.co.uk liangtl@amazon.com
AWSCredentialFatalExceptionClassifiers.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
20 2 2022-12-02 2022-12-02 1 1 dannycranmer@apache.org dannycranmer@apache.org
AWSAuthenticationException.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
11 2 2022-12-02 2022-12-02 1 1 dannycranmer@apache.org dannycranmer@apache.org
AWSExceptionHandler.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/sink/throwable
17 3 2023-03-22 2023-03-22 1 1 siebenma@amazon.com siebenma@amazon.com
AWSExceptionClassifierUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/sink/throwable
29 1 2023-03-22 2023-03-22 1 1 siebenma@amazon.com siebenma@amazon.com
AWSOptionUtils.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util
57 5 2022-12-02 2022-12-02 1 1 dannycranmer@apache.org dannycranmer@apache.org
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
KinesisFirehoseStateSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
27 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseException.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
21 4 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@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
KinesisFirehoseSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
193 7 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseSinkElementConverter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
67 6 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseConfigConstants.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
9 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
AWSFirehoseExceptionClassifiers.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
34 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@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
KinesisFirehoseConnectorOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table
20 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseConnectorOptionUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/util
39 3 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
KinesisFirehoseDynamicTableFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table
56 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
ShardConsumerMetricsReporter.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics
57 10 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
PollingRecordPublisherMetricsReporter.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics
54 11 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisConsumerMetricConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics
19 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.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
KinesisProxySyncV2Interface.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
23 - 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
KinesisProxyAsyncV2.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
34 3 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
GetShardListResult.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
47 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
FullJitterBackoff.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
15 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxyInterface.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
15 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxyAsyncV2Interface.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
11 - 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
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
WatermarkTracker.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
50 8 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisConfigUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
443 14 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
TimeoutLatch.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
21 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
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
BeanDeserializerModifierForIgnorables.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
48 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
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
AwsV2Util.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
52 6 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
UniformShardAssigner.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
20 1 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@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
FlinkKinesisConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
313 17 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
ProducerConfigConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config
8 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
ConsumerConfigConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config
164 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
AWSConfigConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config
4 - 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.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
KinesisConfigUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
443 14 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
FanOutShardSubscriber.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
376 28 2023-06-30 2023-06-30 1 1 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 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.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
FanOutRecordPublisherConfiguration.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
306 27 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
249 17 2023-06-30 2023-06-30 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
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 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
KinesisStreamsConnectorOptionsUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util
210 12 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
FanOutRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
205 6 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
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
KinesisFirehoseSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
193 7 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
193 15 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
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
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
ConsumerConfigConstants.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config
164 2 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
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
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
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
KinesisStreamsSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
143 7 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbDynamicSink.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
136 13 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
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
KinesisStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
116 6 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@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
PollingKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
107 10 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.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
RowDataKinesisDeserializationSchema.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
97 7 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
KinesisStreamsSourceEnumeratorStateSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
94 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
DynamoDbSink.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
93 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisDynamicTableSinkFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
91 3 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@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
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
KinesisStreamsSinkElementConverter.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
84 7 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
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
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
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
DynamoDbSinkBuilder.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink
72 8 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisShardSplitSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
72 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@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
Correlations

File Size vs. Number of Changes: 161 points

flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/AWSFirehoseExceptionClassifiers.java x: 34 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseConfigConstants.java x: 9 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/sink/KinesisFirehoseSinkElementConverter.java x: 67 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: 193 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseStateSerializer.java x: 27 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseConnectorOptions.java x: 20 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-firehose/src/main/java/org/apache/flink/connector/firehose/table/util/KinesisFirehoseConnectorOptionUtils.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/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/KinesisStreamsSinkElementConverter.java x: 84 lines of code y: 1 # 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: 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/sink/PartitionKeyGenerator.java x: 7 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 143 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: 42 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisShardAssigner.java x: 18 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java x: 249 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorStateSerializer.java x: 94 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/ShardAssignerFactory.java x: 11 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: 116 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/StreamProxy.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/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/reader/KinesisStreamsSourceReader.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/source/split/KinesisShardSplit.java x: 64 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitSerializer.java x: 72 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/FixedKinesisPartitionKeyGenerator.java x: 36 lines of code y: 1 # changes flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicTableSinkFactory.java x: 91 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-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorOptionsUtils.java x: 210 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSink.java x: 93 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequest.java x: 48 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestType.java x: 25 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConnectorOptions.java x: 26 lines of code y: 1 # changes flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSink.java x: 136 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/DynamoDbType.java x: 49 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/FlinkKinesisConsumer.java x: 313 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/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/RecordPublisher.java x: 16 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: 205 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisherConfiguration.java x: 306 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisherFactory.java x: 53 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java x: 376 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/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/proxy/KinesisProxySyncV2.java x: 146 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxySyncV2Interface.java x: 23 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/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java x: 443 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/RecordEmitter.java x: 175 lines of code y: 1 # changes flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/StreamConsumerRegistrarUtil.java x: 108 lines of code y: 1 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java x: 149 lines of code y: 2 # 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/util/AWSGeneralUtil.java x: 341 lines of code y: 4 # 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/GlueSchemaRegistryJsonDeserializationSchema.java x: 45 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 flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSerializationSchema.java x: 62 lines of code y: 1 # changes tools/maven/suppressions.xml x: 15 lines of code y: 3 # changes
4.0
# changes
  min: 1.0
  average: 1.05
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 929.0
lines of code
min: 4.0 | average: 81.0 | 25th percentile: 21.0 | median: 49.0 | 75th percentile: 90.0 | max: 929.0

Number of Contributors vs. Number of Changes: 161 points

flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/AWSFirehoseExceptionClassifiers.java x: 1 # contributors y: 1 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java x: 2 # contributors y: 2 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigConstants.java x: 2 # contributors y: 3 # changes flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java x: 3 # contributors y: 4 # changes
4.0
# changes
  min: 1.0
  average: 1.05
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 3.0
# contributors
min: 1.0 | average: 1.03 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

Number of Contributors vs. File Size: 161 points

flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/AWSFirehoseExceptionClassifiers.java x: 1 # contributors y: 34 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseConfigConstants.java x: 1 # contributors y: 9 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseException.java x: 1 # contributors y: 21 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSink.java x: 1 # contributors y: 89 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkBuilder.java x: 1 # contributors y: 70 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkElementConverter.java x: 1 # contributors y: 67 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java x: 1 # contributors y: 193 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseStateSerializer.java x: 1 # contributors y: 27 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-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicTableFactory.java x: 1 # contributors y: 56 lines of code flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/util/KinesisFirehoseConnectorOptionUtils.java x: 1 # contributors y: 39 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSink.java x: 1 # contributors y: 107 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkElementConverter.java x: 1 # contributors y: 84 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java x: 1 # contributors y: 223 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsStateSerializer.java x: 1 # contributors y: 54 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java x: 1 # contributors y: 7 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java x: 1 # contributors y: 143 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSourceBuilder.java x: 1 # contributors y: 42 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisShardAssigner.java x: 1 # contributors y: 18 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java x: 1 # contributors y: 249 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorStateSerializer.java x: 1 # contributors y: 94 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/ShardAssignerFactory.java x: 1 # contributors y: 11 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisStreamProxy.java x: 1 # contributors y: 116 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisStreamsRecordEmitter.java x: 1 # contributors y: 46 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java x: 1 # contributors y: 64 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPosition.java x: 1 # contributors y: 59 lines of code flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorOptionsUtils.java x: 1 # contributors y: 210 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequest.java x: 1 # contributors y: 48 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestType.java x: 1 # contributors y: 25 lines of code flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSink.java x: 1 # contributors y: 136 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/FlinkKinesisConsumer.java x: 1 # contributors y: 313 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/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/fanout/FanOutRecordPublisher.java x: 1 # contributors y: 205 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisherConfiguration.java x: 1 # contributors y: 306 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java x: 1 # contributors y: 376 lines of code flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/StreamConsumerRegistrar.java x: 1 # contributors y: 215 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/table/KinesisDynamicSource.java x: 1 # contributors y: 200 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 flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java x: 1 # contributors y: 443 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java x: 2 # contributors y: 149 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigConstants.java x: 2 # contributors y: 71 lines of code flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java x: 3 # contributors y: 341 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 # contributors y: 32 lines of code tools/maven/suppressions.xml x: 2 # contributors y: 15 lines of code
929.0
lines of code
  min: 4.0
  average: 81.0
  25th percentile: 21.0
  median: 49.0
  75th percentile: 90.0
  max: 929.0
0 3.0
# contributors
min: 1.0 | average: 1.03 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0