Path	Lines of Code
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisAWSCredentialsProvider.java	36
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java	171
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemAdmin.java	73
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemFactory.java	53
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisIncomingMessageEnvelope.java	30
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisRecordProcessor.java	111
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisRecordProcessorListener.java	8
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumer.java	157
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumerOffset.java	60
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/NoAvailablePartitionException.java	10
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/SSPAllocator.java	32
samza-aws/src/main/java/org/apache/samza/system/kinesis/descriptors/KinesisInputDescriptor.java	53
samza-aws/src/main/java/org/apache/samza/system/kinesis/descriptors/KinesisSystemDescriptor.java	60
samza-aws/src/main/java/org/apache/samza/system/kinesis/metrics/KinesisSystemConsumerMetrics.java	63
samza-aws/src/main/java/org/apache/samza/system/kinesis/metrics/SamzaHistogram.java	35