path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor tools/maven/suppressions.xml 15 3 972 820 3 2 2022-09-09 2023-02-08 dannycranmer@apache.org liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseConnectorOptions.java 20 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/util/KinesisFirehoseConnectorOptionUtils.java 39 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicTableFactory.java 56 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/table/KinesisFirehoseDynamicSink.java 133 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseStateSerializer.java 27 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseException.java 21 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/AWSFirehoseExceptionClassifiers.java 34 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkElementConverter.java 64 2 678 395 2 2 2023-06-30 2024-04-08 liangtl@amazon.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkBuilder.java 70 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseConfigConstants.java 9 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java 190 2 678 374 2 2 2023-06-30 2024-04-29 liangtl@amazon.com pilipa@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSink.java 89 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConfiguration.java 38 2 678 271 2 2 2023-06-30 2024-08-10 liangtl@amazon.com maoxingda@meican.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataElementConverter.java 49 2 678 271 2 2 2023-06-30 2024-08-10 liangtl@amazon.com maoxingda@meican.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSink.java 147 2 678 271 2 2 2023-06-30 2024-08-10 liangtl@amazon.com maoxingda@meican.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConnectorOptions.java 32 2 678 271 2 2 2023-06-30 2024-08-10 liangtl@amazon.com maoxingda@meican.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java 47 2 678 271 2 2 2023-06-30 2024-08-10 liangtl@amazon.com maoxingda@meican.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/converter/ArrayAttributeConverter.java 40 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/converter/ArrayAttributeConverterProvider.java 56 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataToAttributeValueConverter.java 76 2 678 271 2 2 2023-06-30 2024-08-10 liangtl@amazon.com maoxingda@meican.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/PrimaryKeyBuilder.java 76 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbSerializationUtil.java 164 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/util/DynamoDbType.java 49 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequestType.java 25 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSink.java 110 2 678 465 2 2 2023-06-30 2024-01-29 liangtl@amazon.com z3d1kk@gmail.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriterStateSerializer.java 25 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DefaultDynamoDbElementConverter.java 27 1 395 395 1 1 2024-04-08 2024-04-08 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/SdkClientProvider.java 8 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java 43 2 678 555 2 2 2023-06-30 2023-10-31 liangtl@amazon.com dannycranmer@apache.org flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/InvalidRequestException.java 8 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbBeanElementConverter.java 39 2 678 395 2 2 2023-06-30 2024-04-08 liangtl@amazon.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbConfigConstants.java 9 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkException.java 19 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/InvalidConfigurationException.java 8 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java 223 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java 315 1 395 395 1 1 2024-04-08 2024-04-08 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkBuilder.java 73 2 678 395 2 2 2023-06-30 2024-04-08 liangtl@amazon.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbWriteRequest.java 48 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/metrics/MetricConstants.java 11 1 294 294 1 1 2024-07-18 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/metrics/DynamoDbStreamsShardMetrics.java 51 1 294 294 1 1 2024-07-18 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSource.java 187 6 322 79 6 2 2024-06-20 2025-02-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config/DynamodbStreamsSourceConfigConstants.java 64 3 322 79 3 1 2024-06-20 2025-02-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util/ListShardsResult.java 65 1 294 294 1 1 2024-07-18 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/util/ShardUtils.java 30 3 294 207 3 1 2024-07-18 2024-10-13 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy/StreamProxy.java 13 2 322 294 2 1 2024-06-20 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/proxy/DynamoDbStreamsProxy.java 180 2 322 294 2 1 2024-06-20 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/exception/DynamoDbStreamsSourceException.java 10 1 322 322 1 1 2024-06-20 2024-06-20 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner/UniformShardAssigner.java 37 2 322 45 2 1 2024-06-20 2025-03-24 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/assigner/ShardAssignerFactory.java 11 1 322 322 1 1 2024-06-20 2024-06-20 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsShardAssigner.java 18 1 322 322 1 1 2024-06-20 2024-06-20 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumeratorState.java 21 3 322 207 3 1 2024-06-20 2024-10-13 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumeratorStateSerializer.java 87 3 322 207 3 1 2024-06-20 2024-10-13 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/event/SplitsFinishedEvent.java 22 1 294 294 1 1 2024-07-18 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/SplitAssignmentStatus.java 23 1 294 294 1 1 2024-07-18 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java 297 5 322 45 5 1 2024-06-20 2025-03-24 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDBStreamsShardSplitWithAssignmentStatus.java 47 1 294 294 1 1 2024-07-18 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitGraphInconsistencyTracker.java 69 3 294 241 3 1 2024-07-18 2024-09-09 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java 253 6 294 45 6 1 2024-07-18 2025-03-24 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSourceBuilder.java 43 1 322 322 1 1 2024-06-20 2024-06-20 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplitSerializer.java 90 3 322 45 3 1 2024-06-20 2025-03-24 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/StartingPosition.java 58 1 322 322 1 1 2024-06-20 2024-06-20 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplitState.java 40 2 322 294 2 1 2024-06-20 2024-07-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/split/DynamoDbStreamsShardSplit.java 93 3 322 45 3 1 2024-06-20 2025-03-24 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsRecordEmitter.java 48 1 322 322 1 1 2024-06-20 2024-06-20 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/DynamoDbStreamsSourceReader.java 125 4 322 45 4 2 2024-06-20 2025-03-24 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java 204 4 322 79 4 2 2024-06-20 2025-02-18 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/serialization/DynamoDbStreamsDeserializationSchema.java 16 1 322 322 1 1 2024-06-20 2024-06-20 gguptp@amazon.com gguptp@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics/ShardConsumerMetricsReporter.java 57 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics/PollingRecordPublisherMetricsReporter.java 54 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics/KinesisConsumerMetricConstants.java 19 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java 310 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StartingPosition.java 64 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/DynamoDBStreamsShardHandle.java 24 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SentinelSequenceNumber.java 26 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java 83 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java 54 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardHandle.java 55 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShardState.java 63 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardMetadata.java 172 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java 313 3 678 386 3 3 2023-06-30 2024-04-17 liangtl@amazon.com pilipa@amazon.co.uk flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisShardAssigner.java 8 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicShardAssignerFactory.java 8 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/UniformShardAssignerFactory.java 16 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicTableFactory.java 70 2 678 226 2 2 2023-06-30 2024-09-24 liangtl@amazon.com burakoz@amazon.co.uk flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisConnectorOptionsUtil.java 27 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisConsumerOptionsUtil.java 57 3 678 226 3 3 2023-06-30 2024-09-24 liangtl@amazon.com burakoz@amazon.co.uk flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataKinesisDeserializationSchema.java 100 2 678 584 2 2 2023-06-30 2023-10-02 liangtl@amazon.com pilipa@amazon.co.uk flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicSource.java 200 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/DefaultShardAssignerFactory.java 17 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java 8 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ExceptionConfig.java 10 1 548 548 1 1 2023-11-07 2023-11-07 969071+iemre@users.noreply.github.com 969071+iemre@users.noreply.github.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java 4 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/RecoverableErrorsConfig.java 61 1 548 548 1 1 2023-11-07 2023-11-07 969071+iemre@users.noreply.github.com 969071+iemre@users.noreply.github.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java 166 2 678 548 2 2 2023-06-30 2023-11-07 liangtl@amazon.com 969071+iemre@users.noreply.github.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java 17 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java 188 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/WatermarkTracker.java 50 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/UniformShardAssigner.java 20 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/RecordEmitter.java 175 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/JobManagerWatermarkTracker.java 146 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AwsV2Util.java 57 2 678 277 2 2 2023-06-30 2024-08-04 liangtl@amazon.com z3d1kk@gmail.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisStateUtil.java 24 1 605 605 1 1 2023-09-11 2023-09-11 cyberness@gmail.com cyberness@gmail.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/StreamConsumerRegistrarUtil.java 108 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/BeanDeserializerModifierForIgnorables.java 48 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/TimeoutLatch.java 21 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java 448 2 678 548 2 2 2023-06-30 2023-11-07 liangtl@amazon.com 969071+iemre@users.noreply.github.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java 929 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/PollingRecordPublisher.java 123 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/PollingRecordPublisherConfiguration.java 40 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/AdaptivePollingRecordPublisher.java 79 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/PollingRecordPublisherFactory.java 53 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisherConfiguration.java 315 2 678 548 2 2 2023-06-30 2023-11-07 liangtl@amazon.com 969071+iemre@users.noreply.github.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisherFactory.java 53 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/StreamConsumerRegistrar.java 215 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublisher.java 206 2 678 548 2 2 2023-06-30 2023-11-07 liangtl@amazon.com 969071+iemre@users.noreply.github.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutShardSubscriber.java 402 2 678 548 2 2 2023-06-30 2023-11-07 liangtl@amazon.com 969071+iemre@users.noreply.github.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/RecordPublisher.java 16 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/RecordBatch.java 56 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/RecordPublisherFactory.java 17 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java 151 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/DynamoDBStreamsDataFetcher.java 84 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxySyncV2.java 146 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyAsyncV2Interface.java 11 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/DynamoDBStreamsProxy.java 96 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/GetShardListResult.java 47 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyInterface.java 15 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyAsyncV2.java 34 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2Factory.java 70 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java 476 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxySyncV2Interface.java 23 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/FullJitterBackoff.java 15 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchema.java 18 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisSerializationSchema.java 11 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/DynamoDBStreamsSchema.java 24 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchemaWrapper.java 46 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisException.java 17 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkDynamoDBStreamsConsumer.java 37 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicSink.java 199 1 264 264 1 1 2024-08-17 2024-08-17 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicTableFactory.java 108 1 264 264 1 1 2024-08-17 2024-08-17 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsConnectorOptions.java 28 1 264 264 1 1 2024-08-17 2024-08-17 ahmed.hamdy@ververica.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsConfigConstants.java 17 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsStateSerializer.java 43 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkWriter.java 176 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkBuilder.java 72 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkException.java 27 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSink.java 111 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/client/SdkClientProvider.java 8 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/client/SqsAsyncClientProvider.java 35 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsExceptionClassifiers.java 34 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/sink/SqsSinkElementConverter.java 52 1 363 363 1 1 2024-05-10 2024-05-10 dhipriya@amazon.com dhipriya@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicTableFactory.java 126 1 226 226 1 1 2024-09-24 2024-09-24 burakoz@amazon.co.uk burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorSourceOptionsUtils.java 42 1 226 226 1 1 2024-09-24 2024-09-24 burakoz@amazon.co.uk burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/util/KinesisStreamsConnectorSinkOptionsUtils.java 213 1 226 226 1 1 2024-09-24 2024-09-24 burakoz@amazon.co.uk burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/RowMetadata.java 37 1 226 226 1 1 2024-09-24 2024-09-24 burakoz@amazon.co.uk burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/RowDataFieldsKinesisPartitionKeyGenerator.java 145 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSource.java 184 1 226 226 1 1 2024-09-24 2024-09-24 burakoz@amazon.co.uk burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSink.java 198 2 678 226 2 2 2023-06-30 2024-09-24 liangtl@amazon.com burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/RandomKinesisPartitionKeyGenerator.java 19 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisPartitionKeyGeneratorFactory.java 59 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisConnectorOptions.java 70 2 678 226 2 2 2023-06-30 2024-09-24 liangtl@amazon.com burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/FixedKinesisPartitionKeyGenerator.java 36 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/PartitionKeyGenerator.java 7 2 678 208 2 2 2023-06-30 2024-10-12 liangtl@amazon.com jorick.caberio@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkElementConverter.java 81 2 678 395 2 2 2023-06-30 2024-04-08 liangtl@amazon.com ahmed.hamdy@ververica.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSink.java 107 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsConfigConstants.java 9 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java 223 2 678 374 2 2 2023-06-30 2024-04-29 liangtl@amazon.com pilipa@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsStateSerializer.java 54 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsException.java 19 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkBuilder.java 73 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/metrics/KinesisShardMetrics.java 50 1 328 328 1 1 2024-06-14 2024-06-14 burakoz@amazon.co.uk burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/metrics/MetricConstants.java 11 1 328 328 1 1 2024-06-14 2024-06-14 burakoz@amazon.co.uk burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java 100 4 238 35 4 3 2024-09-12 2025-04-03 liangtl@amazon.com leekeiabstraction@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisStreamsSourceConfigUtil.java 70 4 678 226 4 3 2023-06-30 2024-09-24 liangtl@amazon.com burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisAsyncStreamProxy.java 39 1 238 238 1 1 2024-09-12 2024-09-12 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/StreamProxy.java 26 4 678 234 4 3 2023-06-30 2024-09-16 liangtl@amazon.com burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/AsyncStreamProxy.java 14 1 238 238 1 1 2024-09-12 2024-09-12 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisStreamProxy.java 166 5 678 189 5 4 2023-06-30 2024-10-31 liangtl@amazon.com etoringe@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/ListShardsStartingPosition.java 36 1 315 315 1 1 2024-06-27 2024-06-27 z3d1kk@gmail.com z3d1kk@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/exception/KinesisStreamsSourceException.java 9 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java 281 10 678 35 12 7 2023-06-30 2025-04-03 liangtl@amazon.com leekeiabstraction@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/event/SplitsFinishedEvent.java 22 1 315 315 1 1 2024-06-27 2024-06-27 z3d1kk@gmail.com z3d1kk@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/UniformShardAssigner.java 30 2 678 246 2 1 2023-06-30 2024-09-04 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/ShardAssignerFactory.java 11 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisShardSplitWithAssignmentStatus.java 45 1 315 315 1 1 2024-06-27 2024-06-27 z3d1kk@gmail.com z3d1kk@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisShardAssigner.java 18 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java 350 6 678 234 6 3 2023-06-30 2024-09-16 liangtl@amazon.com burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/SplitAssignmentStatus.java 22 1 315 315 1 1 2024-06-27 2024-06-27 z3d1kk@gmail.com z3d1kk@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorStateV0.java 22 1 315 315 1 1 2024-06-27 2024-06-27 z3d1kk@gmail.com z3d1kk@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorStateSerializer.java 123 2 678 315 2 2 2023-06-30 2024-06-27 liangtl@amazon.com z3d1kk@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorState.java 20 2 678 315 2 2 2023-06-30 2024-06-27 liangtl@amazon.com z3d1kk@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTracker.java 87 1 315 315 1 1 2024-06-27 2024-06-27 z3d1kk@gmail.com z3d1kk@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSourceBuilder.java 86 4 678 234 4 3 2023-06-30 2024-09-16 liangtl@amazon.com burakoz@amazon.co.uk flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitSerializer.java 129 3 678 246 3 2 2023-06-30 2024-09-04 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitState.java 42 3 678 246 3 2 2023-06-30 2024-09-04 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPosition.java 59 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPositionUtil.java 36 1 238 238 1 1 2024-09-12 2024-09-12 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplit.java 108 4 678 246 4 3 2023-06-30 2024-09-04 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.java 41 3 245 35 3 2 2024-09-05 2025-04-03 liangtl@amazon.com leekeiabstraction@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReader.java 64 3 245 35 3 2 2024-09-05 2025-04-03 liangtl@amazon.com leekeiabstraction@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/StreamConsumerRegistrar.java 117 1 238 238 1 1 2024-09-12 2024-09-12 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSubscription.java 252 1 238 238 1 1 2024-09-12 2024-09-12 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisStreamsRecordEmitter.java 46 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisStreamsSourceReader.java 77 4 678 245 4 3 2023-06-30 2024-09-05 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisShardSplitReaderBase.java 213 3 245 35 3 2 2024-09-05 2025-04-03 liangtl@amazon.com leekeiabstraction@gmail.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/serialization/KinesisDeserializationSchema.java 18 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/serialization/KinesisDeserializationSchemaWrapper.java 28 1 678 678 1 1 2023-06-30 2023-06-30 liangtl@amazon.com liangtl@amazon.com flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util/AWSOptionUtils.java 57 2 888 226 2 2 2022-12-02 2024-09-24 dannycranmer@apache.org burakoz@amazon.co.uk flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/table/util/AsyncClientOptionsUtils.java 76 1 888 888 1 1 2022-12-02 2022-12-02 dannycranmer@apache.org dannycranmer@apache.org flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java 147 1 234 234 1 1 2024-09-16 2024-09-16 burakoz@amazon.co.uk burakoz@amazon.co.uk flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigConstants.java 71 3 888 756 3 2 2022-12-02 2023-04-13 dannycranmer@apache.org kartoi@amazon.co.uk flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSAuthenticationException.java 11 1 888 888 1 1 2022-12-02 2022-12-02 dannycranmer@apache.org dannycranmer@apache.org flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java 355 7 888 223 7 6 2022-12-02 2024-09-27 dannycranmer@apache.org etoringe@amazon.co.uk flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSClientUtil.java 168 3 842 246 3 3 2023-01-17 2024-09-04 darenwkt@amazon.co.uk gguptp@amazon.com flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSCredentialFatalExceptionClassifiers.java 20 1 888 888 1 1 2022-12-02 2022-12-02 dannycranmer@apache.org dannycranmer@apache.org flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/sink/throwable/AWSExceptionHandler.java 17 1 778 778 1 1 2023-03-22 2023-03-22 siebenma@amazon.com siebenma@amazon.com flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/sink/throwable/AWSExceptionClassifierUtil.java 29 1 778 778 1 1 2023-03-22 2023-03-22 siebenma@amazon.com siebenma@amazon.com flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSchemaCoderProvider.java 18 2 820 465 2 2 2023-02-08 2024-01-29 liangtl@amazon.com z3d1kk@gmail.com flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSerializationSchema.java 32 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonDeserializationSchema.java 45 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-formats-aws/flink-json-glue-schema-registry/src/main/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSchemaCoder.java 79 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryInputStreamDeserializer.java 50 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroDeserializationSchema.java 32 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSchemaCoderProvider.java 21 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSchemaCoder.java 48 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroSerializationSchema.java 62 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-formats-aws/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryOutputStreamSerializer.java 56 1 820 820 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com flink-python/MANIFEST.in 19 1 507 507 1 1 2023-12-18 2023-12-18 dannycranmer@apache.org dannycranmer@apache.org flink-python/pyflink/datastream/connectors/kinesis.py 194 1 507 507 1 1 2023-12-18 2023-12-18 dannycranmer@apache.org dannycranmer@apache.org flink-python/setup.py 91 1 507 507 1 1 2023-12-18 2023-12-18 dannycranmer@apache.org dannycranmer@apache.org