Path	Lines of Code
src/main/java/com/aliyun/emr/example/hadoop/EMapReduceOSSUtil.java	57
src/main/java/com/aliyun/emr/example/hadoop/WordCount.java	119
src/main/java/com/aliyun/emr/example/spark/SparkMaxComputeJavaDemo.java	41
src/main/java/com/aliyun/emr/example/spark/SparkOssJavaDemo.java	27
src/main/java/com/aliyun/emr/example/spark/SparkTableStoreJavaDemo.java	68
src/main/java/com/aliyun/emr/example/spark/sql/streaming/SparkSLSContinuousStructuredStreamingJavaDemo.java	53
src/main/java/com/aliyun/emr/example/spark/sql/streaming/SparkSLSStructuredStreamingJavaDemo.java	58
src/main/java/com/aliyun/emr/example/spark/streaming/JavaLoghubWordCount.java	71
src/main/java/com/aliyun/emr/example/spark/streaming/SparkMNSJavaDemo.java	60
src/main/java/com/aliyun/emr/example/spark/streaming/SparkRocketMQJavaDemo.java	69
src/main/java/com/aliyun/emr/example/storm/StormKafkaSample.java	67
src/main/java/com/aliyun/emr/example/storm/benchmark/AbstractTopology.java	67
src/main/java/com/aliyun/emr/example/storm/benchmark/BasicTopology.java	94
src/main/java/com/aliyun/emr/example/storm/benchmark/KafkaHdfs.java	48
src/main/java/com/aliyun/emr/example/storm/benchmark/TridentWordCount.java	89
src/main/java/com/aliyun/emr/example/storm/benchmark/WindowedWordCount.java	83
src/main/java/com/aliyun/emr/example/storm/benchmark/WordCount.java	71
src/main/java/com/aliyun/emr/example/storm/benchmark/util/Helper.java	102
src/main/pig/sample.pig	55
src/main/python/deeplearning/tf_fm_on_spark.py	131
src/main/python/deeplearning/train_boston.py	50
src/main/python/odps-sample.py	48
src/main/python/streaming/loghub-wordcount.py	27
src/main/python/streaming/wcmapper.py	6
src/main/python/streaming/wcreducer.py	21
src/main/python/wordcount.py	13
src/main/scala/com/aliyun/emr/example/flink/FlinkOSSSample.scala	19
src/main/scala/com/aliyun/emr/example/spark/AbstractParams.scala	19
src/main/scala/com/aliyun/emr/example/spark/LinearRegression.scala	91
src/main/scala/com/aliyun/emr/example/spark/MongoDBWordCount.scala	61
src/main/scala/com/aliyun/emr/example/spark/RunLocally.scala	12
src/main/scala/com/aliyun/emr/example/spark/SparkMaxComputeDemo.scala	49
src/main/scala/com/aliyun/emr/example/spark/SparkOssDemo.scala	43
src/main/scala/com/aliyun/emr/example/spark/SparkPi.scala	16
src/main/scala/com/aliyun/emr/example/spark/SparkRdsDemo.scala	63
src/main/scala/com/aliyun/emr/example/spark/SparkWordCount.scala	25
src/main/scala/com/aliyun/emr/example/spark/sql/ODPSDataSourceSample.scala	61
src/main/scala/com/aliyun/emr/example/spark/sql/streaming/SparkSLSContinuousStructuredStreamingDemo.scala	44
src/main/scala/com/aliyun/emr/example/spark/sql/streaming/SparkSLSStructuredStreamingDemo.scala	44
src/main/scala/com/aliyun/emr/example/spark/streaming/DirectSparkSLSDemo.scala	52
src/main/scala/com/aliyun/emr/example/spark/streaming/DtsSample.scala	38
src/main/scala/com/aliyun/emr/example/spark/streaming/SparkDatahubDemo.scala	70
src/main/scala/com/aliyun/emr/example/spark/streaming/SparkHBaseDemo.scala	90
src/main/scala/com/aliyun/emr/example/spark/streaming/SparkKafkaDemo.scala	43
src/main/scala/com/aliyun/emr/example/spark/streaming/SparkMNSDemo.scala	30
src/main/scala/com/aliyun/emr/example/spark/streaming/SparkRocketMQDemo.scala	95
src/main/scala/com/aliyun/emr/example/spark/streaming/SparkSLSDemo.scala	42
src/main/scala/com/aliyun/emr/example/spark/streaming/benchmark/AbstractStreaming.scala	45
src/main/scala/com/aliyun/emr/example/spark/streaming/benchmark/KafkaHdfs.scala	12
src/main/scala/com/aliyun/emr/example/spark/streaming/benchmark/WordCount.scala	22
src/main/scala/com/aliyun/emr/example/spark/streaming/benchmark/metrics/BasicMetrics.scala	19
src/main/scala/com/aliyun/emr/example/spark/streaming/benchmark/metrics/HdfsMetrics.scala	34
src/main/scala/com/aliyun/emr/example/spark/streaming/benchmark/metrics/KafkaMetrics.scala	26