apache / flink-connector-aws
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 161 files with 13,041 lines of code in files.
    • 0 files that are 366+ days old (0 lines of code)
    • 18 files that are 181-365 days old (1,183 lines of code)
    • 2 files that are 91-180 days old (46 lines of code)
    • 141 files that are 31-90 days old (11,812 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
0% | 9% | <1% | 90% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 161 files with 13,041 lines of code in files.
    • 0 files have been last changed 366+ days ago (0 lines of code)
    • 15 files have been last changed 181-365 days ago (622 lines of code)
    • 5 files have been last changed 91-180 days ago (607 lines of code)
    • 141 files have been last changed 31-90 days ago (11,812 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
0% | 4% | 4% | 90% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, properties, md, sql, yml, avsc, json, yaml, gitignore, txt, gitmodules
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java0% | 8% | <1% | 90% | 0%
xml0% | 100% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java0% | 4% | 4% | 90% | 0%
xml0% | 100% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
flink-connector-aws-base0% | 94% | 5% | 0% | 0%
flink-formats-aws0% | 100% | 0% | 0% | 0%
tools0% | 100% | 0% | 0% | 0%
flink-connector-aws0% | 0% | 0% | 100% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-formats-aws0% | 100% | 0% | 0% | 0%
flink-connector-aws-base0% | 21% | 78% | 0% | 0%
tools0% | 100% | 0% | 0% | 0%
flink-connector-aws0% | 0% | 0% | 100% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
suppressions.xml
in tools/maven
 15 - 2022-09-09 2023-02-08 3 2 dannycranmer@apache.org liangtl@amazon.com
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
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
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
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
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
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
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
GlueSchemaRegistryAvroSerializationSchema.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 62 4 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryOutputStreamSerializer.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 56 4 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryInputStreamDeserializer.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 50 3 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryAvroSchemaCoder.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 48 5 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryJsonDeserializationSchema.java
in flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry
 45 5 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryJsonSerializationSchema.java
in flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry
 32 2 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryAvroDeserializationSchema.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 32 3 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
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
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
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
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
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
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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
suppressions.xml
in tools/maven
 15 - 2022-09-09 2023-02-08 3 2 dannycranmer@apache.org liangtl@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
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
GlueSchemaRegistryAvroDeserializationSchema.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 32 3 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryJsonSerializationSchema.java
in flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry
 32 2 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryJsonDeserializationSchema.java
in flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry
 45 5 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryAvroSchemaCoder.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 48 5 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryInputStreamDeserializer.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 50 3 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryOutputStreamSerializer.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 56 4 2023-02-08 2023-02-08 1 1 liangtl@amazon.com liangtl@amazon.com
GlueSchemaRegistryAvroSerializationSchema.java
in flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry
 62 4 2023-02-08 2023-02-08 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
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
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-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
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
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
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
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
Most Recently Created Files (Top 50)
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
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
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
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 70 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
Most Recently Changed Files (Top 50)
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
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
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
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
 70 2 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com