Path	Lines of Code
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FixedKinesisPartitioner.java	40
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkDynamoDBStreamsConsumer.java	41
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkKinesisConsumer.java	248
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkKinesisException.java	17
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkKinesisProducer.java	247
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/KinesisPartitioner.java	13
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/KinesisShardAssigner.java	8
amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/RandomKinesisPartitioner.java	18