This is an automated email from the ASF dual-hosted git repository.
bertty pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git.
from 55ffd89 Merge branch 'rel/0.6.0'
new 0f7ad3e [RELEASE][PREPARATION][FIX] Creation of the artifact for
differnt version of scala at release moment
new c4ad143 [RELEASE][PREPARATION][FIX] remove the profile at any moment
new 6b7b96d [RELEASE][PREPARATION] correction because it not need the
profiles
The 3 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:
.travis.yml | 4 +-
README.md | 10 +-
bin/create_scala_structure.sh | 90 ++++++
build.md | 2 +-
jenkins.pom | 2 +-
pom.xml | 318 +++++++++++++++------
wayang-api/pom.xml | 4 +-
wayang-api/wayang-api-python/pom.xml | 4 +-
.../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}/test/resources/wayang.properties | 0
.../test/scala/org/apache/wayang/api/ApiTest.scala | 0
wayang-api/wayang-api-scala-java/pom.xml | 27 +-
.../wayang-api-scala-java/src/main/scala/README.md | 16 ++
.../wayang-api-scala-java_2.11/pom.xml | 26 +-
.../src/main/resources_2.11/README.md | 16 ++
.../wayang-api-scala-java_2.11/src/main/scala | 1 +
.../src/main/scala_2.11/README.md | 16 ++
.../wayang-api-scala-java_2.11/src/test/java | 1 +
.../wayang-api-scala-java_2.11/src/test/resources | 1 +
.../src/test/resources_2.11/README.md | 16 ++
.../wayang-api-scala-java_2.11/src/test/scala | 1 +
.../src/test/scala_2.11/README.md | 16 ++
.../wayang-api-scala-java_2.12/pom.xml | 27 +-
.../src/main/resources_2.12/README.md | 16 ++
.../wayang-api-scala-java_2.12/src/main/scala | 1 +
.../src/main/scala_2.12/README.md | 16 ++
.../wayang-api-scala-java_2.12/src/test/java | 1 +
.../wayang-api-scala-java_2.12/src/test/resources | 1 +
.../src/test/resources_2.12/README.md | 16 ++
.../wayang-api-scala-java_2.12/src/test/scala | 1 +
.../src/test/scala_2.12/README.md | 16 ++
.../java/org/apache/wayang/apps/sgd/SGDImpl.java | 0
.../apache/wayang/apps/sgd/SGDImprovedImpl.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
.../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/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 | 0
.../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
.../{src => code}/test/resources/rheem.properties | 0
.../org/apache/wayang/apps/kmeans/KmeansTest.scala | 0
.../apache/wayang/apps/util/ParametersTest.scala | 0
wayang-benchmark/pom.xml | 28 +-
.../wayang-benchmark_2.11/pom.xml | 26 +-
.../wayang-benchmark_2.11/src/main/java | 1 +
.../wayang-benchmark_2.11/src/main/resources | 1 +
.../src/main/resources_2.11/README.md | 16 ++
.../wayang-benchmark_2.11/src/main/scala | 1 +
.../src/main/scala_2.11/README.md | 16 ++
.../wayang-benchmark_2.11/src/test/java | 1 +
.../wayang-benchmark_2.11/src/test/resources | 1 +
.../src/test/resources_2.11/README.md | 16 ++
.../wayang-benchmark_2.11/src/test/scala | 1 +
.../src/test/scala_2.11/README.md | 16 ++
.../wayang-benchmark_2.12/pom.xml | 27 +-
.../wayang-benchmark_2.12/src/main/java | 1 +
.../wayang-benchmark_2.12/src/main/resources | 1 +
.../src/main/resources_2.12/README.md | 16 ++
.../wayang-benchmark_2.12/src/main/scala | 1 +
.../src/main/scala_2.12/README.md | 16 ++
.../wayang-benchmark_2.12/src/test/java | 1 +
.../wayang-benchmark_2.12/src/test/resources | 1 +
.../src/test/resources_2.12/README.md | 16 ++
.../wayang-benchmark_2.12/src/test/scala | 1 +
.../src/test/scala_2.12/README.md | 16 ++
wayang-commons/pom.xml | 4 +-
wayang-commons/wayang-basic/pom.xml | 8 +-
wayang-commons/wayang-core/pom.xml | 6 +-
wayang-commons/wayang-utils-profile-db/pom.xml | 2 +-
wayang-distro/pom.xml | 10 +-
wayang-platforms/pom.xml | 16 +-
.../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
.../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-platforms/wayang-flink/pom.xml | 17 +-
.../wayang-flink/wayang-flink_2.11/pom.xml | 27 +-
.../wayang-flink/wayang-flink_2.11/src/main/java | 1 +
.../wayang-flink_2.11/src/main/resources | 1 +
.../src/main/resources_2.11/README.md | 16 ++
.../src/main/scala_2.11/README.md | 16 ++
.../src/test/resources_2.11/README.md | 16 ++
.../src/test/scala_2.11/README.md | 16 ++
.../wayang-flink/wayang-flink_2.12/pom.xml | 27 +-
.../wayang-flink/wayang-flink_2.12/src/main/java | 1 +
.../wayang-flink_2.12/src/main/resources | 1 +
.../src/main/resources_2.12/README.md | 16 ++
.../src/main/scala_2.12/README.md | 16 ++
.../src/test/resources_2.12/README.md | 16 ++
.../src/test/scala_2.12/README.md | 16 ++
wayang-platforms/wayang-giraph/pom.xml | 10 +-
wayang-platforms/wayang-graphchi/pom.xml | 4 +-
.../wayang-graphchi/scala_11 | 0
wayang-platforms/wayang-java/pom.xml | 12 +-
wayang-platforms/wayang-jdbc-template/pom.xml | 12 +-
wayang-platforms/wayang-postgres/pom.xml | 8 +-
.../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
.../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
.../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
.../wayang/spark/platform/SparkPlatform.java | 0
.../wayang/spark/plugin/SparkBasicPlugin.java | 0
.../wayang/spark/plugin/SparkConversionPlugin.java | 0
.../wayang/spark/plugin/SparkGraphPlugin.java | 0
.../resources/wayang-spark-defaults.properties | 0
.../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
.../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
.../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
.../{src => code}/test/resources/0-to-10000.input | Bin
.../{src => code}/test/resources/wayang.properties | 0
wayang-platforms/wayang-spark/pom.xml | 17 +-
.../wayang-spark/wayang-spark_2.11/pom.xml | 27 +-
.../wayang-spark/wayang-spark_2.11/src/main/java | 1 +
.../wayang-spark_2.11/src/main/resources | 1 +
.../src/main/resources_2.11/README.md | 16 ++
.../wayang-spark/wayang-spark_2.11/src/main/scala | 1 +
.../src/main/scala_2.11/README.md | 16 ++
.../wayang-spark/wayang-spark_2.11/src/test/java | 1 +
.../wayang-spark_2.11/src/test/resources | 1 +
.../src/test/resources_2.11/README.md | 16 ++
.../src/test/scala_2.11/README.md | 16 ++
.../wayang-spark/wayang-spark_2.12/pom.xml | 27 +-
.../wayang-spark/wayang-spark_2.12/src/main/java | 1 +
.../wayang-spark_2.12/src/main/resources | 1 +
.../src/main/resources_2.12/README.md | 16 ++
.../wayang-spark/wayang-spark_2.12/src/main/scala | 1 +
.../src/main/scala_2.12/README.md | 16 ++
.../wayang-spark/wayang-spark_2.12/src/test/java | 1 +
.../wayang-spark_2.12/src/test/resources | 1 +
.../src/test/resources_2.12/README.md | 16 ++
.../src/test/scala_2.12/README.md | 16 ++
wayang-platforms/wayang-sqlite3/pom.xml | 10 +-
wayang-plugins/pom.xml | 4 +-
.../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
.../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}/test/resources/wayang.properties | 0
wayang-plugins/wayang-iejoin/pom.xml | 19 +-
.../wayang-iejoin/wayang-iejoin_2.11/pom.xml | 27 +-
.../wayang-iejoin/wayang-iejoin_2.11/src/main/java | 1 +
.../src/main/resources_2.11/README.md | 16 ++
.../src/main/scala_2.11/README.md | 16 ++
.../wayang-iejoin/wayang-iejoin_2.11/src/test/java | 1 +
.../wayang-iejoin_2.11/src/test/resources | 1 +
.../src/test/resources_2.11/README.md | 16 ++
.../src/test/scala_2.11/README.md | 16 ++
.../wayang-iejoin/wayang-iejoin_2.12/pom.xml | 27 +-
.../wayang-iejoin/wayang-iejoin_2.12/src/main/java | 1 +
.../src/main/resources_2.12/README.md | 16 ++
.../src/main/scala_2.12/README.md | 16 ++
.../wayang-iejoin/wayang-iejoin_2.12/src/test/java | 1 +
.../wayang-iejoin_2.12/src/test/resources | 1 +
.../src/test/resources_2.12/README.md | 16 ++
.../src/test/scala_2.12/README.md | 16 ++
.../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 | 0
.../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/pom.xml | 25 +-
.../wayang-profiler_2.11/pom.xml | 26 +-
wayang-profiler/wayang-profiler_2.11/src/main/java | 1 +
.../src/main/resources_2.11/README.md | 16 ++
.../src/main/scala_2.11/README.md | 16 ++
.../src/test/resources_2.11/README.md | 16 ++
.../src/test/scala_2.11/README.md | 16 ++
.../wayang-profiler_2.12/pom.xml | 27 +-
wayang-profiler/wayang-profiler_2.12/src/main/java | 1 +
.../src/main/resources_2.12/README.md | 16 ++
.../src/main/scala_2.12/README.md | 16 ++
.../src/test/resources_2.12/README.md | 16 ++
.../src/test/scala_2.12/README.md | 16 ++
wayang-resources/pom.xml | 2 +-
.../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
.../{src => code}/test/resources/other-lines.input | 0
.../test/resources/simplelogger.properties | 0
.../{src => code}/test/resources/some-lines.input | 0
.../{src => code}/test/resources/ulysses.input | 0
.../resources/wayang-hsqldb-defaults.properties | 0
.../{src => code}/test/resources/wayang.properties | 0
wayang-tests-integration/pom.xml | 103 +++----
.../wayang-tests-integration_2.11/pom.xml | 52 ++++
.../src/main/resources_2.11/README.md | 16 ++
.../src/main/scala_2.11/README.md | 16 ++
.../wayang-tests-integration_2.11/src/test/java | 1 +
.../apache/wayang/test/GraphChiIntegrationIT.java | 0
.../src/test/resources | 1 +
.../src/test/resources_2.11/README.md | 16 ++
.../src/test/scala_2.11/README.md | 16 ++
.../wayang-tests-integration_2.12/pom.xml | 27 +-
.../src/main/resources_2.12/README.md | 16 ++
.../src/main/scala_2.12/README.md | 16 ++
.../wayang-tests-integration_2.12/src/test/java | 1 +
.../src/test/resources | 1 +
.../src/test/resources_2.12/README.md | 16 ++
.../src/test/scala_2.12/README.md | 16 ++
501 files changed, 1690 insertions(+), 446 deletions(-)
create mode 100755 bin/create_scala_structure.sh
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/DataQuanta.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/PlanBuilder.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/RecordDataQuanta.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/RecordDataQuantaBuilder.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/graph/Edge.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/graph/EdgeDataQuanta.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/graph/EdgeDataQuantaBuilder.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/graph/package.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/package.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/util/DataQuantaBuilderCache.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/util/DataQuantaBuilderDecorator.scala
(100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/util/TypeTrap.scala (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/test/java/org/apache/wayang/api/JavaApiTest.java (100%)
rename {wayang-plugins/wayang-iejoin/src =>
wayang-api/wayang-api-scala-java/code}/test/resources/wayang.properties (100%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/test/scala/org/apache/wayang/api/ApiTest.scala (100%)
create mode 100644 wayang-api/wayang-api-scala-java/src/main/scala/README.md
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/pom.xml (64%)
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/main/resources_2.11/README.md
create mode 120000
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/main/scala
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/main/scala_2.11/README.md
create mode 120000
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/java
create mode 120000
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/resources
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/resources_2.11/README.md
create mode 120000
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/scala
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/scala_2.11/README.md
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/pom.xml (64%)
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/main/resources_2.12/README.md
create mode 120000
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/main/scala
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/main/scala_2.12/README.md
create mode 120000
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/java
create mode 120000
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/resources
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/resources_2.12/README.md
create mode 120000
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/scala
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/scala_2.12/README.md
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/sgd/SGDImpl.java (100%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/sgd/SGDImprovedImpl.java (100%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/tpch/Main.java (100%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/tpch/data/LineItemTuple.java (100%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/tpch/data/q1/GroupKey.java (100%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/tpch/data/q1/ReturnTuple.java (100%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/wordcount/Main.java (100%)
rename wayang-benchmark/{src => code}/main/resources/simplelogger.properties
(100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/benchmark/OptimizerScalabilityTest.scala
(100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/benchmark/PlanGenerator.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/crocopr/CreateInitialPageRanks.scala
(100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/crocopr/CrocoPR.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/kmeans/Kmeans.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/sgd/SGD.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/AddIdFunction.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/CreateWordNeighborhoodFunction.scala
(100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/ResolveClusterFunction.scala
(100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/ScrubFunction.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/SelectNearestCentroidFunction.scala
(100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/SimWords.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/SparseVector.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/TextScrubber.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/simwords/Word2NVec.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/sindy/Sindy.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/CsvUtils.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/SqlUtils.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/TpcH.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/data/Customer.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/data/LineItem.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/data/Order.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/queries/Query1.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/queries/Query3Database.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/queries/Query3File.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/queries/Query3Hybrid.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/util/ExperimentDescriptor.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/util/Parameters.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/util/ProfileDBHelper.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/util/StdOut.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/wordcount/WordCountScala.scala (100%)
rename wayang-benchmark/{src =>
code}/test/java/org/apache/wayang/apps/tpch/data/LineItemTupleTest.java (100%)
rename wayang-benchmark/{src => code}/test/resources/kmeans-datagenerator.py
(100%)
rename wayang-benchmark/{src => code}/test/resources/kmeans-k4-10000.input
(100%)
rename wayang-benchmark/{src => code}/test/resources/rheem.properties (100%)
rename wayang-benchmark/{src =>
code}/test/scala/org/apache/wayang/apps/kmeans/KmeansTest.scala (100%)
rename wayang-benchmark/{src =>
code}/test/scala/org/apache/wayang/apps/util/ParametersTest.scala (100%)
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-benchmark/wayang-benchmark_2.11/pom.xml (64%)
create mode 120000 wayang-benchmark/wayang-benchmark_2.11/src/main/java
create mode 120000 wayang-benchmark/wayang-benchmark_2.11/src/main/resources
create mode 100644
wayang-benchmark/wayang-benchmark_2.11/src/main/resources_2.11/README.md
create mode 120000 wayang-benchmark/wayang-benchmark_2.11/src/main/scala
create mode 100644
wayang-benchmark/wayang-benchmark_2.11/src/main/scala_2.11/README.md
create mode 120000 wayang-benchmark/wayang-benchmark_2.11/src/test/java
create mode 120000 wayang-benchmark/wayang-benchmark_2.11/src/test/resources
create mode 100644
wayang-benchmark/wayang-benchmark_2.11/src/test/resources_2.11/README.md
create mode 120000 wayang-benchmark/wayang-benchmark_2.11/src/test/scala
create mode 100644
wayang-benchmark/wayang-benchmark_2.11/src/test/scala_2.11/README.md
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-benchmark/wayang-benchmark_2.12/pom.xml (64%)
create mode 120000 wayang-benchmark/wayang-benchmark_2.12/src/main/java
create mode 120000 wayang-benchmark/wayang-benchmark_2.12/src/main/resources
create mode 100644
wayang-benchmark/wayang-benchmark_2.12/src/main/resources_2.12/README.md
create mode 120000 wayang-benchmark/wayang-benchmark_2.12/src/main/scala
create mode 100644
wayang-benchmark/wayang-benchmark_2.12/src/main/scala_2.12/README.md
create mode 120000 wayang-benchmark/wayang-benchmark_2.12/src/test/java
create mode 120000 wayang-benchmark/wayang-benchmark_2.12/src/test/resources
create mode 100644
wayang-benchmark/wayang-benchmark_2.12/src/test/resources_2.12/README.md
create mode 120000 wayang-benchmark/wayang-benchmark_2.12/src/test/scala
create mode 100644
wayang-benchmark/wayang-benchmark_2.12/src/test/scala_2.12/README.md
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/Flink.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/channels/ChannelConversions.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/channels/DataSetChannel.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/FlinkCoGroupFunction.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/KeySelectorDistinct.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/OutputFormatConsumer.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/WayangFileOutputFormat.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/criterion/DummyFilter.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/criterion/DummyMap.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/criterion/WayangAggregator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/criterion/WayangConvergenceCriterion.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/criterion/WayangFilterCriterion.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/criterion/WayangListValue.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/compiler/criterion/WayangValue.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/execution/FlinkContextReference.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/execution/FlinkExecutionContext.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/CartesianMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/CoGroupMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/CollectionSourceMapping.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/CountMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/DistinctMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/DoWhileMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/FilterMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/FlatMapMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/GlobalMaterializedGroupMapping.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/GlobalReduceMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/GroupByMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/IntersectMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/JoinMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/LocalCallbackSinkMapping.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/LoopMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/MapMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/MapPartitionsMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/Mappings.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/MaterializedGroupByMapping.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/PageRankMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/ReduceByMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/RepeatMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/SampleMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/SortMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/TextFileSinkMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/TextFileSourceMapping.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/UnionAllMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/ZipWithIdMapping.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkCountOperator.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkDoWhileOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkExecutionOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkFilterOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkFlatMapOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkGlobalMaterializedGroupOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkIntersectOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkLoopOperator.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkMapOperator.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkMapPartitionsOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkMaterializedGroupByOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkPageRankOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkRepeatOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkSampleOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkSortOperator.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/operators/FlinkZipWithIdOperator.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/platform/FlinkPlatform.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/plugin/FlinkBasicPlugin.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/plugin/FlinkConversionPlugin.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/plugin/FlinkGraphPlugin.java (100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/resources/wayang-flink-defaults.properties (100%)
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-platforms/wayang-flink/wayang-flink_2.11/pom.xml (65%)
create mode 120000
wayang-platforms/wayang-flink/wayang-flink_2.11/src/main/java
create mode 120000
wayang-platforms/wayang-flink/wayang-flink_2.11/src/main/resources
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.11/src/main/resources_2.11/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.11/src/main/scala_2.11/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.11/src/test/resources_2.11/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.11/src/test/scala_2.11/README.md
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-platforms/wayang-flink/wayang-flink_2.12/pom.xml (65%)
create mode 120000
wayang-platforms/wayang-flink/wayang-flink_2.12/src/main/java
create mode 120000
wayang-platforms/wayang-flink/wayang-flink_2.12/src/main/resources
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.12/src/main/resources_2.12/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.12/src/main/scala_2.12/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.12/src/test/resources_2.12/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.12/src/test/scala_2.12/README.md
copy wayang-commons/wayang-core/src/test/resources/empty-plugin.yaml =>
wayang-platforms/wayang-graphchi/scala_11 (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/Spark.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/channels/BroadcastChannel.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/channels/ChannelConversions.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/channels/FileChannels.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/channels/RddChannel.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/BinaryOperatorAdapter.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/ExtendedBinaryOperatorAdapter.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/ExtendedFlatMapFunctionAdapter.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/ExtendedFunction.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/ExtendedMapFunctionAdapter.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/ExtendedMapPartitionsFunctionAdapter.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/ExtendedPredicateAdapater.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/FlatMapFunctionAdapter.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/FunctionCompiler.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/MapFunctionAdapter.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/MapPartitionsFunctionAdapter.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/compiler/PredicateAdapter.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/execution/SparkContextReference.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/execution/SparkExecutionContext.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/execution/SparkExecutor.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/CartesianMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/CoGroupMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/CollectionSourceMapping.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/CountMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/DistinctMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/DoWhileMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/FilterMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/FlatMapMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/GlobalMaterializedGroupMapping.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/GlobalReduceMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/IntersectMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/JoinMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/LocalCallbackSinkMapping.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/LoopMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/MapMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/MapPartitionsMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/Mappings.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/MaterializedGroupByMapping.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/ReduceByMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/RepeatMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/SampleMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/SortMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/TextFileSinkMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/TextFileSourceMapping.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/UnionAllMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/ZipWithIdMapping.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/graph/PageRankMapping.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkBroadcastOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkCacheOperator.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkCartesianOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkCoGroupOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkCollectOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkCollectionSource.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkCountOperator.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkDistinctOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkDoWhileOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkExecutionOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkFilterOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkFlatMapOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkGlobalReduceOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkIntersectOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkJoinOperator.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkLocalCallbackSink.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkLoopOperator.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkMapOperator.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkMapPartitionsOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkMaterializedGroupByOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkObjectFileSink.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkObjectFileSource.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkReduceByOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkRepeatOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkSortOperator.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkTextFileSink.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkTextFileSource.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkTsvFileSink.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkTsvFileSource.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkUnionAllOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/operators/SparkZipWithIdOperator.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/platform/SparkPlatform.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/plugin/SparkBasicPlugin.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/plugin/SparkConversionPlugin.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/plugin/SparkGraphPlugin.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/resources/wayang-spark-defaults.properties (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/scala/org/apache/wayang/spark/operators/graph/SparkPageRankOperator.scala
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkCartesianOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkCoGroupOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkCollectionSourceTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkCountOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkDistinctOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkFilterOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkFlatMapOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkGlobalReduceOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkJoinOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkMapPartitionsOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkMaterializedGroupByOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkObjectFileSinkTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkObjectFileSourceTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkOperatorTestBase.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkReduceByOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkSortOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkTextFileSinkTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/operators/SparkUnionAllOperatorTest.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/java/org/apache/wayang/spark/test/ChannelFactory.java (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/resources/0-to-10000.input (100%)
rename wayang-platforms/wayang-spark/{src =>
code}/test/resources/wayang.properties (100%)
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-platforms/wayang-spark/wayang-spark_2.11/pom.xml (65%)
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/java
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/resources
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/resources_2.11/README.md
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/scala
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/scala_2.11/README.md
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.11/src/test/java
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.11/src/test/resources
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.11/src/test/resources_2.11/README.md
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.11/src/test/scala_2.11/README.md
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-platforms/wayang-spark/wayang-spark_2.12/pom.xml (65%)
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/java
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/resources
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/resources_2.12/README.md
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/scala
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/scala_2.12/README.md
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.12/src/test/java
create mode 120000
wayang-platforms/wayang-spark/wayang-spark_2.12/src/test/resources
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.12/src/test/resources_2.12/README.md
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.12/src/test/scala_2.12/README.md
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/IEJoin.java (100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/data/Data.java (100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/mapping/Mappings.java (100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/mapping/java/IEJoinMapping.java (100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/mapping/java/IESelfJoinMapping.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/mapping/spark/IEJoinMapping.java (100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/mapping/spark/IESelfJoinMapping.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/IEJoinMasterOperator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/IEJoinOperator.java (100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/IESelfJoinOperator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/JavaIESelfJoinOperator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/java_helpers/BitSetJoin.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/java_helpers/DataComparator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/java_helpers/extractData.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/java_helpers/myMergeSort.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/java_helpers/revDataComparator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/BitSetJoin.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/List2AttributesObjectSkinny.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/addUniqueID.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/build2ListObject.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/extractData.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/filterUnwantedBlocks.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/myMergeSort.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/main/java/org/apache/wayang/iejoin/operators/spark_helpers/revDataComparator.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/operators/JavaExecutionOperatorTestBase.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperatorTest.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest2.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest3.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest4.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperatorTest.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/operators/SparkOperatorTestBase.java
(100%)
rename wayang-plugins/wayang-iejoin/{src =>
code}/test/java/org/apache/wayang/iejoin/test/ChannelFactory.java (100%)
rename {wayang-api/wayang-api-scala-java/src =>
wayang-plugins/wayang-iejoin/code}/test/resources/wayang.properties (100%)
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/pom.xml (64%)
create mode 120000
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/main/java
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/main/resources_2.11/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/main/scala_2.11/README.md
create mode 120000
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/test/java
create mode 120000
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/test/resources
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/test/resources_2.11/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/test/scala_2.11/README.md
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/pom.xml (64%)
create mode 120000
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/main/java
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/main/resources_2.12/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/main/scala_2.12/README.md
create mode 120000
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/test/java
create mode 120000
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/test/resources
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/test/resources_2.12/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/test/scala_2.12/README.md
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/data/DataGenerators.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/hardware/DiskProfiler.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/BinaryOperatorProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/JavaCollectionSourceProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/JavaTextFileSourceProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/OperatorProfiler.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/OperatorProfilers.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/Profiler.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/SinkProfiler.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/SourceProfiler.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/java/UnaryOperatorProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/DynamicEstimationContext.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/DynamicLoadEstimator.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/DynamicLoadProfileEstimator.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/DynamicLoadProfileEstimators.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/GeneticOptimizer.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/GeneticOptimizerApp.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/Individual.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/LogEvaluator.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/OptimizationSpace.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/Variable.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/sampling/Battle.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/sampling/ReservoirSampler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/sampling/Sampler.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/log/sampling/TournamentSampler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/BinaryOperatorProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/Main.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/OperatorProfilers.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/SinkProfiler.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/SparkCollectionSourceProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/SparkOperatorProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/SparkSourceProfiler.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/SparkTextFileSourceProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/spark/SparkUnaryOperatorProfiler.java
(100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/util/ProfilingUtils.java (100%)
rename wayang-profiler/{src =>
code}/main/java/org/apache/wayang/profiler/util/RrdAccessor.java (100%)
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-profiler/wayang-profiler_2.11/pom.xml (64%)
create mode 120000 wayang-profiler/wayang-profiler_2.11/src/main/java
create mode 100644
wayang-profiler/wayang-profiler_2.11/src/main/resources_2.11/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.11/src/main/scala_2.11/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.11/src/test/resources_2.11/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.11/src/test/scala_2.11/README.md
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-profiler/wayang-profiler_2.12/pom.xml (64%)
create mode 120000 wayang-profiler/wayang-profiler_2.12/src/main/java
create mode 100644
wayang-profiler/wayang-profiler_2.12/src/main/resources_2.12/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.12/src/main/scala_2.12/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.12/src/test/resources_2.12/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.12/src/test/scala_2.12/README.md
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/FlinkIntegrationIT.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/FullIntegrationIT.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/GiraphIntegrationIT.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/JavaIntegrationIT.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/PostgresIntegrationIT.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/RegressionIT.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/SparkIntegrationIT.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/WayangPlans.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/WayangPlansOperators.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/WordCountIT.java (100%)
rename wayang-tests-integration/{src =>
code}/test/java/org/apache/wayang/tests/platform/MyMadeUpPlatform.java (100%)
rename wayang-tests-integration/{src =>
code}/test/resources/lines-with-key1.input (100%)
rename wayang-tests-integration/{src =>
code}/test/resources/lines-with-key2.input (100%)
rename wayang-tests-integration/{src => code}/test/resources/other-lines.input
(100%)
rename wayang-tests-integration/{src =>
code}/test/resources/simplelogger.properties (100%)
rename wayang-tests-integration/{src => code}/test/resources/some-lines.input
(100%)
rename wayang-tests-integration/{src => code}/test/resources/ulysses.input
(100%)
rename wayang-tests-integration/{src =>
code}/test/resources/wayang-hsqldb-defaults.properties (100%)
rename wayang-tests-integration/{src => code}/test/resources/wayang.properties
(100%)
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/pom.xml
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/src/main/resources_2.11/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/src/main/scala_2.11/README.md
create mode 120000
wayang-tests-integration/wayang-tests-integration_2.11/src/test/java
rename wayang-tests-integration/{src_2_11/test/java =>
wayang-tests-integration_2.11/src/test/java_2.11}/org/apache/wayang/test/GraphChiIntegrationIT.java
(100%)
create mode 120000
wayang-tests-integration/wayang-tests-integration_2.11/src/test/resources
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/src/test/resources_2.11/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/src/test/scala_2.11/README.md
copy wayang-resources/src/main/assembly/resources.xml =>
wayang-tests-integration/wayang-tests-integration_2.12/pom.xml (63%)
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/src/main/resources_2.12/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/src/main/scala_2.12/README.md
create mode 120000
wayang-tests-integration/wayang-tests-integration_2.12/src/test/java
create mode 120000
wayang-tests-integration/wayang-tests-integration_2.12/src/test/resources
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/src/test/resources_2.12/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/src/test/scala_2.12/README.md
