path	# lines of code
src/main/scala/com/amazonaws/awslabs/sparkstreaming/SparkKafkaExample.scala	27
src/main/scala/com/amazonaws/awslabs/sparkstreaming/SparkKinesisExampleWithPreferredLocation.scala	77
src/main/scala/com/amazonaws/awslabs/sparkstreaming/listener/CloudWatchQueryListener.scala	40
src/main/scala/com/amazonaws/awslabs/sparkstreaming/listener/CloudWatchSparkListener.scala	50
src/main/scala/com/amazonaws/awslabs/sparkstreaming/SparkKinesisExample.scala	48
src/main/scala/com/amazonaws/awslabs/utils/CloudWatchMetricsUtil.scala	75
src/main/scala/com/amazonaws/awslabs/kinesis-producer/ExampleKinesisProducer.scala	81
src/main/scala/org/apache/spark/streaming/kinesis/CustomKinesisReceiver.scala	34
src/main/scala/org/apache/spark/streaming/kinesis/CustomKinesisInputDStream.scala	156
build.sbt	9