Path	Lines of Code
README.md	166
checkstyle.xml	112
common/src/main/resources/log4j.properties	33
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/examples/MapReduceDisaggregationOptimization.java	36
deploy/README.md	57
examples/beam/pom.xml	105
examples/beam/src/main/java/org/apache/nemo/examples/beam/AlternatingLeastSquare.java	264
examples/beam/src/main/java/org/apache/nemo/examples/beam/AlternatingLeastSquareInefficient.java	95
examples/beam/src/main/java/org/apache/nemo/examples/beam/BeamWordCount.java	75
examples/beam/src/main/java/org/apache/nemo/examples/beam/Broadcast.java	39
examples/beam/src/main/java/org/apache/nemo/examples/beam/EDGARAvgDocSize.java	56
examples/beam/src/main/java/org/apache/nemo/examples/beam/EDGARDocumentSuccessRate.java	57
examples/beam/src/main/java/org/apache/nemo/examples/beam/EDGARRequestsByCIK.java	56
examples/beam/src/main/java/org/apache/nemo/examples/beam/EDGARTop10BadRefererDocs.java	71
examples/beam/src/main/java/org/apache/nemo/examples/beam/EDGARTop10Documents.java	70
examples/beam/src/main/java/org/apache/nemo/examples/beam/FloatArrayCoder.java	28
examples/beam/src/main/java/org/apache/nemo/examples/beam/GenericSourceSink.java	100
examples/beam/src/main/java/org/apache/nemo/examples/beam/IntArrayCoder.java	28
examples/beam/src/main/java/org/apache/nemo/examples/beam/MinimalWordCount.java	35
examples/beam/src/main/java/org/apache/nemo/examples/beam/MultinomialLogisticRegression.java	298
examples/beam/src/main/java/org/apache/nemo/examples/beam/NemoPipelineOptionsFactory.java	20
examples/beam/src/main/java/org/apache/nemo/examples/beam/NetworkTraceAnalysis.java	98
examples/beam/src/main/java/org/apache/nemo/examples/beam/ObjectCoderForString.java	24
examples/beam/src/main/java/org/apache/nemo/examples/beam/PartitionWordsByLength.java	70
examples/beam/src/main/java/org/apache/nemo/examples/beam/PerKeyMedian.java	50
examples/beam/src/main/java/org/apache/nemo/examples/beam/PerPercentileAverage.java	86
examples/beam/src/main/java/org/apache/nemo/examples/beam/SimpleSumSQL.java	47
examples/beam/src/main/java/org/apache/nemo/examples/beam/WindowedBroadcast.java	50
examples/beam/src/main/java/org/apache/nemo/examples/beam/WindowedWordCount.java	95
examples/beam/src/main/java/org/apache/nemo/examples/beam/WordCount.java	43
examples/beam/src/main/java/org/apache/nemo/examples/beam/WordCountTimeOut1Sec.java	27
examples/beam/src/main/java/org/apache/nemo/examples/beam/WriteOneFilePerWindow.java	82
examples/beam/src/test/java/org/apache/nemo/examples/beam/AlternatingLeastSquareITCase.java	66
examples/beam/src/test/java/org/apache/nemo/examples/beam/BeamSimpleSumSQLITCase.java	43
examples/beam/src/test/java/org/apache/nemo/examples/beam/BroadcastITCase.java	53
examples/beam/src/test/java/org/apache/nemo/examples/beam/EDGARITCase.java	152
examples/beam/src/test/java/org/apache/nemo/examples/beam/MultinomialLogisticRegressionITCase.java	43
examples/beam/src/test/java/org/apache/nemo/examples/beam/NetworkTraceAnalysisITCase.java	71
examples/beam/src/test/java/org/apache/nemo/examples/beam/PartitionWordsByLengthITCase.java	57
examples/beam/src/test/java/org/apache/nemo/examples/beam/PerKeyMedianITCase.java	53
examples/beam/src/test/java/org/apache/nemo/examples/beam/PerPercentileAverageITCase.java	49
examples/beam/src/test/java/org/apache/nemo/examples/beam/TimeoutITCase.java	42
examples/beam/src/test/java/org/apache/nemo/examples/beam/WindowedBroadcastITCase.java	36
examples/beam/src/test/java/org/apache/nemo/examples/beam/WindowedWordCountITCase.java	108
examples/beam/src/test/java/org/apache/nemo/examples/beam/WordCountITCase.java	106
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/AggressiveSpeculativeCloningPolicyParallelismFive.java	27
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/DataSkewPolicyParallelismFive.java	22
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/DefaultPolicyParallelismFive.java	22
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/DisaggregationPolicyParallelismFive.java	23
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/LargeShufflePolicyParallelismFive.java	22
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/PolicyTestUtil.java	13
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/StreamingPolicyParallelismFive.java	25
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/TransientResourcePolicyParallelismFive.java	23
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/TransientResourcePolicyParallelismTen.java	23
examples/beam/src/test/java/org/apache/nemo/examples/beam/policy/UpfrontSchedulingPolicyParallelismFive.java	27
examples/nexmark/pom.xml	79
examples/nexmark/src/test/java/org/apache/nemo/examples/nexmark/NexmarkITCase.java	34
examples/pom.xml	17
examples/resources/executors/beam_test_executor_resources.json	12
examples/resources/executors/beam_test_one_executor_resources.json	7
examples/resources/executors/beam_test_poisoned_executor_resources.json	13
examples/resources/executors/spark_test_executor_resources.json	12
examples/resources/inputs/test_input_employees.json	4
examples/resources/inputs/test_input_people.json	3
examples/resources/inputs/test_input_people.txt	3
examples/spark/pom.xml	133
examples/spark/src/main/java/org/apache/nemo/examples/spark/JavaMapReduce.java	43
examples/spark/src/main/java/org/apache/nemo/examples/spark/JavaSparkPi.java	31
examples/spark/src/main/java/org/apache/nemo/examples/spark/JavaWordAndLineCount.java	55
examples/spark/src/main/java/org/apache/nemo/examples/spark/JavaWordCount.java	46
examples/spark/src/main/java/org/apache/nemo/examples/spark/sql/JavaSparkSQLExample.java	135
examples/spark/src/main/java/org/apache/nemo/examples/spark/sql/JavaUserDefinedTypedAggregation.java	93
examples/spark/src/main/java/org/apache/nemo/examples/spark/sql/JavaUserDefinedUntypedAggregation.java	75
examples/spark/src/main/scala/org/apache/nemo/examples/spark/SparkALS.scala	100
examples/spark/src/main/scala/org/apache/nemo/examples/spark/SparkCachingWordCount.scala	42
examples/spark/src/main/scala/org/apache/nemo/examples/spark/SparkPi.scala	20
examples/spark/src/main/scala/org/apache/nemo/examples/spark/SparkWordCount.scala	29
examples/spark/src/test/java/org/apache/nemo/examples/spark/MRJava.java	62
examples/spark/src/test/java/org/apache/nemo/examples/spark/SparkJava.java	64
examples/spark/src/test/java/org/apache/nemo/examples/spark/SparkScala.java	106
log4j.properties	33
ml/requirements.txt	9
webui/README.md	22
webui/package.json	60