Path Lines of Code kinesis-lambda/src/main/java/com/optimize/downstream/additionaldata/AdditionalIOTData.java 26 kinesis-lambda/src/main/java/com/optimize/downstream/additionaldata/TestAdditonalData.java 26 kinesis-lambda/src/main/java/com/optimize/downstream/lambda/ProcessKinesisRecords.java 147 sample-kinesis-producer/src/main/java/com/optimize/downstream/datagenerator/GenerateDataMain.java 31 sample-kinesis-producer/src/main/java/com/optimize/downstream/datagenerator/GenerateDataWorker.java 18 sample-kinesis-producer/src/main/java/com/optimize/downstream/entry/Main.java 30 sample-kinesis-producer/src/main/java/com/optimize/downstream/samplekinesisproducer/IOTDevice.java 39 sample-kinesis-producer/src/main/java/com/optimize/downstream/samplekinesisproducer/IOTDeviceConsumerFromBlockingQueueToKinesisStreams.java 73 sample-kinesis-producer/src/main/java/com/optimize/downstream/samplekinesisproducer/IOTDeviceProducerToBlockingQueue.java 140 sample-kinesis-producer/src/main/java/com/optimize/downstream/samplekinesisproducer/SampleEvent.java 16 sample-kinesis-producer/src/main/java/com/optimize/downstream/sensors/Accelerometer.java 68 sample-kinesis-producer/src/main/java/com/optimize/downstream/sensors/GPS.java 33 sample-kinesis-producer/src/main/java/com/optimize/downstream/sensors/Illuminance.java 12 sample-kinesis-producer/src/main/java/com/optimize/downstream/sensors/TemperatureSensor.java 26 spark-process/src/main/scala/com/optimize/downstream/process/ProcessFilesFromS3AndConvertToParquet.scala 54