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 230 files with 19,085 lines of code in files.
    • 165 files that are 366+ days old (14,042 lines of code)
    • 65 files that are 181-365 days old (5,043 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
73% | 26% | 0% | 0% | 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 230 files with 19,085 lines of code in files.
    • 137 files have been last changed 366+ days ago (11,106 lines of code)
    • 79 files have been last changed 181-365 days ago (5,930 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 14 files have been last changed 31-90 days ago (2,049 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
58% | 31% | 0% | 10% | 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, properties, xml, md, yaml, sql, py, avsc, txt, sh, in, ini, gitignore, gitmodules
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java73% | 26% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
in100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java57% | 31% | 0% | 10% | 0%
py100% | 0% | 0% | 0% | 0%
in100% | 0% | 0% | 0% | 0%
xml100% | 0% | 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-aws71% | 28% | 0% | 0% | 0%
flink-connector-aws-base84% | 15% | 0% | 0% | 0%
flink-formats-aws100% | 0% | 0% | 0% | 0%
flink-python100% | 0% | 0% | 0% | 0%
tools100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-connector-aws58% | 29% | 0% | 11% | 0%
flink-formats-aws100% | 0% | 0% | 0% | 0%
flink-python100% | 0% | 0% | 0% | 0%
flink-connector-aws-base23% | 76% | 0% | 0% | 0%
tools100% | 0% | 0% | 0% | 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
355 23 2022-12-02 2024-09-27 7 6 dannycranmer@apache.org etoringe@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 2024-09-24 2 2 dannycranmer@apache.org burakoz@amazon.co.uk
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
168 9 2023-01-17 2024-09-04 3 3 darenwkt@amazon.co.uk gguptp@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 2024-01-29 2 2 liangtl@amazon.com z3d1kk@gmail.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
448 15 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
FanOutShardSubscriber.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
402 30 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
KinesisStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
350 22 2023-06-30 2024-09-16 6 3 liangtl@amazon.com burakoz@amazon.co.uk
FanOutRecordPublisherConfiguration.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
315 29 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
FlinkKinesisConsumer.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis
313 17 2023-06-30 2024-04-17 3 3 liangtl@amazon.com pilipa@amazon.co.uk
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
KinesisStreamsSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
281 11 2023-06-30 2025-04-03 10 7 liangtl@amazon.com leekeiabstraction@gmail.com
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 2024-04-29 2 2 liangtl@amazon.com pilipa@amazon.co.uk
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
FanOutRecordPublisher.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout
206 6 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
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
KinesisDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
198 16 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
KinesisFirehoseSinkWriter.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink
190 7 2023-06-30 2024-04-29 2 2 liangtl@amazon.com pilipa@amazon.co.uk
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
166 2 2023-06-30 2023-11-07 2 2 liangtl@amazon.com 969071+iemre@users.noreply....
KinesisStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
166 10 2023-06-30 2024-10-31 5 4 liangtl@amazon.com etoringe@amazon.co.uk
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
DynamoDbDynamicSink.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table
147 14 2023-06-30 2024-08-10 2 2 liangtl@amazon.com maoxingda@meican.com
JobManagerWatermarkTracker.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
146 8 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisProxySyncV2.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy
146 9 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
RowDataFieldsKinesisPartitionKeyGenerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
145 8 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisFirehoseDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table
133 11 2023-06-30 2023-06-30 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisShardSplitSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
129 2 2023-06-30 2024-09-04 3 2 liangtl@amazon.com liangtl@amazon.com
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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-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
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
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
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
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
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
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
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
KinesisStreamsConnectorSinkOptionsUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util
213 12 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisDynamicSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
184 11 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
126 4 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisStreamsConnectorSourceOptionsUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util
42 4 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
RowMetadata.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
37 3 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
AWSConfigOptions.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config
147 - 2024-09-16 2024-09-16 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
FanOutKinesisShardSubscription.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
252 11 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
StreamConsumerRegistrar.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
117 4 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisSourceConfigOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
100 - 2024-09-12 2025-04-03 4 3 liangtl@amazon.com leekeiabstraction@gmail.com
KinesisAsyncStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
39 3 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
StartingPositionUtil.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
36 1 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
AsyncStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
14 - 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisShardSplitReaderBase.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
213 16 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
FanOutKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
64 4 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
PollingKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling
41 3 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
SqsDynamicSink.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
199 15 2024-08-17 2024-08-17 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com
SqsDynamicTableFactory.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
108 5 2024-08-17 2024-08-17 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com
SqsConnectorOptions.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
28 - 2024-08-17 2024-08-17 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com
SplitTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
253 22 2024-07-18 2025-03-24 6 1 gguptp@amazon.com gguptp@amazon.com
SplitGraphInconsistencyTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
69 8 2024-07-18 2024-09-09 3 1 gguptp@amazon.com gguptp@amazon.com
ListShardsResult.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util
65 10 2024-07-18 2024-07-18 1 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardMetrics.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/metrics
51 5 2024-07-18 2024-07-18 1 1 gguptp@amazon.com gguptp@amazon.com
DynamoDBStreamsShardSplitWithAssignmentStatus.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
47 6 2024-07-18 2024-07-18 1 1 gguptp@amazon.com gguptp@amazon.com
ShardUtils.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util
30 4 2024-07-18 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
SplitAssignmentStatus.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
23 2 2024-07-18 2024-07-18 1 1 gguptp@amazon.com gguptp@amazon.com
SplitsFinishedEvent.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/event
22 3 2024-07-18 2024-07-18 1 1 gguptp@amazon.com gguptp@amazon.com
MetricConstants.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/metrics
11 - 2024-07-18 2024-07-18 1 1 gguptp@amazon.com gguptp@amazon.com
SplitTracker.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/tracker
87 10 2024-06-27 2024-06-27 1 1 z3d1kk@gmail.com z3d1kk@gmail.com
KinesisShardSplitWithAssignmentStatus.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
45 6 2024-06-27 2024-06-27 1 1 z3d1kk@gmail.com z3d1kk@gmail.com
ListShardsStartingPosition.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
36 5 2024-06-27 2024-06-27 1 1 z3d1kk@gmail.com z3d1kk@gmail.com
SplitsFinishedEvent.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/event
22 3 2024-06-27 2024-06-27 1 1 z3d1kk@gmail.com z3d1kk@gmail.com
SplitAssignmentStatus.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
22 2 2024-06-27 2024-06-27 1 1 z3d1kk@gmail.com z3d1kk@gmail.com
KinesisStreamsSourceEnumeratorStateV0.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
22 3 2024-06-27 2024-06-27 1 1 z3d1kk@gmail.com z3d1kk@gmail.com
DynamoDbStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
297 20 2024-06-20 2025-03-24 5 1 gguptp@amazon.com gguptp@amazon.com
PollingDynamoDbStreamsShardSplitReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
204 13 2024-06-20 2025-02-18 4 2 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSource.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source
187 6 2024-06-20 2025-02-18 6 2 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsProxy.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy
180 7 2024-06-20 2024-07-18 2 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSourceReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
125 10 2024-06-20 2025-03-24 4 2 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardSplit.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
93 11 2024-06-20 2025-03-24 3 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardSplitSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
90 2 2024-06-20 2025-03-24 3 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSourceEnumeratorStateSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
87 3 2024-06-20 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
DynamodbStreamsSourceConfigConstants.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config
64 - 2024-06-20 2025-02-18 3 1 gguptp@amazon.com gguptp@amazon.com
StartingPosition.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
58 8 2024-06-20 2024-06-20 1 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsRecordEmitter.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
48 6 2024-06-20 2024-06-20 1 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSourceBuilder.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source
43 6 2024-06-20 2024-06-20 1 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardSplitState.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
40 9 2024-06-20 2024-07-18 2 1 gguptp@amazon.com gguptp@amazon.com
UniformShardAssigner.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner
37 1 2024-06-20 2025-03-24 2 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSourceEnumeratorState.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
21 3 2024-06-20 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardAssigner.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
18 - 2024-06-20 2024-06-20 1 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsDeserializationSchema.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/serialization
16 1 2024-06-20 2024-06-20 1 1 gguptp@amazon.com gguptp@amazon.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
KinesisStreamsSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
281 11 2023-06-30 2025-04-03 10 7 liangtl@amazon.com leekeiabstraction@gmail.com
KinesisShardSplitReaderBase.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
213 16 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
KinesisSourceConfigOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
100 - 2024-09-12 2025-04-03 4 3 liangtl@amazon.com leekeiabstraction@gmail.com
FanOutKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
64 4 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
PollingKinesisShardSplitReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling
41 3 2024-09-05 2025-04-03 3 2 liangtl@amazon.com leekeiabstraction@gmail.com
DynamoDbStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
297 20 2024-06-20 2025-03-24 5 1 gguptp@amazon.com gguptp@amazon.com
SplitTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
253 22 2024-07-18 2025-03-24 6 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSourceReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
125 10 2024-06-20 2025-03-24 4 2 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardSplit.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
93 11 2024-06-20 2025-03-24 3 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsShardSplitSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split
90 2 2024-06-20 2025-03-24 3 1 gguptp@amazon.com gguptp@amazon.com
UniformShardAssigner.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner
37 1 2024-06-20 2025-03-24 2 1 gguptp@amazon.com gguptp@amazon.com
PollingDynamoDbStreamsShardSplitReader.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader
204 13 2024-06-20 2025-02-18 4 2 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSource.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source
187 6 2024-06-20 2025-02-18 6 2 gguptp@amazon.com gguptp@amazon.com
DynamodbStreamsSourceConfigConstants.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config
64 - 2024-06-20 2025-02-18 3 1 gguptp@amazon.com gguptp@amazon.com
KinesisStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
166 10 2023-06-30 2024-10-31 5 4 liangtl@amazon.com etoringe@amazon.co.uk
DynamoDbStreamsSourceEnumeratorStateSerializer.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
87 3 2024-06-20 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
ShardUtils.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util
30 4 2024-07-18 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
DynamoDbStreamsSourceEnumeratorState.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator
21 3 2024-06-20 2024-10-13 3 1 gguptp@amazon.com gguptp@amazon.com
PartitionKeyGenerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink
7 - 2023-06-30 2024-10-12 2 2 liangtl@amazon.com jorick.caberio@gmail.com
AWSGeneralUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
355 23 2022-12-02 2024-09-27 7 6 dannycranmer@apache.org etoringe@amazon.co.uk
KinesisStreamsConnectorSinkOptionsUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util
213 12 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisDynamicSink.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
198 16 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
KinesisDynamicSource.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
184 11 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
126 4 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisDynamicTableFactory.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
70 2 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
KinesisConnectorOptions.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
70 - 2023-06-30 2024-09-24 2 2 liangtl@amazon.com burakoz@amazon.co.uk
KinesisStreamsSourceConfigUtil.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config
70 3 2023-06-30 2024-09-24 4 3 liangtl@amazon.com burakoz@amazon.co.uk
KinesisConsumerOptionsUtil.java
in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table
57 5 2023-06-30 2024-09-24 3 3 liangtl@amazon.com burakoz@amazon.co.uk
AWSOptionUtils.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util
57 5 2022-12-02 2024-09-24 2 2 dannycranmer@apache.org burakoz@amazon.co.uk
KinesisStreamsConnectorSourceOptionsUtils.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util
42 4 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
RowMetadata.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table
37 3 2024-09-24 2024-09-24 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisStreamsSourceEnumerator.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator
350 22 2023-06-30 2024-09-16 6 3 liangtl@amazon.com burakoz@amazon.co.uk
AWSConfigOptions.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config
147 - 2024-09-16 2024-09-16 1 1 burakoz@amazon.co.uk burakoz@amazon.co.uk
KinesisStreamsSourceBuilder.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source
86 13 2023-06-30 2024-09-16 4 3 liangtl@amazon.com burakoz@amazon.co.uk
StreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
26 - 2023-06-30 2024-09-16 4 3 liangtl@amazon.com burakoz@amazon.co.uk
FanOutKinesisShardSubscription.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
252 11 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
StreamConsumerRegistrar.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout
117 4 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
KinesisAsyncStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
39 3 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
StartingPositionUtil.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
36 1 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
AsyncStreamProxy.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy
14 - 2024-09-12 2024-09-12 1 1 liangtl@amazon.com liangtl@amazon.com
SplitGraphInconsistencyTracker.java
in flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker
69 8 2024-07-18 2024-09-09 3 1 gguptp@amazon.com gguptp@amazon.com
KinesisStreamsSourceReader.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader
77 8 2023-06-30 2024-09-05 4 3 liangtl@amazon.com liangtl@amazon.com
AWSClientUtil.java
in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util
168 9 2023-01-17 2024-09-04 3 3 darenwkt@amazon.co.uk gguptp@amazon.com
KinesisShardSplitSerializer.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
129 2 2023-06-30 2024-09-04 3 2 liangtl@amazon.com liangtl@amazon.com
KinesisShardSplit.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
108 11 2023-06-30 2024-09-04 4 3 liangtl@amazon.com liangtl@amazon.com
KinesisShardSplitState.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split
42 9 2023-06-30 2024-09-04 3 2 liangtl@amazon.com liangtl@amazon.com
UniformShardAssigner.java
in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner
30 1 2023-06-30 2024-09-04 2 1 liangtl@amazon.com liangtl@amazon.com
SqsDynamicSink.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
199 15 2024-08-17 2024-08-17 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com
SqsDynamicTableFactory.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
108 5 2024-08-17 2024-08-17 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com
SqsConnectorOptions.java
in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table
28 - 2024-08-17 2024-08-17 1 1 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com