path # lines of code aws-blog-firehose-lambda/kinesisFirehose/src/main/java/com/amazonaws/proserv/SampleAWSCredentialProvider.java 8 aws-blog-firehose-lambda/kinesisFirehose/src/main/java/com/amazonaws/proserv/lambda/KinesisToFirehose.java 124 aws-blog-firehose-lambda/kinesisFirehose/src/main/java/com/amazonaws/proserv/PopulateKinesisData.java 48 aws-blog-end-to-end-emrencyrption/code/test.q 41 aws-blog-end-to-end-emrencyrption/code/test.py 7 aws-blog-spark-parquet-conversion/convert2parquet.py 18 aws-blog-spark-parquet-conversion/createtable.hql 26 aws-blog-spark-parquet-conversion/addpartitions.gvy 18 aws-blog-spark-parquet-conversion/addpartitions.hql 365 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/CreateAthenaPartitionsBasedOnS3Event.java 49 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/RemoveAthenaPartitionsBasedOnS3Event.java 41 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/model/Partition.java 30 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/model/S3Object.java 51 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/model/TableService.java 64 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/model/PartitionType.java 75 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/model/PartitionConfig.java 27 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/model/ExpirationConfig.java 19 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/utils/TimeUnitParser.java 21 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/utils/EnvironmentVariableUtils.java 16 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/utils/Clock.java 11 aws-blog-vpcflowlogs-athena-quicksight/PartitioningFunction/src/main/java/com/amazonaws/services/lambda/RemoveAthenaPartitions.java 51 aws-blog-vpcflowlogs-athena-quicksight/CloudwatchLogsToFirehose/lambdacode.py 28 aws-blog-campanile/hive/diff.q 7 aws-blog-retain-redshift-stl/scripts/extract_rs_query_logs.py 81 aws-blog-mirth-healthcare-hub/hl7-webapp/service-xml-to-json.js 32 aws-blog-mirth-healthcare-hub/bb-webapp/bb-conversion-listener.js 26 aws-blog-mirth-healthcare-hub/mirth-aws-sample-app/src/main/java/org/mirth/project/MCAWS.java 193 aws-blog-mirth-healthcare-hub/mirth-aws-dicom-app/src/main/java/org/mirthblog/dicom/MDICOM.java 64 aws-blog-strata2016/pattern-kinesis-sparkstreaming/raw_streaming_code.scala 44 aws-blog-strata2016/pattern-lambda-elasticsearch/lambda_code_node.js 45 aws-blog-kinesis-storm-clickstream-app/static/visualization/node-app.js 30 aws-blog-kinesis-storm-clickstream-app/static/visualization/index.html 79 aws-blog-kinesis-storm-clickstream-app/src/main/java/KinesisStormClickstreamApp/SampleTopology.java 110 aws-blog-kinesis-storm-clickstream-app/src/main/java/KinesisStormClickstreamApp/ParseReferrerBolt.java 41 aws-blog-kinesis-storm-clickstream-app/src/main/java/KinesisStormClickstreamApp/ConfigKeys.java 10 aws-blog-kinesis-storm-clickstream-app/src/main/java/KinesisStormClickstreamApp/RollingCountBolt.java 112 aws-blog-kinesis-storm-clickstream-app/src/main/java/KinesisStormClickstreamApp/CustomCredentialsProviderChain.java 14 aws-blog-sqoop/hive-tables.hql 26 aws-blog-sparkstreaming-from-kafka/src/main/scala/com/awsproserv/kafkaandsparkstreaming/ClickstreamKafkaProducer.scala 33 aws-blog-sparkstreaming-from-kafka/src/main/scala/com/awsproserv/kafkaandsparkstreaming/ClickstreamSparkstreaming.scala 54 aws-blog-firehose-lambda-elasticsearch-near-real-time-discovery-platform/lambda-s3-twitter-to-es-python/tweet_utils.py 127 aws-blog-firehose-lambda-elasticsearch-near-real-time-discovery-platform/lambda-s3-twitter-to-es-python/twitter_to_es.py 51 aws-blog-firehose-lambda-elasticsearch-near-real-time-discovery-platform/lambda-s3-twitter-to-es-python/lambda_function.py 53 aws-blog-firehose-lambda-elasticsearch-near-real-time-discovery-platform/lambda-s3-twitter-to-es-python/config.py 7 aws-blog-firehose-lambda-elasticsearch-near-real-time-discovery-platform/firehose-twitter-streaming-nodejs/twitter_stream_producer.js 98 aws-blog-firehose-lambda-elasticsearch-near-real-time-discovery-platform/firehose-twitter-streaming-nodejs/config.js 30 aws-blog-firehose-lambda-elasticsearch-near-real-time-discovery-platform/firehose-twitter-streaming-nodejs/util/logger.js 28 aws-blog-firehose-lambda-elasticsearch-near-real-time-discovery-platform/firehose-twitter-streaming-nodejs/twitter_stream_producer_app.js 6 aws-blog-machine-learning-with-spark/spark-emr/project/assembly.sbt 2 aws-blog-machine-learning-with-spark/spark-emr/project/plugins.sbt 1 aws-blog-machine-learning-with-spark/spark-emr/src/main/scala/ModelingWorkflow.scala 54 aws-blog-machine-learning-with-spark/spark-emr/build.sbt 37 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/emr/src/main/java/com/amazon/aws/blog/model/StatefulArtifactIndex.java 23 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/emr/src/main/java/com/amazon/aws/blog/function/PreFetcherFlatMapFunction.java 114 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/emr/src/main/java/com/amazon/aws/blog/StatefulMain.java 66 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/emr/src/main/java/com/amazon/aws/blog/PreFetcherMain.java 26 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/emr/src/main/java/com/amazon/aws/blog/StatelessMain.java 28 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/template.yml 1024 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/lambda/src/main/java/com/amazon/aws/blog/StateIndexer.java 10 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/lambda/src/main/java/com/amazon/aws/blog/model/StateIndexerCoordinatorInput.java 10 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/lambda/src/main/java/com/amazon/aws/blog/model/StateIndexerWorkerOutput.java 8 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/lambda/src/main/java/com/amazon/aws/blog/model/StateIndexerWorkerInput.java 11 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/lambda/src/main/java/com/amazon/aws/blog/StateIndexerLambdaImpl.java 216 BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/lambda/src/main/java/com/amazon/aws/blog/ddb/StatefulArtifactIndex.java 23 aws-blog-kinesis-beanstalk-workers/src/main/java/com/amazonaws/services/kinesis/ManagedClientProcessorFactory.java 27 aws-blog-kinesis-beanstalk-workers/src/main/java/com/amazonaws/services/kinesis/ManagedConsumer.java 139 aws-blog-kinesis-beanstalk-workers/src/main/java/com/amazonaws/services/kinesis/beanstalk/connector/KinesisWorkerServletInitiator.java 111 aws-blog-kinesis-beanstalk-workers/src/main/java/com/amazonaws/services/kinesis/ManagedClientProcessor.java 71 aws-blog-kinesis-beanstalk-workers/src/main/java/com/amazonaws/services/kinesis/InvalidConfigurationException.java 18 aws-blog-kinesis-beanstalk-workers/src/main/java/MyRecordProcessor.java 30 aws-blog-kinesis-beanstalk-workers/src/main/WebContent/index.html 8 aws-blog-kinesis-beanstalk-workers/src/main/WebContent/styles/styles.css 68 aws-blog-bigtop-application-emr/bigtop-packages/src/rpm/elasticsearch/SPECS/elasticsearch.spec 89 aws-blog-bigtop-application-emr/bigtop-packages/src/common/elasticsearch/logging.yml 37 aws-blog-bigtop-application-emr/bigtop-deploy/puppet/modules/elasticsearch/templates/elasticsearch.yml 7 aws-blog-bigtop-application-emr/bigtop-deploy/puppet/modules/elasticsearch/manifests/init.pp 33 aws-blog-s3-index-with-lambda-ddb/example-indexer-app/template.yaml 82 aws-blog-s3-index-with-lambda-ddb/example-indexer-app/s3Indexer.js 53 aws-blog-s3-index-with-lambda-ddb/s3-log-generator/src/main/java/com/amazonaws/bigdatablog/s3index/Util.java 11 aws-blog-s3-index-with-lambda-ddb/s3-log-generator/src/main/java/com/amazonaws/bigdatablog/s3index/VerifyIndex.java 79 aws-blog-s3-index-with-lambda-ddb/s3-log-generator/src/main/java/com/amazonaws/bigdatablog/s3index/TruncateBucket.java 76 aws-blog-s3-index-with-lambda-ddb/s3-log-generator/src/main/java/com/amazonaws/bigdatablog/s3index/S3DataGenerator.java 177 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/connector/EMRHBaseKinesisConnectorConfiguration.java 34 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/connector/HBaseTransformer.java 5 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/connector/HBaseEmitter.java 91 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/connector/KinesisMessageModelHBaseTransformer.java 34 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/connector/HBaseExecutor.java 20 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/connector/HBasePipeline.java 29 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/kinesis/KinesisConnectorExecutor.java 120 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/kinesis/StreamSource.java 78 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/kinesis/utils/EMRUtils.java 167 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/kinesis/utils/KinesisUtils.java 154 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/kinesis/utils/HBaseUtils.java 95 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/kinesis/BatchedStreamSource.java 65 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/kinesis/KinesisMessageModel.java 300 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/kinesis/KinesisConnectorMetricsExecutor.java 14 aws-blog-hbase-on-emr/hbase-connector/src/main/java/com/amazonaws/hbase/utils/EmrHelper.java 34 aws-blog-analyzing-using-ipython-notebook/wordSplitter.py 9 aws-blog-analyzing-using-ipython-notebook/plot-example.py 24 aws-blog-kinesis-data-visualization/TwitterProducer/src/main/java/com/amazonaws/kinesis/dataviz/producer/Producer.java 9 aws-blog-kinesis-data-visualization/TwitterProducer/src/main/java/com/amazonaws/kinesis/dataviz/producer/ProducerClient.java 67 aws-blog-kinesis-data-visualization/TwitterProducer/src/main/java/com/amazonaws/kinesis/dataviz/producer/Event.java 28 aws-blog-kinesis-data-visualization/TwitterProducer/src/main/java/com/amazonaws/kinesis/dataviz/producer/ProducerBuilder.java 34 aws-blog-kinesis-data-visualization/TwitterProducer/src/main/java/com/amazonaws/kinesis/dataviz/producer/ProducerBase.java 35 aws-blog-kinesis-data-visualization/TwitterProducer/src/main/java/com/amazonaws/kinesis/dataviz/twitter/TwitterProducer.java 111 aws-blog-kinesis-data-visualization/KinesisApplication/src/main/java/com/amazonaws/kinesis/dataviz/kinesisclient/ConfigKeys.java 11 aws-blog-kinesis-data-visualization/KinesisApplication/src/main/java/com/amazonaws/kinesis/dataviz/kinesisclient/Coordinate.java 21 aws-blog-kinesis-data-visualization/KinesisApplication/src/main/java/com/amazonaws/kinesis/dataviz/kinesisclient/KinesisRecordProcessorFactory.java 15 aws-blog-kinesis-data-visualization/KinesisApplication/src/main/java/com/amazonaws/kinesis/dataviz/kinesisclient/KinesisRecordProcessor.java 127 aws-blog-kinesis-data-visualization/KinesisApplication/src/main/java/com/amazonaws/kinesis/dataviz/kinesisclient/KinesisApplication.java 118 aws-blog-kinesis-data-visualization/Globe/views/layout.jade 7 aws-blog-kinesis-data-visualization/Globe/views/index.jade 4 aws-blog-kinesis-data-visualization/Globe/globe.html 45 aws-blog-kinesis-data-visualization/Globe/public/js/earth2.js 117 aws-blog-kinesis-data-visualization/Globe/public/js/earth.js 168 aws-blog-kinesis-data-visualization/Globe/public/js/TrackballControls.js 337 aws-blog-kinesis-data-visualization/Globe/public/js/Detector.js 38 aws-blog-kinesis-data-visualization/Globe/public/js/LensFlare.js 40 aws-blog-kinesis-data-visualization/Globe/public/js/OrbitControls.js 334 aws-blog-kinesis-data-visualization/Globe/public/js/Quaternion.js 257 aws-blog-kinesis-data-visualization/Globe/public/js/PointCloud.js 93 aws-blog-kinesis-data-visualization/Globe/public/stylesheets/style.css 7 aws-blog-kinesis-data-visualization/Globe/heatmap.html 68 aws-blog-kinesis-data-visualization/Globe/server.js 34 aws-blog-kinesis-data-visualization/Globe/routes/index.js 3 aws-blog-kinesis-data-visualization/Globe/routes/user.js 3 aws-blog-sparkr-geospatial-analysis/Spark-Redshift.R 13 aws-blog-sparkr-geospatial-analysis/SparkRGeoIntPipes.R 164 aws-blog-sparkr-geospatial-analysis/SparkRGeoInt.R 180 aws-blog-multi-az-multi-region-redshift/loader.py 219 aws-blog-jobserver-emr/python_lambda/models.py 65 aws-blog-jobserver-emr/src/main/scala/com/amazonaws/proserv/blog/FlightsSql.scala 35 aws-blog-jobserver-emr/src/main/scala/com/amazonaws/proserv/blog/FlightsBatch.scala 44 aws-blog-jobserver-emr/src/main/scala/com/amazonaws/proserv/ml/MovieRecML.scala 93 aws-blog-jobserver-emr/html/mltest.html 245 aws-blog-real-time-clickstream/ClickImpressionGenerator.py 32 aws-blog-event-driven-batch-analytics/src/main/java/com/amazonaws/bigdatablog/edba/emr/ProcessVendorTrasactions.java 91 aws-blog-event-driven-batch-analytics/src/main/java/com/amazonaws/bigdatablog/edba/LambdaContainer.java 204 aws-blog-lambda-map-reduce-streaming/scatter.html 217 aws-blog-lambda-map-reduce-streaming/app.js 71 aws-blog-lambda-map-reduce-streaming/streams.js 251 aws-blog-lambda-map-reduce-streaming/cascade.js 112 aws-blog-lambda-map-reduce-streaming/index.html 90 aws-blog-lambda-map-reduce-streaming/wordcount.js 106 aws-blog-elasticsearch-cascading-commoncrawl/commoncrawl.cascading.elasticsearch/src/main/java/com/amazonaws/bigdatablog/indexcommoncrawl/ConfigReader.java 20 aws-blog-elasticsearch-cascading-commoncrawl/commoncrawl.cascading.elasticsearch/src/main/java/com/amazonaws/bigdatablog/indexcommoncrawl/Main.java 21 aws-blog-elasticsearch-cascading-commoncrawl/commoncrawl.cascading.elasticsearch/src/main/java/com/amazonaws/bigdatablog/indexcommoncrawl/CommonCrawlIndex.java 34 aws-blog-redshift-python-udf-tutorial/CMS.STAT_RELEVANT_PHYSICIAN_SPECIALTY.SQL 26 aws-blog-emrencyrption/code/test.q 23 aws-blog-emrencyrption/code/test.py 14 aws-blog-athena-genomics/etl/thousand_genomes/create_trimmed_parquet.py 53 aws-blog-real-time-in-memory-oltp-and-analytics-with-apache-ignite/src/main/java/com/amazon/dynamostreams/clientlibrary/StreamsRecordProcessor.java 127 aws-blog-real-time-in-memory-oltp-and-analytics-with-apache-ignite/src/main/java/com/amazon/dynamostreams/clientlibrary/OrderData.java 51 aws-blog-real-time-in-memory-oltp-and-analytics-with-apache-ignite/src/main/java/com/amazon/dynamostreams/clientlibrary/Properties.java 16 aws-blog-real-time-in-memory-oltp-and-analytics-with-apache-ignite/src/main/java/com/amazon/dynamostreams/clientlibrary/StreamsRecordProcessorFactory.java 14 aws-blog-real-time-in-memory-oltp-and-analytics-with-apache-ignite/src/main/java/com/amazon/dynamostreams/clientlibrary/AmazonDynamoDBStreamstoIgnite.java 77 aws-blog-real-time-in-memory-oltp-and-analytics-with-apache-ignite/sample/ddbStreamstoFirehose.py 36 aws-blog-real-time-in-memory-oltp-and-analytics-with-apache-ignite/sample/dummyOrderGenerator.py 39 aws-blog-athena-importing-hive-metastores/exportdatabase.py 29 aws-blog-athena-importing-hive-metastores/sample_createtable.hql 39 aws-blog-athena-importing-hive-metastores/sample_addpartitions.hql 4 aws-blog-athena-importing-hive-metastores/executescript.gvy 38 aws-blog-nodejs-on-emr/src/sample-reducer.js 35 aws-blog-nodejs-on-emr/src/sample-mapper.js 37 aws-blog-titan-graph-database/src/main/java/com/amazonaws/bigdatablog/titanrestaurants/RestaurantFactory.java 156 aws-blog-iot-athena-quicksight-bi/heartrate.py 40