(incubator-wayang) branch main updated (f8d4a8ef -> 58fed276)

[zkaoudi]

This is an automated email from the ASF dual-hosted git repository.

zkaoudi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git


    from f8d4a8ef Merge pull request #388 from joker-star-l/dev
     new 4c9ada77 Retire Java8/Scala 2.11 support in restructure
     new 4ee98feb Add spark-mllib in wayang-api-spark-java
     new 44ccaf78 Revert changes to packaging tags in poms
     new 3498a9d6 remove misc file
     new c20c7f40 Fix build but still have failing integration tests
     new 3b95432f Remove spark.version definition in wayang-tests-integration
     new 8e815bde Reintroduce multiversion compilation for 
wayang-tests-integration
     new c158fe6c Finish restructure and fix to verify build
     new dbd6e15b Rebase from main
     new b75b1ab7 Fix build by integrating changes from main
     new 4d474d06 Add missing dependency for scala-java-api
     new 6db41886 Remove wayang-graphchi
     new 58fed276 Merge pull request #389 from juripetersen/283-code-restructure

The 1974 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .github/workflows/backend.yml                      |   6 +-
 .gitignore                                         |   2 +-
 README.md                                          |  17 +-
 build.md                                           |  14 +-
 guides/develop-with-Wayang.md                      |   8 +-
 guides/pom-example.xml                             |   4 +-
 pom.xml                                            | 171 +---------------
 wayang-api/pom.xml                                 |   2 +-
 wayang-api/wayang-api-scala-java/pom.xml           |  66 +++---
 .../wayang-api-scala-java/src/main/scala/README.md |  16 --
 .../scala/org/apache/wayang/api/DataQuanta.scala   |   0
 .../org/apache/wayang/api/DataQuantaBuilder.scala  |   0
 .../org/apache/wayang/api/JavaPlanBuilder.scala    |   0
 .../scala/org/apache/wayang/api/PlanBuilder.scala  |   0
 .../org/apache/wayang/api/RecordDataQuanta.scala   |   0
 .../wayang/api/RecordDataQuantaBuilder.scala       |   0
 .../scala/org/apache/wayang/api/graph/Edge.scala   |   0
 .../apache/wayang/api/graph/EdgeDataQuanta.scala   |   0
 .../wayang/api/graph/EdgeDataQuantaBuilder.scala   |   0
 .../org/apache/wayang/api/graph/package.scala      |   0
 .../main/scala/org/apache/wayang/api/package.scala |   0
 .../wayang/api/util/DataQuantaBuilderCache.scala   |   0
 .../api/util/DataQuantaBuilderDecorator.scala      |   0
 .../org/apache/wayang/api/util/TypeTrap.scala      |   0
 .../java/org/apache/wayang/api/JavaApiTest.java    |   0
 .../{code => src}/test/resources/wayang.properties |   0
 .../test/scala/org/apache/wayang/api/ApiTest.scala |   0
 .../wayang-api-scala-java_2.11/pom.xml             |  56 ------
 .../wayang-api-scala-java_2.11/scala_2.11          |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../src/main/scala/README.md                       |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../src/test/scala/README.md                       |  16 --
 .../wayang-api-scala-java_2.12/pom.xml             |  57 ------
 .../wayang-api-scala-java_2.12/scala_2.12          |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../src/main/scala/README.md                       |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../src/test/scala/README.md                       |  16 --
 wayang-api/wayang-api-sql/pom.xml                  |  29 ++-
 wayang-assembly/pom.xml                            |  26 ++-
 wayang-benchmark/pom.xml                           |  75 ++++---
 .../java/org/apache/wayang/apps/grep/Grep.java     |   0
 .../java/org/apache/wayang/apps/sgd/SGDImpl.java   |   0
 .../apache/wayang/apps/sgd/SGDImprovedImpl.java    |   0
 .../org/apache/wayang/apps/terasort/Random16.java  |   0
 .../apache/wayang/apps/terasort/Unsigned16.java    |   0
 .../java/org/apache/wayang/apps/tpch/Main.java     |   0
 .../wayang/apps/tpch/data/LineItemTuple.java       |   0
 .../apache/wayang/apps/tpch/data/q1/GroupKey.java  |   0
 .../wayang/apps/tpch/data/q1/ReturnTuple.java      |   0
 .../org/apache/wayang/apps/wordcount/Main.java     |   0
 .../main/resources/simplelogger.properties         |   0
 wayang-benchmark/src/main/scala/README.md          |  16 --
 .../apps/benchmark/OptimizerScalabilityTest.scala  |   0
 .../wayang/apps/benchmark/PlanGenerator.scala      |   0
 .../apps/crocopr/CreateInitialPageRanks.scala      |   0
 .../org/apache/wayang/apps/crocopr/CrocoPR.scala   |   0
 .../org/apache/wayang/apps/kmeans/Kmeans.scala     |   0
 .../wayang/apps/kmeans/postgres/Kmeans.scala       |   0
 .../scala/org/apache/wayang/apps/sgd/SGD.scala     |   0
 .../wayang/apps/simwords/AddIdFunction.scala       |   0
 .../simwords/CreateWordNeighborhoodFunction.scala  |   0
 .../apps/simwords/ResolveClusterFunction.scala     |   0
 .../wayang/apps/simwords/ScrubFunction.scala       |   0
 .../simwords/SelectNearestCentroidFunction.scala   |   0
 .../org/apache/wayang/apps/simwords/SimWords.scala |   0
 .../apache/wayang/apps/simwords/SparseVector.scala |   0
 .../apache/wayang/apps/simwords/TextScrubber.scala |   0
 .../apache/wayang/apps/simwords/Word2NVec.scala    |   0
 .../scala/org/apache/wayang/apps/sindy/Sindy.scala |   0
 .../org/apache/wayang/apps/terasort/TeraApp.scala  |   0
 .../org/apache/wayang/apps/terasort/TeraGen.scala  |   0
 .../org/apache/wayang/apps/terasort/TeraSort.scala |   0
 .../apache/wayang/apps/terasort/TeraValidate.scala |   0
 .../org/apache/wayang/apps/tpch/CsvUtils.scala     |   0
 .../org/apache/wayang/apps/tpch/SqlUtils.scala     |   0
 .../scala/org/apache/wayang/apps/tpch/TpcH.scala   |   0
 .../apache/wayang/apps/tpch/data/Customer.scala    |   0
 .../apache/wayang/apps/tpch/data/LineItem.scala    |   0
 .../org/apache/wayang/apps/tpch/data/Order.scala   |   0
 .../apache/wayang/apps/tpch/queries/Query1.scala   |   0
 .../wayang/apps/tpch/queries/Query3Database.scala  |   0
 .../wayang/apps/tpch/queries/Query3File.scala      |   0
 .../wayang/apps/tpch/queries/Query3Hybrid.scala    |   0
 .../wayang/apps/util/ExperimentDescriptor.scala    |   0
 .../org/apache/wayang/apps/util/Parameters.scala   |   2 -
 .../apache/wayang/apps/util/ProfileDBHelper.scala  |   0
 .../scala/org/apache/wayang/apps/util/StdOut.scala |   0
 .../wayang/apps/wordcount/WordCountScala.scala     |   0
 .../wayang/apps/tpch/data/LineItemTupleTest.java   |   0
 .../test/resources/kmeans-datagenerator.py         |   0
 .../test/resources/kmeans-k4-10000.input           |   0
 .../{code => src}/test/resources/rheem.properties  |   0
 .../org/apache/wayang/apps/kmeans/KmeansTest.scala |   0
 .../apache/wayang/apps/util/ParametersTest.scala   |   0
 wayang-benchmark/wayang-benchmark_2.11/pom.xml     |  63 ------
 wayang-benchmark/wayang-benchmark_2.11/scala_2.11  |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../wayang-benchmark_2.11/src/main/scala/README.md |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../wayang-benchmark_2.11/src/test/scala/README.md |  16 --
 wayang-benchmark/wayang-benchmark_2.12/pom.xml     |  64 ------
 wayang-benchmark/wayang-benchmark_2.12/scala_2.12  |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../wayang-benchmark_2.12/src/main/scala/README.md |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../wayang-benchmark_2.12/src/test/scala/README.md |  16 --
 wayang-commons/pom.xml                             |   2 +-
 wayang-docs/src/main/resources/index.md            |  10 +-
 wayang-ml4all/pom.xml                              |  18 +-
 .../apache/wayang/ml4all/examples/RunKMeans.java   |   1 +
 wayang-platforms/pom.xml                           |   3 +-
 wayang-platforms/wayang-flink/pom.xml              |  44 ++--
 .../main/java/org/apache/wayang/flink/Flink.java   |   0
 .../wayang/flink/channels/ChannelConversions.java  |   0
 .../wayang/flink/channels/DataSetChannel.java      |   0
 .../flink/compiler/FlinkCoGroupFunction.java       |   0
 .../wayang/flink/compiler/FunctionCompiler.java    |   0
 .../wayang/flink/compiler/KeySelectorDistinct.java |   0
 .../wayang/flink/compiler/KeySelectorFunction.java |   0
 .../flink/compiler/OutputFormatConsumer.java       |   0
 .../flink/compiler/WayangFileOutputFormat.java     |   0
 .../flink/compiler/criterion/DummyFilter.java      |   0
 .../wayang/flink/compiler/criterion/DummyMap.java  |   0
 .../flink/compiler/criterion/WayangAggregator.java |   0
 .../criterion/WayangConvergenceCriterion.java      |   0
 .../compiler/criterion/WayangFilterCriterion.java  |   0
 .../flink/compiler/criterion/WayangListValue.java  |   0
 .../flink/compiler/criterion/WayangValue.java      |   0
 .../flink/execution/FlinkContextReference.java     |   0
 .../flink/execution/FlinkExecutionContext.java     |   0
 .../wayang/flink/execution/FlinkExecutor.java      |   0
 .../wayang/flink/mapping/CartesianMapping.java     |   0
 .../wayang/flink/mapping/CoGroupMapping.java       |   0
 .../flink/mapping/CollectionSourceMapping.java     |   0
 .../apache/wayang/flink/mapping/CountMapping.java  |   0
 .../wayang/flink/mapping/DistinctMapping.java      |   0
 .../wayang/flink/mapping/DoWhileMapping.java       |   0
 .../apache/wayang/flink/mapping/FilterMapping.java |   0
 .../wayang/flink/mapping/FlatMapMapping.java       |   0
 .../mapping/GlobalMaterializedGroupMapping.java    |   0
 .../wayang/flink/mapping/GlobalReduceMapping.java  |   0
 .../wayang/flink/mapping/GroupByMapping.java       |   0
 .../wayang/flink/mapping/IntersectMapping.java     |   0
 .../apache/wayang/flink/mapping/JoinMapping.java   |   0
 .../flink/mapping/LocalCallbackSinkMapping.java    |   0
 .../apache/wayang/flink/mapping/LoopMapping.java   |   0
 .../apache/wayang/flink/mapping/MapMapping.java    |   0
 .../wayang/flink/mapping/MapPartitionsMapping.java |   0
 .../org/apache/wayang/flink/mapping/Mappings.java  |   0
 .../flink/mapping/MaterializedGroupByMapping.java  |   0
 .../flink/mapping/ObjectFileSinkMapping.java       |   0
 .../flink/mapping/ObjectFileSourceMapping.java     |   0
 .../wayang/flink/mapping/PageRankMapping.java      |   0
 .../wayang/flink/mapping/ReduceByMapping.java      |   0
 .../apache/wayang/flink/mapping/RepeatMapping.java |   0
 .../apache/wayang/flink/mapping/SampleMapping.java |   0
 .../apache/wayang/flink/mapping/SortMapping.java   |   0
 .../wayang/flink/mapping/TextFileSinkMapping.java  |   0
 .../flink/mapping/TextFileSourceMapping.java       |   0
 .../wayang/flink/mapping/UnionAllMapping.java      |   0
 .../wayang/flink/mapping/ZipWithIdMapping.java     |   0
 .../flink/operators/FlinkCartesianOperator.java    |   0
 .../flink/operators/FlinkCoGroupOperator.java      |   0
 .../flink/operators/FlinkCollectionSink.java       |   0
 .../flink/operators/FlinkCollectionSource.java     |   0
 .../wayang/flink/operators/FlinkCountOperator.java |   0
 .../flink/operators/FlinkDistinctOperator.java     |   0
 .../flink/operators/FlinkDoWhileOperator.java      |   0
 .../flink/operators/FlinkExecutionOperator.java    |   0
 .../flink/operators/FlinkFilterOperator.java       |   0
 .../flink/operators/FlinkFlatMapOperator.java      |   0
 .../FlinkGlobalMaterializedGroupOperator.java      |   0
 .../flink/operators/FlinkGlobalReduceOperator.java |   0
 .../flink/operators/FlinkGroupByOperator.java      |   0
 .../flink/operators/FlinkIntersectOperator.java    |   0
 .../wayang/flink/operators/FlinkJoinOperator.java  |   0
 .../flink/operators/FlinkLocalCallbackSink.java    |   0
 .../wayang/flink/operators/FlinkLoopOperator.java  |   0
 .../wayang/flink/operators/FlinkMapOperator.java   |   0
 .../operators/FlinkMapPartitionsOperator.java      |   0
 .../FlinkMaterializedGroupByOperator.java          |   0
 .../flink/operators/FlinkObjectFileSink.java       |   0
 .../flink/operators/FlinkObjectFileSource.java     |   0
 .../flink/operators/FlinkPageRankOperator.java     |   0
 .../flink/operators/FlinkReduceByOperator.java     |   0
 .../operators/FlinkRepeatExpandedOperator.java     |   0
 .../flink/operators/FlinkRepeatOperator.java       |   0
 .../flink/operators/FlinkSampleOperator.java       |   0
 .../wayang/flink/operators/FlinkSortOperator.java  |   0
 .../wayang/flink/operators/FlinkTextFileSink.java  |   0
 .../flink/operators/FlinkTextFileSource.java       |   0
 .../wayang/flink/operators/FlinkTsvFileSink.java   |   0
 .../flink/operators/FlinkUnionAllOperator.java     |   0
 .../flink/operators/FlinkZipWithIdOperator.java    |   0
 .../wayang/flink/platform/FlinkPlatform.java       |   0
 .../wayang/flink/plugin/FlinkBasicPlugin.java      |   0
 .../wayang/flink/plugin/FlinkConversionPlugin.java |   0
 .../wayang/flink/plugin/FlinkGraphPlugin.java      |   0
 .../resources/wayang-flink-defaults.properties     |   0
 .../wayang-flink/src/main/scala/README.md          |  16 --
 .../operators/FlinkCartesianOperatorTest.java      |   0
 .../flink/operators/FlinkCoGroupOperatorTest.java  |   0
 .../flink/operators/FlinkCollectionSourceTest.java |   0
 .../flink/operators/FlinkCountOperatorTest.java    |   0
 .../flink/operators/FlinkDistinctOperatorTest.java |   0
 .../flink/operators/FlinkFilterOperatorTest.java   |   0
 .../flink/operators/FlinkFlatMapOperatorTest.java  |   0
 .../FlinkGlobalMaterializedGroupOperatorTest.java  |   0
 .../operators/FlinkGlobalReduceOperatorTest.java   |   0
 .../flink/operators/FlinkJoinOperatorTest.java     |   0
 .../operators/FlinkMapPartitionsOperatorTest.java  |   0
 .../FlinkMaterializedGroupByOperatorTest.java      |   0
 .../flink/operators/FlinkOperatorTestBase.java     |   0
 .../flink/operators/FlinkReduceByOperatorTest.java |   0
 .../flink/operators/FlinkSortOperatorTest.java     |   0
 .../flink/operators/FlinkUnionAllOperatorTest.java |   0
 .../apache/wayang/flink/test/ChannelFactory.java   |   0
 .../wayang-flink/wayang-flink_2.11/pom.xml         |  56 ------
 .../wayang-flink/wayang-flink_2.11/scala_2.11      |  18 --
 .../wayang-flink_2.11/src/main/resources/README.md |  16 --
 .../wayang-flink_2.11/src/main/scala/README.md     |  16 --
 .../wayang-flink_2.11/src/test/resources/README.md |  16 --
 .../wayang-flink_2.11/src/test/scala/README.md     |  16 --
 .../wayang-flink/wayang-flink_2.12/pom.xml         |  56 ------
 .../wayang-flink/wayang-flink_2.12/scala_2.12      |  18 --
 .../wayang-flink_2.12/src/main/resources/README.md |  16 --
 .../wayang-flink_2.12/src/main/scala/README.md     |  16 --
 .../wayang-flink_2.12/src/test/resources/README.md |  16 --
 .../wayang-flink_2.12/src/test/scala/README.md     |  16 --
 wayang-platforms/wayang-generic-jdbc/pom.xml       |   2 +-
 wayang-platforms/wayang-graphchi/pom.xml           |  74 -------
 .../java/org/apache/wayang/graphchi/GraphChi.java  |  50 -----
 .../graphchi/channels/ChannelConversions.java      |  37 ----
 .../graphchi/execution/GraphChiExecutor.java       | 122 -----------
 .../apache/wayang/graphchi/mappings/Mappings.java  |  35 ----
 .../wayang/graphchi/mappings/PageRankMapping.java  |  62 ------
 .../operators/GraphChiExecutionOperator.java       |  50 -----
 .../operators/GraphChiPageRankOperator.java        | 222 ---------------------
 .../wayang/graphchi/platform/GraphChiPlatform.java |  98 ---------
 .../wayang/graphchi/plugin/GraphChiPlugin.java     |  63 ------
 .../resources/wayang-graphchi-defaults.properties  |  65 ------
 .../operators/GraphChiPageRankOperatorTest.java    |  92 ---------
 .../src/test/resources/test.edgelist.input         |   7 -
 wayang-platforms/wayang-jdbc-template/pom.xml      |   3 +-
 wayang-platforms/wayang-spark/pom.xml              |  45 +++--
 .../main/java/org/apache/wayang/spark/Spark.java   |   0
 .../wayang/spark/channels/BroadcastChannel.java    |   0
 .../wayang/spark/channels/ChannelConversions.java  |   0
 .../apache/wayang/spark/channels/FileChannels.java |   0
 .../apache/wayang/spark/channels/RddChannel.java   |   0
 .../spark/compiler/BinaryOperatorAdapter.java      |   0
 .../compiler/ExtendedBinaryOperatorAdapter.java    |   0
 .../compiler/ExtendedFlatMapFunctionAdapter.java   |   0
 .../wayang/spark/compiler/ExtendedFunction.java    |   0
 .../spark/compiler/ExtendedMapFunctionAdapter.java |   0
 .../ExtendedMapPartitionsFunctionAdapter.java      |   0
 .../spark/compiler/ExtendedPredicateAdapater.java  |   0
 .../spark/compiler/FlatMapFunctionAdapter.java     |   0
 .../wayang/spark/compiler/FunctionCompiler.java    |   0
 .../wayang/spark/compiler/MapFunctionAdapter.java  |   0
 .../compiler/MapPartitionsFunctionAdapter.java     |   0
 .../wayang/spark/compiler/PredicateAdapter.java    |   0
 .../spark/execution/SparkContextReference.java     |   0
 .../spark/execution/SparkExecutionContext.java     |   0
 .../wayang/spark/execution/SparkExecutor.java      |   0
 .../wayang/spark/mapping/CartesianMapping.java     |   0
 .../wayang/spark/mapping/CoGroupMapping.java       |   0
 .../spark/mapping/CollectionSourceMapping.java     |   0
 .../apache/wayang/spark/mapping/CountMapping.java  |   0
 .../wayang/spark/mapping/DistinctMapping.java      |   0
 .../wayang/spark/mapping/DoWhileMapping.java       |   0
 .../apache/wayang/spark/mapping/FilterMapping.java |   0
 .../wayang/spark/mapping/FlatMapMapping.java       |   0
 .../mapping/GlobalMaterializedGroupMapping.java    |   0
 .../wayang/spark/mapping/GlobalReduceMapping.java  |   0
 .../wayang/spark/mapping/IntersectMapping.java     |   0
 .../apache/wayang/spark/mapping/JoinMapping.java   |   0
 .../spark/mapping/LocalCallbackSinkMapping.java    |   0
 .../apache/wayang/spark/mapping/LoopMapping.java   |   0
 .../apache/wayang/spark/mapping/MapMapping.java    |   0
 .../wayang/spark/mapping/MapPartitionsMapping.java |   0
 .../org/apache/wayang/spark/mapping/Mappings.java  |   0
 .../spark/mapping/MaterializedGroupByMapping.java  |   0
 .../spark/mapping/ObjectFileSinkMapping.java       |   0
 .../spark/mapping/ObjectFileSourceMapping.java     |   0
 .../wayang/spark/mapping/ReduceByMapping.java      |   0
 .../apache/wayang/spark/mapping/RepeatMapping.java |   0
 .../apache/wayang/spark/mapping/SampleMapping.java |   0
 .../apache/wayang/spark/mapping/SortMapping.java   |   0
 .../wayang/spark/mapping/TextFileSinkMapping.java  |   0
 .../spark/mapping/TextFileSourceMapping.java       |   0
 .../wayang/spark/mapping/UnionAllMapping.java      |   0
 .../wayang/spark/mapping/ZipWithIdMapping.java     |   0
 .../spark/mapping/graph/PageRankMapping.java       |   0
 .../ml/DecisionTreeClassificationMapping.java      |   0
 .../wayang/spark/mapping/ml/KMeansMapping.java     |   0
 .../spark/mapping/ml/LinearRegressionMapping.java  |   0
 .../spark/mapping/ml/ModelTransformMapping.java    |   0
 .../apache/wayang/spark/model/SparkMLModel.java    |   0
 .../spark/monitoring/interfaces/Application.java   |   0
 .../spark/monitoring/interfaces/Executor.java      |   0
 .../wayang/spark/monitoring/interfaces/Job.java    |   0
 .../monitoring/interfaces/SerializableObject.java  |   0
 .../wayang/spark/monitoring/interfaces/Stage.java  |   0
 .../wayang/spark/monitoring/interfaces/Task.java   |   0
 .../spark/monitoring/interfaces/TaskMetric.java    |   0
 .../spark/monitoring/metrics/ApplicationEnd.java   |   0
 .../spark/monitoring/metrics/ApplicationStart.java |   0
 .../spark/monitoring/metrics/ExecutorAdded.java    |   0
 .../spark/monitoring/metrics/ExecutorRemoved.java  |   0
 .../spark/monitoring/metrics/ExecutorUpdated.java  |   0
 .../wayang/spark/monitoring/metrics/JobEnd.java    |   0
 .../wayang/spark/monitoring/metrics/JobStart.java  |   0
 .../spark/monitoring/metrics/SparkListener.java    |   0
 .../spark/monitoring/metrics/StageCompleted.java   |   0
 .../monitoring/metrics/StageExecutorMetrics.java   |   0
 .../spark/monitoring/metrics/StageSubmitted.java   |   0
 .../wayang/spark/monitoring/metrics/TaskEnd.java   |   0
 .../monitoring/metrics/TaskGettingResult.java      |   0
 .../spark/monitoring/metrics/TaskMetric.java       |   0
 .../wayang/spark/monitoring/metrics/TaskStart.java |   0
 .../operators/SparkBernoulliSampleOperator.java    |   0
 .../spark/operators/SparkBroadcastOperator.java    |   0
 .../wayang/spark/operators/SparkCacheOperator.java |   0
 .../spark/operators/SparkCartesianOperator.java    |   0
 .../spark/operators/SparkCoGroupOperator.java      |   0
 .../spark/operators/SparkCollectOperator.java      |   0
 .../spark/operators/SparkCollectionSource.java     |   0
 .../wayang/spark/operators/SparkCountOperator.java |   0
 .../spark/operators/SparkDistinctOperator.java     |   0
 .../spark/operators/SparkDoWhileOperator.java      |   0
 .../spark/operators/SparkExecutionOperator.java    |   0
 .../spark/operators/SparkFilterOperator.java       |   0
 .../spark/operators/SparkFlatMapOperator.java      |   0
 .../SparkGlobalMaterializedGroupOperator.java      |   0
 .../spark/operators/SparkGlobalReduceOperator.java |   0
 .../spark/operators/SparkIntersectOperator.java    |   0
 .../wayang/spark/operators/SparkJoinOperator.java  |   0
 .../spark/operators/SparkLocalCallbackSink.java    |   0
 .../wayang/spark/operators/SparkLoopOperator.java  |   0
 .../wayang/spark/operators/SparkMapOperator.java   |   0
 .../operators/SparkMapPartitionsOperator.java      |   0
 .../SparkMaterializedGroupByOperator.java          |   0
 .../spark/operators/SparkObjectFileSink.java       |   0
 .../spark/operators/SparkObjectFileSource.java     |   0
 .../SparkRandomPartitionSampleOperator.java        |   0
 .../spark/operators/SparkReduceByOperator.java     |   0
 .../spark/operators/SparkRepeatOperator.java       |   0
 .../SparkShufflePartitionSampleOperator.java       |   0
 .../wayang/spark/operators/SparkSortOperator.java  |   0
 .../wayang/spark/operators/SparkTextFileSink.java  |   0
 .../spark/operators/SparkTextFileSource.java       |   0
 .../wayang/spark/operators/SparkTsvFileSink.java   |   0
 .../wayang/spark/operators/SparkTsvFileSource.java |   0
 .../spark/operators/SparkUnionAllOperator.java     |   0
 .../spark/operators/SparkZipWithIdOperator.java    |   0
 .../org/apache/wayang/spark/operators/ml/Attr.java |   0
 .../SparkDecisionTreeClassificationOperator.java   |   0
 .../spark/operators/ml/SparkKMeansOperator.java    |   0
 .../ml/SparkLinearRegressionOperator.java          |   0
 .../operators/ml/SparkModelTransformOperator.java  |   0
 .../wayang/spark/platform/SparkPlatform.java       |   0
 .../wayang/spark/plugin/SparkBasicPlugin.java      |   0
 .../wayang/spark/plugin/SparkConversionPlugin.java |   0
 .../wayang/spark/plugin/SparkGraphPlugin.java      |   0
 .../apache/wayang/spark/plugin/SparkMLPlugin.java  |   0
 .../resources/wayang-spark-defaults.properties     |   0
 .../main/resources/wayang-spark-kafka.properties   |   0
 .../wayang-spark/src/main/scala/README.md          |  16 --
 .../operators/graph/SparkPageRankOperator.scala    |   0
 .../SparkBernoulliSampleOperatorTest.java          |   0
 .../operators/SparkCartesianOperatorTest.java      |   0
 .../spark/operators/SparkCoGroupOperatorTest.java  |   0
 .../spark/operators/SparkCollectionSourceTest.java |   0
 .../spark/operators/SparkCountOperatorTest.java    |   0
 ...parkDecisionTreeClassificationOperatorTest.java |   0
 .../spark/operators/SparkDistinctOperatorTest.java |   0
 .../spark/operators/SparkFilterOperatorTest.java   |   0
 .../spark/operators/SparkFlatMapOperatorTest.java  |   0
 .../SparkGlobalMaterializedGroupOperatorTest.java  |   0
 .../operators/SparkGlobalReduceOperatorTest.java   |   0
 .../spark/operators/SparkJoinOperatorTest.java     |   0
 .../spark/operators/SparkKMeansOperatorTest.java   |   0
 .../SparkLinearRegressionOperatorTest.java         |   0
 .../operators/SparkMapPartitionsOperatorTest.java  |   0
 .../SparkMaterializedGroupByOperatorTest.java      |   0
 .../spark/operators/SparkObjectFileSinkTest.java   |   0
 .../spark/operators/SparkObjectFileSourceTest.java |   0
 .../spark/operators/SparkOperatorTestBase.java     |   0
 .../SparkRandomPartitionSampleOperatorTest.java    |   0
 .../spark/operators/SparkReduceByOperatorTest.java |   0
 .../SparkShufflePartitionSampleOperatorTest.java   |   0
 .../spark/operators/SparkSortOperatorTest.java     |   0
 .../spark/operators/SparkTextFileSinkTest.java     |   0
 .../spark/operators/SparkUnionAllOperatorTest.java |   0
 .../apache/wayang/spark/test/ChannelFactory.java   |   0
 .../{code => src}/test/resources/0-to-10000.input  | Bin
 .../{code => src}/test/resources/wayang.properties |   0
 .../wayang-spark/wayang-spark_2.11/pom.xml         |  81 --------
 .../wayang-spark/wayang-spark_2.11/scala_2.11      |  18 --
 .../wayang-spark_2.11/src/main/resources/README.md |  16 --
 .../wayang-spark_2.11/src/main/scala/README.md     |  16 --
 .../wayang-spark_2.11/src/test/resources/README.md |  16 --
 .../wayang-spark_2.11/src/test/scala/README.md     |  16 --
 .../wayang-spark/wayang-spark_2.12/pom.xml         |  64 ------
 .../wayang-spark/wayang-spark_2.12/scala_2.12      |  18 --
 .../wayang-spark_2.12/src/main/resources/README.md |  16 --
 .../wayang-spark_2.12/src/main/scala/README.md     |  16 --
 .../wayang-spark_2.12/src/test/resources/README.md |  16 --
 .../wayang-spark_2.12/src/test/scala/README.md     |  16 --
 wayang-plugins/pom.xml                             |   6 +-
 wayang-plugins/wayang-iejoin/pom.xml               |  38 ++--
 .../main/java/org/apache/wayang/iejoin/IEJoin.java |   0
 .../java/org/apache/wayang/iejoin/data/Data.java   |   0
 .../org/apache/wayang/iejoin/mapping/Mappings.java |   0
 .../wayang/iejoin/mapping/java/IEJoinMapping.java  |   0
 .../iejoin/mapping/java/IESelfJoinMapping.java     |   0
 .../wayang/iejoin/mapping/spark/IEJoinMapping.java |   0
 .../iejoin/mapping/spark/IESelfJoinMapping.java    |   0
 .../iejoin/operators/IEJoinMasterOperator.java     |   0
 .../wayang/iejoin/operators/IEJoinOperator.java    |   0
 .../iejoin/operators/IESelfJoinOperator.java       |   0
 .../iejoin/operators/JavaIEJoinOperator.java       |   0
 .../iejoin/operators/JavaIESelfJoinOperator.java   |   0
 .../iejoin/operators/SparkIEJoinOperator.java      |   0
 .../iejoin/operators/SparkIESelfJoinOperator.java  |   0
 .../iejoin/operators/java_helpers/BitSetJoin.java  |   0
 .../operators/java_helpers/DataComparator.java     |   0
 .../iejoin/operators/java_helpers/extractData.java |   0
 .../iejoin/operators/java_helpers/myMergeSort.java |   0
 .../operators/java_helpers/revDataComparator.java  |   0
 .../iejoin/operators/spark_helpers/BitSetJoin.java |   0
 .../spark_helpers/List2AttributesObjectSkinny.java |   0
 .../operators/spark_helpers/addUniqueID.java       |   0
 .../operators/spark_helpers/build2ListObject.java  |   0
 .../operators/spark_helpers/extractData.java       |   0
 .../spark_helpers/filterUnwantedBlocks.java        |   0
 .../operators/spark_helpers/myMergeSort.java       |   0
 .../operators/spark_helpers/revDataComparator.java |   0
 .../wayang-iejoin/src/main/scala/README.md         |  16 --
 .../operators/JavaExecutionOperatorTestBase.java   |   0
 .../iejoin/operators/JavaIEJoinOperatorTest.java   |   0
 .../iejoin/operators/SparkIEJoinOperatorTest.java  |   0
 .../iejoin/operators/SparkIEJoinOperatorTest2.java |   0
 .../iejoin/operators/SparkIEJoinOperatorTest3.java |   0
 .../iejoin/operators/SparkIEJoinOperatorTest4.java |   0
 .../operators/SparkIESelfJoinOperatorTest.java     |   0
 .../iejoin/operators/SparkOperatorTestBase.java    |   0
 .../apache/wayang/iejoin/test/ChannelFactory.java  |   0
 .../{code => src}/test/resources/wayang.properties |   0
 .../wayang-iejoin/wayang-iejoin_2.11/pom.xml       |  48 -----
 .../wayang-iejoin/wayang-iejoin_2.11/scala_2.11    |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../wayang-iejoin_2.11/src/main/scala/README.md    |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../wayang-iejoin_2.11/src/test/scala/README.md    |  16 --
 .../wayang-iejoin/wayang-iejoin_2.12/pom.xml       |  48 -----
 .../wayang-iejoin/wayang-iejoin_2.12/scala_2.12    |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../wayang-iejoin_2.12/src/main/scala/README.md    |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../wayang-iejoin_2.12/src/test/scala/README.md    |  16 --
 wayang-profiler/pom.xml                            |  37 ++--
 .../wayang/profiler/data/DataGenerators.java       |   0
 .../wayang/profiler/hardware/DiskProfiler.java     |   0
 .../profiler/java/BinaryOperatorProfiler.java      |   0
 .../java/JavaCollectionSourceProfiler.java         |   0
 .../profiler/java/JavaTextFileSourceProfiler.java  |   0
 .../wayang/profiler/java/OperatorProfiler.java     |   0
 .../wayang/profiler/java/OperatorProfilers.java    |   0
 .../org/apache/wayang/profiler/java/Profiler.java  |   0
 .../apache/wayang/profiler/java/SinkProfiler.java  |   0
 .../wayang/profiler/java/SourceProfiler.java       |   0
 .../profiler/java/UnaryOperatorProfiler.java       |   0
 .../profiler/log/DynamicEstimationContext.java     |   0
 .../wayang/profiler/log/DynamicLoadEstimator.java  |   0
 .../profiler/log/DynamicLoadProfileEstimator.java  |   0
 .../profiler/log/DynamicLoadProfileEstimators.java |   0
 .../wayang/profiler/log/GeneticOptimizer.java      |   0
 .../wayang/profiler/log/GeneticOptimizerApp.java   |   1 -
 .../org/apache/wayang/profiler/log/Individual.java |   0
 .../apache/wayang/profiler/log/LogEvaluator.java   |   0
 .../wayang/profiler/log/OptimizationSpace.java     |   0
 .../org/apache/wayang/profiler/log/Variable.java   |   0
 .../wayang/profiler/log/sampling/Battle.java       |   0
 .../profiler/log/sampling/ReservoirSampler.java    |   0
 .../wayang/profiler/log/sampling/Sampler.java      |   0
 .../profiler/log/sampling/TournamentSampler.java   |   0
 .../profiler/spark/BinaryOperatorProfiler.java     |   0
 .../org/apache/wayang/profiler/spark/Main.java     |   0
 .../wayang/profiler/spark/OperatorProfilers.java   |   0
 .../apache/wayang/profiler/spark/SinkProfiler.java |   0
 .../spark/SparkCollectionSourceProfiler.java       |   0
 .../profiler/spark/SparkOperatorProfiler.java      |   0
 .../wayang/profiler/spark/SparkSourceProfiler.java |   0
 .../spark/SparkTextFileSourceProfiler.java         |   0
 .../profiler/spark/SparkUnaryOperatorProfiler.java |   0
 .../wayang/profiler/util/ProfilingUtils.java       |   0
 .../apache/wayang/profiler/util/RrdAccessor.java   |   0
 wayang-profiler/src/main/scala/README.md           |  16 --
 wayang-profiler/wayang-profiler_2.11/pom.xml       |  65 ------
 wayang-profiler/wayang-profiler_2.11/scala_2.11    |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../wayang-profiler_2.11/src/main/scala/README.md  |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../wayang-profiler_2.11/src/test/scala/README.md  |  16 --
 wayang-profiler/wayang-profiler_2.12/pom.xml       |  48 -----
 wayang-profiler/wayang-profiler_2.12/scala_2.12    |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../wayang-profiler_2.12/src/main/scala/README.md  |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../wayang-profiler_2.12/src/test/scala/README.md  |  16 --
 wayang-tests-integration/pom.xml                   |  76 +++++--
 wayang-tests-integration/src/main/scala/README.md  |  16 --
 .../apache/wayang/tests/FlinkIntegrationIT.java    |   0
 .../org/apache/wayang/tests/FullIntegrationIT.java |   0
 .../apache/wayang/tests/GiraphIntegrationIT.java   |   0
 .../org/apache/wayang/tests/JavaIntegrationIT.java |   0
 .../apache/wayang/tests/PostgresIntegrationIT.java |   0
 .../java/org/apache/wayang/tests/RegressionIT.java |   0
 .../apache/wayang/tests/SparkIntegrationIT.java    |   0
 .../java/org/apache/wayang/tests/WayangPlans.java  |   0
 .../apache/wayang/tests/WayangPlansOperators.java  |   0
 .../java/org/apache/wayang/tests/WordCountIT.java  |   0
 .../wayang/tests/platform/MyMadeUpPlatform.java    |   0
 .../test/resources/lines-with-key1.input           |   0
 .../test/resources/lines-with-key2.input           |   0
 .../{code => src}/test/resources/other-lines.input |   0
 .../{code => src}/test/resources/pagerank.input    |   0
 .../test/resources/pagerank_solution.input         |   0
 .../test/resources/simplelogger.properties         |   0
 .../{code => src}/test/resources/some-lines.input  |   0
 .../{code => src}/test/resources/text.input        |   0
 .../resources/wayang-hsqldb-defaults.properties    |   0
 .../{code => src}/test/resources/wayang.properties |   0
 .../wayang-tests-integration_2.11/pom.xml          | 110 ----------
 .../wayang-tests-integration_2.11/scala_2.11       |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../src/main/scala/README.md                       |  16 --
 .../apache/wayang/test/GraphChiIntegrationIT.java  | 103 ----------
 .../src/test/resources/README.md                   |  16 --
 .../src/test/scala/README.md                       |  16 --
 .../wayang-tests-integration_2.12/pom.xml          |  93 ---------
 .../wayang-tests-integration_2.12/scala_2.12       |  18 --
 .../src/main/resources/README.md                   |  16 --
 .../src/main/scala/README.md                       |  16 --
 .../src/test/resources/README.md                   |  16 --
 .../src/test/scala/README.md                       |  16 --
 550 files changed, 338 insertions(+), 3619 deletions(-)
 delete mode 100644 wayang-api/wayang-api-scala-java/src/main/scala/README.md
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/DataQuanta.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/PlanBuilder.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/RecordDataQuanta.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/RecordDataQuantaBuilder.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/graph/Edge.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/graph/EdgeDataQuanta.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/graph/EdgeDataQuantaBuilder.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/graph/package.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/package.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/util/DataQuantaBuilderCache.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/util/DataQuantaBuilderDecorator.scala 
(100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/main/scala/org/apache/wayang/api/util/TypeTrap.scala (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/test/java/org/apache/wayang/api/JavaApiTest.java (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/test/resources/wayang.properties (100%)
 rename wayang-api/wayang-api-scala-java/{code => 
src}/test/scala/org/apache/wayang/api/ApiTest.scala (100%)
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/pom.xml
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/scala_2.11
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/main/resources/README.md
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/main/scala/README.md
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/resources/README.md
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/scala/README.md
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/pom.xml
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/scala_2.12
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/main/resources/README.md
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/main/scala/README.md
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/resources/README.md
 delete mode 100644 
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/scala/README.md
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/grep/Grep.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/sgd/SGDImpl.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/sgd/SGDImprovedImpl.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/terasort/Random16.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/terasort/Unsigned16.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/tpch/Main.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/tpch/data/LineItemTuple.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/tpch/data/q1/GroupKey.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/tpch/data/q1/ReturnTuple.java (100%)
 rename wayang-benchmark/{code => 
src}/main/java/org/apache/wayang/apps/wordcount/Main.java (100%)
 rename wayang-benchmark/{code => src}/main/resources/simplelogger.properties 
(100%)
 delete mode 100644 wayang-benchmark/src/main/scala/README.md
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/benchmark/OptimizerScalabilityTest.scala 
(100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/benchmark/PlanGenerator.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/crocopr/CreateInitialPageRanks.scala 
(100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/crocopr/CrocoPR.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/kmeans/Kmeans.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/sgd/SGD.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/AddIdFunction.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/CreateWordNeighborhoodFunction.scala
 (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/ResolveClusterFunction.scala 
(100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/ScrubFunction.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/SelectNearestCentroidFunction.scala
 (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/SimWords.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/SparseVector.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/TextScrubber.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/simwords/Word2NVec.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/sindy/Sindy.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/terasort/TeraApp.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/terasort/TeraGen.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/terasort/TeraSort.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/terasort/TeraValidate.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/CsvUtils.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/SqlUtils.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/TpcH.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/data/Customer.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/data/LineItem.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/data/Order.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/queries/Query1.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/queries/Query3Database.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/queries/Query3File.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/tpch/queries/Query3Hybrid.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/util/ExperimentDescriptor.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/util/Parameters.scala (98%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/util/ProfileDBHelper.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/util/StdOut.scala (100%)
 rename wayang-benchmark/{code => 
src}/main/scala/org/apache/wayang/apps/wordcount/WordCountScala.scala (100%)
 rename wayang-benchmark/{code => 
src}/test/java/org/apache/wayang/apps/tpch/data/LineItemTupleTest.java (100%)
 rename wayang-benchmark/{code => src}/test/resources/kmeans-datagenerator.py 
(100%)
 rename wayang-benchmark/{code => src}/test/resources/kmeans-k4-10000.input 
(100%)
 rename wayang-benchmark/{code => src}/test/resources/rheem.properties (100%)
 rename wayang-benchmark/{code => 
src}/test/scala/org/apache/wayang/apps/kmeans/KmeansTest.scala (100%)
 rename wayang-benchmark/{code => 
src}/test/scala/org/apache/wayang/apps/util/ParametersTest.scala (100%)
 delete mode 100644 wayang-benchmark/wayang-benchmark_2.11/pom.xml
 delete mode 100644 wayang-benchmark/wayang-benchmark_2.11/scala_2.11
 delete mode 100644 
wayang-benchmark/wayang-benchmark_2.11/src/main/resources/README.md
 delete mode 100644 
wayang-benchmark/wayang-benchmark_2.11/src/main/scala/README.md
 delete mode 100644 
wayang-benchmark/wayang-benchmark_2.11/src/test/resources/README.md
 delete mode 100644 
wayang-benchmark/wayang-benchmark_2.11/src/test/scala/README.md
 delete mode 100644 wayang-benchmark/wayang-benchmark_2.12/pom.xml
 delete mode 100644 wayang-benchmark/wayang-benchmark_2.12/scala_2.12
 delete mode 100644 
wayang-benchmark/wayang-benchmark_2.12/src/main/resources/README.md
 delete mode 100644 
wayang-benchmark/wayang-benchmark_2.12/src/main/scala/README.md
 delete mode 100644 
wayang-benchmark/wayang-benchmark_2.12/src/test/resources/README.md
 delete mode 100644 
wayang-benchmark/wayang-benchmark_2.12/src/test/scala/README.md
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/Flink.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/channels/ChannelConversions.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/channels/DataSetChannel.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/FlinkCoGroupFunction.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/KeySelectorDistinct.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/OutputFormatConsumer.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/WayangFileOutputFormat.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/criterion/DummyFilter.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/criterion/DummyMap.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/criterion/WayangAggregator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/criterion/WayangConvergenceCriterion.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/criterion/WayangFilterCriterion.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/criterion/WayangListValue.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/compiler/criterion/WayangValue.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/execution/FlinkContextReference.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/execution/FlinkExecutionContext.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/CartesianMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/CoGroupMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/CollectionSourceMapping.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/CountMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/DistinctMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/DoWhileMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/FilterMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/FlatMapMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/GlobalMaterializedGroupMapping.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/GlobalReduceMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/GroupByMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/IntersectMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/JoinMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/LocalCallbackSinkMapping.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/LoopMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/MapMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/MapPartitionsMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/Mappings.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/MaterializedGroupByMapping.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/ObjectFileSinkMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/ObjectFileSourceMapping.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/PageRankMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/ReduceByMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/RepeatMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/SampleMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/SortMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/TextFileSinkMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/TextFileSourceMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/UnionAllMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/mapping/ZipWithIdMapping.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkCountOperator.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkDoWhileOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkExecutionOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkFilterOperator.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkFlatMapOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkGlobalMaterializedGroupOperator.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkIntersectOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkLoopOperator.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkMapOperator.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkMapPartitionsOperator.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkMaterializedGroupByOperator.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkPageRankOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkRepeatOperator.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkSampleOperator.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkSortOperator.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/operators/FlinkZipWithIdOperator.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/platform/FlinkPlatform.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/plugin/FlinkBasicPlugin.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/plugin/FlinkConversionPlugin.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/java/org/apache/wayang/flink/plugin/FlinkGraphPlugin.java (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/main/resources/wayang-flink-defaults.properties (100%)
 delete mode 100644 wayang-platforms/wayang-flink/src/main/scala/README.md
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkCartesianOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkCoGroupOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkCollectionSourceTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkCountOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkDistinctOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkFilterOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkFlatMapOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkGlobalMaterializedGroupOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkJoinOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkMapPartitionsOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkMaterializedGroupByOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkOperatorTestBase.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkReduceByOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkSortOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/operators/FlinkUnionAllOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-flink/{code => 
src}/test/java/org/apache/wayang/flink/test/ChannelFactory.java (100%)
 delete mode 100644 wayang-platforms/wayang-flink/wayang-flink_2.11/pom.xml
 delete mode 100644 wayang-platforms/wayang-flink/wayang-flink_2.11/scala_2.11
 delete mode 100644 
wayang-platforms/wayang-flink/wayang-flink_2.11/src/main/resources/README.md
 delete mode 100644 
wayang-platforms/wayang-flink/wayang-flink_2.11/src/main/scala/README.md
 delete mode 100644 
wayang-platforms/wayang-flink/wayang-flink_2.11/src/test/resources/README.md
 delete mode 100644 
wayang-platforms/wayang-flink/wayang-flink_2.11/src/test/scala/README.md
 delete mode 100644 wayang-platforms/wayang-flink/wayang-flink_2.12/pom.xml
 delete mode 100644 wayang-platforms/wayang-flink/wayang-flink_2.12/scala_2.12
 delete mode 100644 
wayang-platforms/wayang-flink/wayang-flink_2.12/src/main/resources/README.md
 delete mode 100644 
wayang-platforms/wayang-flink/wayang-flink_2.12/src/main/scala/README.md
 delete mode 100644 
wayang-platforms/wayang-flink/wayang-flink_2.12/src/test/resources/README.md
 delete mode 100644 
wayang-platforms/wayang-flink/wayang-flink_2.12/src/test/scala/README.md
 delete mode 100644 wayang-platforms/wayang-graphchi/pom.xml
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/GraphChi.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/channels/ChannelConversions.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/execution/GraphChiExecutor.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/mappings/Mappings.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/mappings/PageRankMapping.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/operators/GraphChiExecutionOperator.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/operators/GraphChiPageRankOperator.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/platform/GraphChiPlatform.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/java/org/apache/wayang/graphchi/plugin/GraphChiPlugin.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/main/resources/wayang-graphchi-defaults.properties
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/test/java/org/apache/wayang/graphchi/operators/GraphChiPageRankOperatorTest.java
 delete mode 100644 
wayang-platforms/wayang-graphchi/src/test/resources/test.edgelist.input
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/Spark.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/channels/BroadcastChannel.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/channels/ChannelConversions.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/channels/FileChannels.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/channels/RddChannel.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/BinaryOperatorAdapter.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/ExtendedBinaryOperatorAdapter.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/ExtendedFlatMapFunctionAdapter.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/ExtendedFunction.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/ExtendedMapFunctionAdapter.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/ExtendedMapPartitionsFunctionAdapter.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/ExtendedPredicateAdapater.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/FlatMapFunctionAdapter.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/FunctionCompiler.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/MapFunctionAdapter.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/MapPartitionsFunctionAdapter.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/compiler/PredicateAdapter.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/execution/SparkContextReference.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/execution/SparkExecutionContext.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/execution/SparkExecutor.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/CartesianMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/CoGroupMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/CollectionSourceMapping.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/CountMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/DistinctMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/DoWhileMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/FilterMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/FlatMapMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/GlobalMaterializedGroupMapping.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/GlobalReduceMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/IntersectMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/JoinMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/LocalCallbackSinkMapping.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/LoopMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/MapMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/MapPartitionsMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/Mappings.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/MaterializedGroupByMapping.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/ObjectFileSinkMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/ObjectFileSourceMapping.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/ReduceByMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/RepeatMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/SampleMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/SortMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/TextFileSinkMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/TextFileSourceMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/UnionAllMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/ZipWithIdMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/graph/PageRankMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/ml/DecisionTreeClassificationMapping.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/ml/KMeansMapping.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/ml/LinearRegressionMapping.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/mapping/ml/ModelTransformMapping.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/model/SparkMLModel.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/interfaces/Application.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/interfaces/Executor.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/interfaces/Job.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/interfaces/SerializableObject.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/interfaces/Stage.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/interfaces/Task.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/interfaces/TaskMetric.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/ApplicationEnd.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/ApplicationStart.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/ExecutorAdded.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/ExecutorRemoved.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/ExecutorUpdated.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/JobEnd.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/JobStart.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/SparkListener.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/StageCompleted.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/StageExecutorMetrics.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/StageSubmitted.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/TaskEnd.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/TaskGettingResult.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/TaskMetric.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/monitoring/metrics/TaskStart.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkBroadcastOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkCacheOperator.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkCartesianOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkCoGroupOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkCollectOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkCollectionSource.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkCountOperator.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkDistinctOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkDoWhileOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkExecutionOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkFilterOperator.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkFlatMapOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkGlobalReduceOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkIntersectOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkJoinOperator.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkLocalCallbackSink.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkLoopOperator.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkMapOperator.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkMapPartitionsOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkMaterializedGroupByOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkObjectFileSink.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkObjectFileSource.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkReduceByOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkRepeatOperator.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkSortOperator.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkTextFileSink.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkTextFileSource.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkTsvFileSink.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkTsvFileSource.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkUnionAllOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/SparkZipWithIdOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/ml/Attr.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/ml/SparkDecisionTreeClassificationOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/ml/SparkKMeansOperator.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/ml/SparkLinearRegressionOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/operators/ml/SparkModelTransformOperator.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/platform/SparkPlatform.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/plugin/SparkBasicPlugin.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/plugin/SparkConversionPlugin.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/plugin/SparkGraphPlugin.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/java/org/apache/wayang/spark/plugin/SparkMLPlugin.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/resources/wayang-spark-defaults.properties (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/main/resources/wayang-spark-kafka.properties (100%)
 delete mode 100644 wayang-platforms/wayang-spark/src/main/scala/README.md
 rename wayang-platforms/wayang-spark/{code => 
src}/main/scala/org/apache/wayang/spark/operators/graph/SparkPageRankOperator.scala
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkCartesianOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkCoGroupOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkCollectionSourceTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkCountOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkDecisionTreeClassificationOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkDistinctOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkFilterOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkFlatMapOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkGlobalReduceOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkJoinOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkKMeansOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkLinearRegressionOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkMapPartitionsOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkMaterializedGroupByOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkObjectFileSinkTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkObjectFileSourceTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkOperatorTestBase.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkReduceByOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperatorTest.java
 (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkSortOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkTextFileSinkTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/operators/SparkUnionAllOperatorTest.java 
(100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/java/org/apache/wayang/spark/test/ChannelFactory.java (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/resources/0-to-10000.input (100%)
 rename wayang-platforms/wayang-spark/{code => 
src}/test/resources/wayang.properties (100%)
 delete mode 100644 wayang-platforms/wayang-spark/wayang-spark_2.11/pom.xml
 delete mode 100644 wayang-platforms/wayang-spark/wayang-spark_2.11/scala_2.11
 delete mode 100644 
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/resources/README.md
 delete mode 100644 
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/scala/README.md
 delete mode 100644 
wayang-platforms/wayang-spark/wayang-spark_2.11/src/test/resources/README.md
 delete mode 100644 
wayang-platforms/wayang-spark/wayang-spark_2.11/src/test/scala/README.md
 delete mode 100644 wayang-platforms/wayang-spark/wayang-spark_2.12/pom.xml
 delete mode 100644 wayang-platforms/wayang-spark/wayang-spark_2.12/scala_2.12
 delete mode 100644 
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/resources/README.md
 delete mode 100644 
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/scala/README.md
 delete mode 100644 
wayang-platforms/wayang-spark/wayang-spark_2.12/src/test/resources/README.md
 delete mode 100644 
wayang-platforms/wayang-spark/wayang-spark_2.12/src/test/scala/README.md
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/IEJoin.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/data/Data.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/mapping/Mappings.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/mapping/java/IEJoinMapping.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/mapping/java/IESelfJoinMapping.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/mapping/spark/IEJoinMapping.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/mapping/spark/IESelfJoinMapping.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/IEJoinMasterOperator.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/IEJoinOperator.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/IESelfJoinOperator.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperator.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/JavaIESelfJoinOperator.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperator.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperator.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/java_helpers/BitSetJoin.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/java_helpers/DataComparator.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/java_helpers/extractData.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/java_helpers/myMergeSort.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/java_helpers/revDataComparator.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/BitSetJoin.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/List2AttributesObjectSkinny.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/addUniqueID.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/build2ListObject.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/extractData.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/filterUnwantedBlocks.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/myMergeSort.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/revDataComparator.java
 (100%)
 delete mode 100644 wayang-plugins/wayang-iejoin/src/main/scala/README.md
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/operators/JavaExecutionOperatorTestBase.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperatorTest.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest2.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest3.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest4.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperatorTest.java
 (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/operators/SparkOperatorTestBase.java 
(100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/java/org/apache/wayang/iejoin/test/ChannelFactory.java (100%)
 rename wayang-plugins/wayang-iejoin/{code => 
src}/test/resources/wayang.properties (100%)
 delete mode 100644 wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/pom.xml
 delete mode 100644 wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/scala_2.11
 delete mode 100644 
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/main/resources/README.md
 delete mode 100644 
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/main/scala/README.md
 delete mode 100644 
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/test/resources/README.md
 delete mode 100644 
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/test/scala/README.md
 delete mode 100644 wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/pom.xml
 delete mode 100644 wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/scala_2.12
 delete mode 100644 
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/main/resources/README.md
 delete mode 100644 
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/main/scala/README.md
 delete mode 100644 
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/test/resources/README.md
 delete mode 100644 
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/test/scala/README.md
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/data/DataGenerators.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/hardware/DiskProfiler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/BinaryOperatorProfiler.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/JavaCollectionSourceProfiler.java
 (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/JavaTextFileSourceProfiler.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/OperatorProfiler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/OperatorProfilers.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/Profiler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/SinkProfiler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/SourceProfiler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/java/UnaryOperatorProfiler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/DynamicEstimationContext.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/DynamicLoadEstimator.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/DynamicLoadProfileEstimator.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/DynamicLoadProfileEstimators.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/GeneticOptimizer.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/GeneticOptimizerApp.java (99%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/Individual.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/LogEvaluator.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/OptimizationSpace.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/Variable.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/sampling/Battle.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/sampling/ReservoirSampler.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/sampling/Sampler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/log/sampling/TournamentSampler.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/BinaryOperatorProfiler.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/Main.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/OperatorProfilers.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/SinkProfiler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/SparkCollectionSourceProfiler.java
 (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/SparkOperatorProfiler.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/SparkSourceProfiler.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/SparkTextFileSourceProfiler.java
 (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/spark/SparkUnaryOperatorProfiler.java 
(100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/util/ProfilingUtils.java (100%)
 rename wayang-profiler/{code => 
src}/main/java/org/apache/wayang/profiler/util/RrdAccessor.java (100%)
 delete mode 100644 wayang-profiler/src/main/scala/README.md
 delete mode 100644 wayang-profiler/wayang-profiler_2.11/pom.xml
 delete mode 100644 wayang-profiler/wayang-profiler_2.11/scala_2.11
 delete mode 100644 
wayang-profiler/wayang-profiler_2.11/src/main/resources/README.md
 delete mode 100644 
wayang-profiler/wayang-profiler_2.11/src/main/scala/README.md
 delete mode 100644 
wayang-profiler/wayang-profiler_2.11/src/test/resources/README.md
 delete mode 100644 
wayang-profiler/wayang-profiler_2.11/src/test/scala/README.md
 delete mode 100644 wayang-profiler/wayang-profiler_2.12/pom.xml
 delete mode 100644 wayang-profiler/wayang-profiler_2.12/scala_2.12
 delete mode 100644 
wayang-profiler/wayang-profiler_2.12/src/main/resources/README.md
 delete mode 100644 
wayang-profiler/wayang-profiler_2.12/src/main/scala/README.md
 delete mode 100644 
wayang-profiler/wayang-profiler_2.12/src/test/resources/README.md
 delete mode 100644 
wayang-profiler/wayang-profiler_2.12/src/test/scala/README.md
 delete mode 100644 wayang-tests-integration/src/main/scala/README.md
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/FlinkIntegrationIT.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/FullIntegrationIT.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/GiraphIntegrationIT.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/JavaIntegrationIT.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/PostgresIntegrationIT.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/RegressionIT.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/SparkIntegrationIT.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/WayangPlans.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/WayangPlansOperators.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/WordCountIT.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/java/org/apache/wayang/tests/platform/MyMadeUpPlatform.java (100%)
 rename wayang-tests-integration/{code => 
src}/test/resources/lines-with-key1.input (100%)
 rename wayang-tests-integration/{code => 
src}/test/resources/lines-with-key2.input (100%)
 rename wayang-tests-integration/{code => src}/test/resources/other-lines.input 
(100%)
 rename wayang-tests-integration/{code => src}/test/resources/pagerank.input 
(100%)
 rename wayang-tests-integration/{code => 
src}/test/resources/pagerank_solution.input (100%)
 rename wayang-tests-integration/{code => 
src}/test/resources/simplelogger.properties (100%)
 rename wayang-tests-integration/{code => src}/test/resources/some-lines.input 
(100%)
 rename wayang-tests-integration/{code => src}/test/resources/text.input (100%)
 rename wayang-tests-integration/{code => 
src}/test/resources/wayang-hsqldb-defaults.properties (100%)
 rename wayang-tests-integration/{code => src}/test/resources/wayang.properties 
(100%)
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.11/pom.xml
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.11/scala_2.11
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.11/src/main/resources/README.md
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.11/src/main/scala/README.md
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.11/src/test/java/org/apache/wayang/test/GraphChiIntegrationIT.java
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.11/src/test/resources/README.md
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.11/src/test/scala/README.md
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.12/pom.xml
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.12/scala_2.12
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.12/src/main/resources/README.md
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.12/src/main/scala/README.md
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.12/src/test/resources/README.md
 delete mode 100644 
wayang-tests-integration/wayang-tests-integration_2.12/src/test/scala/README.md