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 337 185 3 2 2022-09-09 2023-02-08 dannycranmer@apache.org liangtl@amazon.com flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java 341 4 253 121 4 3 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/AWSClientUtil.java 149 2 207 131 2 2 2023-01-17 2023-04-03 darenwkt@amazon.co.uk liangtl@amazon.com flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSCredentialFatalExceptionClassifiers.java 20 1 253 253 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/AWSAuthenticationException.java 11 1 253 253 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/AWSConfigConstants.java 71 3 253 121 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/sink/throwable/AWSExceptionHandler.java 17 1 143 143 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 143 143 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/table/util/AWSOptionUtils.java 57 1 253 253 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/table/util/AsyncClientOptionsUtils.java 76 1 253 253 1 1 2022-12-02 2022-12-02 dannycranmer@apache.org dannycranmer@apache.org flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseStateSerializer.java 27 1 43 43 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 43 43 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/KinesisFirehoseSinkBuilder.java 70 1 43 43 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 193 1 43 43 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 67 1 43 43 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 43 43 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 43 43 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/KinesisFirehoseSink.java 89 1 43 43 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/KinesisFirehoseConnectorOptions.java 20 1 43 43 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 43 43 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 43 43 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 43 43 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/ShardConsumerMetricsReporter.java 57 1 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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/StreamConsumerRegistrarUtil.java 108 1 43 43 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 43 43 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 443 1 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 52 1 43 43 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 43 43 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 43 43 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 1 43 43 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 43 43 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/ConsumerConfigConstants.java 164 1 43 43 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/AWSConfigConstants.java 4 1 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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/KinesisShardAssigner.java 8 1 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 205 1 43 43 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/FanOutShardSubscriber.java 376 1 43 43 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 43 43 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/FanOutRecordPublisherFactory.java 53 1 43 43 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 306 1 43 43 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 43 43 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/RecordPublisher.java 16 1 43 43 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/KinesisDataFetcher.java 929 1 43 43 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 43 43 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 43 43 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 52 1 43 43 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/KinesisDynamicSource.java 200 1 43 43 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 43 43 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 1 43 43 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/RowDataKinesisDeserializationSchema.java 97 1 43 43 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 43 43 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/KinesisConnectorOptionsUtil.java 27 1 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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 43 43 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/KinesisPartitioner.java 17 1 43 43 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 43 43 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/PrimaryKeyBuilder.java 76 1 43 43 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 43 43 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/DynamoDbWriterStateSerializer.java 25 1 43 43 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 43 43 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/DynamoDbConfigConstants.java 9 1 43 43 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 43 43 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 35 1 43 43 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 93 1 43 43 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 43 43 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/DynamoDbSinkBuilder.java 72 1 43 43 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/InvalidRequestException.java 8 1 43 43 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/DynamoDbWriteRequest.java 48 1 43 43 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 43 43 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 1 43 43 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/SdkClientProvider.java 8 1 43 43 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/DynamoDbConnectorOptions.java 26 1 43 43 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/DynamoDbDynamicSink.java 136 1 43 43 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/RowDataElementConverter.java 42 1 43 43 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/ArrayAttributeConverter.java 40 1 43 43 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 43 43 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/DynamoDbDynamicSinkFactory.java 46 1 43 43 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 70 1 43 43 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 34 1 43 43 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/KinesisStreamsRecordEmitter.java 46 1 43 43 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/PollingKinesisShardSplitReader.java 107 1 43 43 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 37 1 43 43 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/KinesisShardSplitSerializer.java 72 1 43 43 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/KinesisShardSplitState.java 39 1 43 43 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/StartingPosition.java 59 1 43 43 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/KinesisShardSplit.java 64 1 43 43 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/KinesisStreamsSourceBuilder.java 42 1 43 43 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/proxy/KinesisStreamProxy.java 116 1 43 43 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/proxy/StreamProxy.java 14 1 43 43 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/config/KinesisStreamsSourceConfigConstants.java 34 1 43 43 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/config/KinesisStreamsSourceConfigUtil.java 27 1 43 43 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 43 43 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/KinesisDeserializationSchema.java 18 1 43 43 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 143 1 43 43 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/exception/KinesisStreamsSourceException.java 9 1 43 43 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/KinesisStreamsSourceEnumeratorStateSerializer.java 94 1 43 43 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 249 1 43 43 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/KinesisStreamsSourceEnumeratorState.java 21 1 43 43 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/KinesisShardAssigner.java 18 1 43 43 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/assigner/ShardAssignerFactory.java 11 1 43 43 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/assigner/UniformShardAssigner.java 35 1 43 43 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 43 43 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 1 43 43 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/KinesisStreamsStateSerializer.java 54 1 43 43 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 43 43 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/KinesisStreamsSink.java 107 1 43 43 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 1 43 43 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/KinesisStreamsSinkElementConverter.java 84 1 43 43 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 43 43 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/KinesisDynamicTableSinkFactory.java 91 1 43 43 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/util/KinesisStreamsConnectorOptionsUtils.java 210 1 43 43 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 43 43 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/FixedKinesisPartitionKeyGenerator.java 36 1 43 43 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/RandomKinesisPartitionKeyGenerator.java 19 1 43 43 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/RowDataFieldsKinesisPartitionKeyGenerator.java 145 1 43 43 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 65 1 43 43 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/KinesisDynamicSink.java 193 1 43 43 1 1 2023-06-30 2023-06-30 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 185 185 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/GlueSchemaRegistryJsonSchemaCoderProvider.java 18 1 185 185 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 185 185 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/GlueSchemaRegistryJsonSerializationSchema.java 32 1 185 185 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 185 185 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 185 185 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 185 185 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 185 185 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 185 185 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 185 185 1 1 2023-02-08 2023-02-08 liangtl@amazon.com liangtl@amazon.com