This is an automated email from the ASF dual-hosted git repository.
bertty pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git.
from 945cc59 Merge pull request #30 from apache/WAYANG-34
add 419fe3d [RELEASE][PREPARATION] add tag on the SCM
add a314c7d [maven-release-plugin] prepare branch @{releaseLabel}
add e486ac7 [maven-release-plugin] prepare for next development iteration
add 0f3526f [maven-release-plugin] prepare release wayang-0.6.0
add 584162c [RELEASE][PREPARATION] delete -SNAPSHOT
add 6666593 [RELEASE][PREPARATION] Corrections error of RC1
add 86f1c3d [RELEASE][PREPARATION] Update README.md for Corrections error
of RC1
add 92db07e [RELEASE][PREPARATION] rollback version to perform the
release again
add fb5973f Merge branch 'rel/0.6.0'
add 73f2f89 [RELEASE][PREPARATION] correction version
add 4540371 [maven-release-plugin] prepare branch 0.6.0
add ee38af4 [maven-release-plugin] prepare for next development iteration
add 709dc9d [maven-release-plugin] prepare branch 0.6.0
add 36778fb [RELEASE][PREPARATION] addition of timestamp
add 7719615 [RELEASE][PREPARATION] modification in the profile for errors
add 89258a2 [RELEASE][PREPARATION] update outputTimeStamp to the current
time
add ffb0ef7 [maven-release-plugin] prepare for next development iteration
add 55ffd89 Merge branch 'rel/0.6.0'
add 0f7ad3e [RELEASE][PREPARATION][FIX] Creation of the artifact for
differnt version of scala at release moment
add c4ad143 [RELEASE][PREPARATION][FIX] remove the profile at any moment
add 6b7b96d [RELEASE][PREPARATION] correction because it not need the
profiles
add 18e5104 [RELEASE][PREPARATION] travis time out
add f75d415 [RELEASE][PREPARATION] correction dependecies in java11 with
a profile automatically trigger
add 017941b [RELEASE][PREPARATION] minor correction in errors not critical
add cb5f480 [RELEASE][PREPARATION] add maven version to avoid errors
add 67af9fa [RELEASE][PREPARATION] update sqlite version to arm processor
add 7208e13 [RELEASE][PREPARATION] variable for the release phase
add 560fd88 [maven-release-plugin] prepare release 0.6.0
add 99fff63 [maven-release-plugin] prepare for next development iteration
add 93a1c70 fixed some typos
add 54026f6 Merge pull request #1 from 2pk03/2pk03-RN-fixes
add 06416e3 Merge pull request #31 from 2pk03/main
add cbab525 [RELEASE][PREPARATION] remove the distro module
add 666967e [RELEASE][PREPARATION] ulysses text remove, change for a
random word text
add b8afb0c [RELEASE][PREPARATION] change symlink to maven directory
structure
add 14dc984 [RELEASE][PREPARATION] get back to the version 0.6.0-snapshot
add ffbcfb5 [RELEASE][PREPARATION] Hadoop instruction for windows
add 18a01c4 Update README.md
add 4dd574e [RELEASE][PREPARATION] correction on the documentation
generation
add 9fe19a1 [maven-release-plugin] prepare release 0.6.0
add 4b47417 [maven-release-plugin] prepare for next development iteration
add aaa47e0 [RELEASE][PREPARATION] remove the datasource take it from
wikipedia
add 8a3ef82 Notice update
add 5901a5c Merge pull request #32 from 2pk03/patch-1
add 7b45c04 update readme to reflect ASF
add 7350f50 Merge pull request #33 from 2pk03/patch-2
add 0e720b8 update to reflect ASF
add bf1fc8f Merge pull request #34 from 2pk03/patch-3
add 62d8776 Merge branch 'main' of
https://github.com/apache/incubator-wayang
add 12ea378 [RELEASE][PREPARATION] NOTICE update to add profile-db
add a55f56b [RELEASE][PREPARATION] Update names form JSONArray to
WayangJsonArray, and from JSONObject to WayangJsonObj
add fcba759 [RELEASE][PREPARATION] remove the webhooks from .travis.yml
add 0ff5bfa [RELEASE][PREPARATION] rollback version to perform RC5
add 0618876 fix in readme
add 7fb5bd1 Rename NOTICE.md to NOTICE
add 1a38631 Merge pull request #35 from 2pk03/patch-4
add 7c4eb76 rephrasing
add 93ed2d5 Update NOTICE
add 4639300 Merge pull request #36 from 2pk03/patch-5
add 247980c Update NOTICE
add a019637 [maven-release-plugin] prepare release 0.6.0
add 07e2b37 [maven-release-plugin] prepare for next development iteration
add a519401 changes suggested from the incubator community
add bbc9862 Merge pull request #37 from 2pk03/patch-6
add 5528730 [RELEASE][PREPARATION] PageRank test case load input case
from files
add 7cf0649 [RELEASE][PREPARATION] version rollback to perform RC6
add f716de8 [maven-release-plugin] prepare release 0.6.0
add ab9a6a2 [maven-release-plugin] prepare for next development iteration
add e3ba4f6 small correction
add 76219f2 downgrade of jackson library
add 87a95ae copyright
add 9b19b8b Merge pull request #38 from 2pk03/patch-8
add 984ed56 copyright
add fed7956 Merge pull request #39 from 2pk03/patch-9
add 7927591 Update copyright
add 9744a32 Merge pull request #40 from 2pk03/patch-7
add 090ee85 removed wrong placed license
add b769746 Merge pull request #41 from 2pk03/patch-10
add b641ac4 [LICENSE] Correction license in profile-db module
add fedd0ea [LICENSE] update header in profile-db module
add e30aa1a [RELEASE][PREPARATION] version rollback to perform RC7
add a45b1e2 [maven-release-plugin] prepare release 0.6.0
add fc40ef3 [maven-release-plugin] prepare for next development iteration
add fbae4b3 add incubating
add b67c642 Merge pull request #42 from 2pk03/patch-11
add 7b865d0 add incubating
add e757c5d Merge pull request #43 from 2pk03/patch-12
add b7b6c1e adding the incubating in all the appears of just Apache Wayang
add 05fe01f minor correction
add c0b30b0 [RELEASE][PREPARATION] rollback to the version 0.6.0-snapshot
add 2af20c7 [maven-release-plugin] prepare release 0.6.0
add 660fe72 [maven-release-plugin] prepare for next development iteration
add 4c9515a release scripts
add 2d56a30 [WIP] add DISCLAIMER-WIP file
add 6dbd422 NOTICE License
add 06e5814 Update NOTICE
add 72ceabe Update NOTICE
add f08eae3 Merge pull request #45 from 2pk03/patch-13
add 09a450b Update LICENSE file
add f19e36f Update LICENSE file
add f4dfbe3 [RELEASE][PREPARATION] rollback to the version 0.6.0-snapshot
add cb464b6 [maven-release-plugin] prepare release 0.6.0
add d6c43f5 [maven-release-plugin] prepare for next development iteration
add 3289eb1 [CI] add skywalking-eyes check and fix some file license
add e1d04be [CI] add skywalking-eyes check and fix some file license
add b8dc06f add check branch
add d33a878 remove old license header
add 7b0fd77 Merge pull request #44 from CalvinKirs/license_eye
add 9dc8e18 LICENSE sort name files, and others
add b74d419 DISCLAIMER update, increase readibility
add e6aeef9 CVE-2021-44228
add 033bee3 Merge pull request #46 from 2pk03/patch-14
add d0dc55b Add .asf.yml
add 5cd3e00 Add .asf.yml
add 9551b2e remove space
add 5099800 fix homepage link error
add e5b1cc9 Merge pull request #47 from CalvinKirs/asf-yml
add be8b5ac CVE-2021-45105
add c9f4214 [SPARK] Correction Error of ArrayIndexOutOfBoundsException
add 44c7908 README.md -- add note on generated code and fix minor grammar
issues (#48)
add b44e546 Happy New Year, Update NOTICE year (#49)
add 3708773 Update .asf.yaml
add b29a6b8 [CI] Add deadline check He can help us detect dead links in
MD documents when we submit PRs
add 95a6280 ignore gitter link
add 0f0efb9 fix some link
add 7fe6f0b ignore jira_issue.md check
add 7433c0b fix error link
add 85d7501 fix error link
add 502b62d ignore user repos
add ddee0ae fix error link
add eaa7378 fix error link
add 7474f3c Merge pull request #50 from CalvinKirs/deadlin-check
add f224ecb Notification settings for repositories
add 2a25d56 Merge pull request #52 from CalvinKirs/commit-mail
add 5a02692 Add maven wrapper to ease the development (#53)
add e82f3a5 [CI]Add CodeQl Check (#51)
add 8e5061d Delete maven-wrapper.jar (#55)
add 03f60b8 Update .asf.yaml
add 15d2503 Merge pull request #56 from apache/berttty-patch-issues
add b9f682e [CI]Add UT check and delete RAT
add 69b1734 Add license header
add 1d0634b remove logpath
add 7a06ec8 Restore RAT
add 3091241 Merge pull request #54 from CalvinKirs/ci_run_ut
add 7a9396a [CI]Auto Build And Install (#59)
add 731b05b [CI] create Issues from the TODO in the code (#60)
add 0f3ea18 [CI] execute the method just in main branch (#62)
add fe066b3 [DOCS] add todo as test
add 278cbdc [DOCS][UTEST] add todo's in wayang-api-scala-java
add c445170 Archive Issue notification emails to the commits email group
add f37b2b0 Merge pull request #73 from CalvinKirs/issue-notify
add f28529a [Github]Set protected branches and review restrictions ignore
todo files license head check
add 764f879 Merge pull request #74 from CalvinKirs/fix_license-check
add 0fdb6e2 Upgrade Apache Parent version to 25
add a91bd36 Merge pull request #75 from CalvinKirs/upgrade-maven-version
add 1ec34d6 upgrade plugins for Reproducible Builds (#77)
add 984f61a Update README.md (#78)
add 7a51f42 add twitter button (#79)
add 2f6c57a [BUG] delete paranamer-2.3 from dependecies to just work with
paranamer-2.8 (#76)
add 1d369e3 fix #80 (code scanning alert) (#81)
add 220568e Merge branch 'main' into develop
add 43ed76d [WAYANG-34] correction structure
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 48 +
.dlc.json | 21 +
.github/actions/todo-to-issue-action | 1 +
.github/workflows/backend.yml | 55 +
.github/workflows/codeql.yml | 55 +
.../workflows/dead-link-checker.yaml | 26 +-
.../workflows/todo2issue.yml | 25 +-
.gitmodules | 3 +
.licenserc.yaml | 42 +
.mvn/wrapper/MavenWrapperDownloader.java | 117 +
.mvn/wrapper/maven-wrapper.properties | 22 +
.travis.yml | 10 +-
DISCLAIMER | 17 +-
LICENSE.TXT => LICENSE | 21 +
NOTICE | 21 +
NOTICE.TXT | 36 -
README.md | 74 +-
RELEASE_NOTES | 20 +-
bin/check-release.sh | 98 +
bin/create_scala_structure.sh | 90 +
bin/rollback_release.sh | 62 +
build.md | 6 +-
general-todos.md | 3 +
jenkins.pom | 2 +-
mvnw | 310 +
mvnw.cmd | 182 +
pom.xml | 433 +-
.../test/config}/wayang.properties | 5 +
wayang-api/pom.xml | 8 +-
wayang-api/wayang-api-python/pom.xml | 8 +-
.../scala/org/apache/wayang/api/DataQuanta.scala | 9 +-
.../org/apache/wayang/api/DataQuantaBuilder.scala | 5 +-
.../org/apache/wayang/api/JavaPlanBuilder.scala | 5 +-
.../scala/org/apache/wayang/api/PlanBuilder.scala | 5 +-
.../org/apache/wayang/api/RecordDataQuanta.scala | 0
.../wayang/api/RecordDataQuantaBuilder.scala | 5 +-
.../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 | 5 +
.../main/scala/org/apache/wayang/api/package.scala | 4 +
.../wayang/api/util/DataQuantaBuilderCache.scala | 0
.../api/util/DataQuantaBuilderDecorator.scala | 4 +
.../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 | 51 +-
.../wayang-api-scala-java/src/main/scala/README.md | 16 +
.../wayang-api-scala-java_2.11}/pom.xml | 60 +-
.../wayang-api-scala-java_2.11/scala_2.11} | 4 +-
.../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 | 59 +-
.../wayang-api-scala-java_2.12/scala_2.12} | 4 +-
.../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-benchmark/README.md | 24 +-
.../java/org/apache/wayang/apps/sgd/SGDImpl.java | 2 +-
.../apache/wayang/apps/sgd/SGDImprovedImpl.java | 2 +-
.../org/apache/wayang/apps/terasort/Random16.java | 0
.../apache/wayang/apps/terasort/Unsigned16.java | 0
.../java/org/apache/wayang/apps/tpch/Main.java | 2 +-
.../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 | 2 +-
.../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 | 2 +-
.../wayang/apps/kmeans/postgres/Kmeans.scala | 2 +-
.../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 | 4 +-
.../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 | 2 +-
.../wayang/apps/tpch/queries/Query3Database.scala | 2 +-
.../wayang/apps/tpch/queries/Query3File.scala | 2 +-
.../wayang/apps/tpch/queries/Query3Hybrid.scala | 2 +-
.../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 | 45 +-
.../wayang-benchmark_2.11}/pom.xml | 55 +-
.../wayang-benchmark_2.11/scala_2.11 | 4 +-
.../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_2.12}/pom.xml | 54 +-
.../wayang-benchmark_2.12/scala_2.12 | 4 +-
.../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 | 16 +-
wayang-commons/wayang-basic/pom.xml | 8 +-
.../wayang/basic/operators/TextFileSourceTest.java | 2 +-
.../wayang-basic/src/test/resources/text.input | 16872 ++++++++++
.../wayang-basic/src/test/resources/ulysses.input | 32657 -------------------
wayang-commons/wayang-core/pom.xml | 6 +-
.../apache/wayang/core/monitor/FileMonitor.java | 13 +-
.../wayang/core/optimizer/SanityChecker.java | 10 +
.../optimizer/cardinality/CardinalityEstimate.java | 14 +-
.../core/optimizer/costs/EstimationContext.java | 17 +-
.../wayang/core/optimizer/costs/LoadEstimate.java | 14 +-
.../wayang/core/optimizer/costs/LoadProfile.java | 29 +-
.../optimizer/costs/LoadProfileEstimators.java | 12 +-
.../optimizer/costs/SimpleEstimationContext.java | 15 +-
.../core/plan/executionplan/ExecutionPlan.java | 6 +
.../wayang/core/platform/AtomicExecution.java | 39 +-
.../wayang/core/platform/AtomicExecutionGroup.java | 11 +-
.../wayang/core/platform/PartialExecution.java | 25 +-
.../org/apache/wayang/core/platform/Platform.java | 8 +-
.../core/profiling/CardinalityRepository.java | 16 +-
.../apache/wayang/core/profiling/ExecutionLog.java | 25 +-
.../apache/wayang/core/util/JsonSerializable.java | 18 +-
.../apache/wayang/core/util/JsonSerializables.java | 163 +-
.../apache/wayang/core/util/JsonSerializer.java | 8 +-
.../json/{JSONArray.java => WayangJsonArray.java} | 31 +-
.../json/{JSONObject.java => WayangJsonObj.java} | 61 +-
.../wayang/core/platform/PartialExecutionTest.java | 19 +-
.../test/SerializableDummyExecutionOperator.java | 10 +-
.../src/test/resources/empty-plugin.yaml | 17 +
.../src/test/resources/partial-plugin.yaml | 17 +
.../src/test/resources/test-plugin.yaml | 17 +
.../wayang-utils-profile-db/{README.md => NOTICE} | 11 +-
wayang-commons/wayang-utils-profile-db/pom.xml | 6 +-
.../wayang/commons/util/profiledb/ProfileDB.java | 20 +-
.../util/profiledb/instrumentation/StopWatch.java | 20 +-
.../profiledb/json/MeasurementDeserializer.java | 20 +-
.../util/profiledb/json/MeasurementSerializer.java | 20 +-
.../commons/util/profiledb/model/Experiment.java | 20 +-
.../commons/util/profiledb/model/Measurement.java | 20 +-
.../commons/util/profiledb/model/Subject.java | 20 +-
.../wayang/commons/util/profiledb/model/Type.java | 20 +-
.../model/measurement/TimeMeasurement.java | 20 +-
.../util/profiledb/storage/FileStorage.java | 20 +-
.../util/profiledb/storage/JDBCStorage.java | 20 +-
.../commons/util/profiledb/storage/Storage.java | 20 +-
.../commons/util/profiledb/ProfileDBTest.java | 20 +-
.../measurement/TestMemoryMeasurement.java | 20 +-
.../profiledb/measurement/TestTimeMeasurement.java | 20 +-
wayang-distro/pom.xml | 121 -
wayang-distro/src/assembly/distro.xml | 30 -
wayang-docs/pom.xml | 18 +-
wayang-docs/src/main/resources/_config.prod.yml | 2 +-
wayang-docs/src/main/resources/_config.yml | 2 +-
.../src/main/resources/_includes/footer.html | 2 +-
wayang-docs/src/main/resources/_includes/head.html | 2 +-
.../src/main/resources/_layouts/default.html | 2 +-
.../logo/Apache_Wayang/Apache_Wayang Informe.txt | 56 -
.../Fonts/HVD Fonts - BrandonText-Regular.otf | Bin 70892 -> 0 bytes
.../logo/Apache_Wayang/Fonts/anguita-sans-bold.otf | Bin 79088 -> 0 bytes
.../main/resources/assets/img/logo/logo_svg.svg | 19 +-
.../resources/assets/img/logo/logo_svg_letter.svg | 19 +-
.../resources/assets/img/logo/logo_svg_puzzle.svg | 19 +-
.../src/main/resources/assets/img/puzzle-piece.svg | 19 +-
.../resources/how_contribute/code_changes/index.md | 2 +-
.../preparing_contribute_code_changes/index.md | 2 +-
.../jira_issue.md | 2 +
.../pull_request.md | 2 +-
.../how_contribute/documentation_changes.md | 2 +-
.../how_contribute/jira_issue_maintenance.md | 2 +-
.../resources/how_contribute/preparing_releases.md | 12 +-
.../resources/how_contribute/reviewing_changes.md | 2 +-
.../resources/how_contribute/slack_channels.md | 2 +-
wayang-docs/src/main/resources/index.md | 8 +-
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
.../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-platforms/wayang-flink/pom.xml | 56 +-
.../wayang-flink/wayang-flink_2.11/pom.xml | 56 +
.../wayang-flink/wayang-flink_2.11/scala_2.11 | 4 +-
.../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 | 4 +-
.../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-giraph/pom.xml | 10 +-
wayang-platforms/wayang-graphchi/pom.xml | 14 +-
wayang-platforms/wayang-java/pom.xml | 12 +-
wayang-platforms/wayang-jdbc-template/pom.xml | 12 +-
.../wayang/jdbc/operators/SqlToStreamOperator.java | 10 +-
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
.../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
.../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 | 50 +-
.../wayang-spark/wayang-spark_2.11/pom.xml | 72 +
.../wayang-spark/wayang-spark_2.11/scala_2.11 | 4 +-
.../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 | 61 +-
.../wayang-spark/wayang-spark_2.12/scala_2.12 | 4 +-
.../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-platforms/wayang-sqlite3/pom.xml | 12 +-
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 | 62 +-
.../{ => wayang-iejoin/wayang-iejoin_2.11}/pom.xml | 50 +-
.../wayang-iejoin/wayang-iejoin_2.11/scala_2.11 | 4 +-
.../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 | 50 +-
.../wayang-iejoin/wayang-iejoin_2.12/scala_2.12 | 4 +-
.../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/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 | 58 +-
wayang-profiler/wayang-profiler_2.11/pom.xml | 65 +
.../wayang-profiler_2.11/scala_2.11 | 4 +-
.../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_2.12}/pom.xml | 50 +-
.../wayang-profiler_2.12/scala_2.12 | 4 +-
.../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-resources/pom.xml | 8 +-
.../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 | 107 +-
.../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
.../code/test/resources/pagerank.input | 10 +
.../code/test/resources/pagerank_solution.input | 11 +
.../test/resources/simplelogger.properties | 0
.../{src => code}/test/resources/some-lines.input | 0
.../code/test/resources/text.input | 16872 ++++++++++
.../resources/wayang-hsqldb-defaults.properties | 0
.../{src => code}/test/resources/wayang.properties | 0
wayang-tests-integration/pom.xml | 167 +-
.../src/test/resources/ulysses.input | 32657 -------------------
.../wayang-tests-integration_2.11/pom.xml | 110 +
.../wayang-tests-integration_2.11/scala_2.11 | 4 +-
.../src/main/resources/README.md | 16 +
.../src/main/scala/README.md | 16 +
.../apache/wayang/test/GraphChiIntegrationIT.java | 0
.../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 | 4 +-
.../src/main/resources/README.md | 16 +
.../src/main/scala/README.md | 16 +
.../src/test/resources/README.md | 16 +
.../src/test/scala/README.md | 16 +
573 files changed, 37932 insertions(+), 66930 deletions(-)
create mode 100644 .asf.yaml
create mode 100644 .dlc.json
create mode 160000 .github/actions/todo-to-issue-action
create mode 100644 .github/workflows/backend.yml
create mode 100644 .github/workflows/codeql.yml
copy wayang-benchmark/src/test/resources/rheem.properties =>
.github/workflows/dead-link-checker.yaml (60%)
copy wayang-benchmark/src/test/resources/rheem.properties =>
.github/workflows/todo2issue.yml (61%)
create mode 100644 .gitmodules
create mode 100644 .licenserc.yaml
create mode 100644 .mvn/wrapper/MavenWrapperDownloader.java
create mode 100644 .mvn/wrapper/maven-wrapper.properties
rename LICENSE.TXT => LICENSE (83%)
create mode 100644 NOTICE
delete mode 100644 NOTICE.TXT
create mode 100755 bin/check-release.sh
create mode 100755 bin/create_scala_structure.sh
create mode 100755 bin/rollback_release.sh
create mode 100644 general-todos.md
create mode 100755 mvnw
create mode 100755 mvnw.cmd
copy {wayang-platforms/wayang-spark/src/test/resources =>
tools/test/config}/wayang.properties (82%)
mode change 100644 => 100755
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/DataQuanta.scala (99%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala (99%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala (97%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/PlanBuilder.scala (97%)
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 (96%)
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 (90%)
rename wayang-api/wayang-api-scala-java/{src =>
code}/main/scala/org/apache/wayang/api/package.scala (98%)
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
(95%)
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-plugins =>
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11}/pom.xml (50%)
copy
wayang-api/{wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-api-scala-java/wayang-api-scala-java_2.11/scala_2.11} (86%)
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/main/resources/README.md
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/main/scala/README.md
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/resources/README.md
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.11/src/test/scala/README.md
copy {wayang-plugins =>
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12}/pom.xml (50%)
copy
wayang-api/{wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-api-scala-java/wayang-api-scala-java_2.12/scala_2.12} (86%)
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/main/resources/README.md
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/main/scala/README.md
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/resources/README.md
create mode 100644
wayang-api/wayang-api-scala-java/wayang-api-scala-java_2.12/src/test/scala/README.md
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/sgd/SGDImpl.java (99%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/sgd/SGDImprovedImpl.java (99%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/terasort/Random16.java (100%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/terasort/Unsigned16.java (100%)
rename wayang-benchmark/{src =>
code}/main/java/org/apache/wayang/apps/tpch/Main.java (99%)
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 (98%)
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 (99%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala (99%)
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 (98%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/terasort/TeraApp.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/terasort/TeraGen.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/terasort/TeraSort.scala (100%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/terasort/TeraValidate.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 (98%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/queries/Query3Database.scala (98%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/queries/Query3File.scala (98%)
rename wayang-benchmark/{src =>
code}/main/scala/org/apache/wayang/apps/tpch/queries/Query3Hybrid.scala (98%)
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-plugins => wayang-benchmark/wayang-benchmark_2.11}/pom.xml (52%)
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-benchmark/wayang-benchmark_2.11/scala_2.11 (86%)
create mode 100644
wayang-benchmark/wayang-benchmark_2.11/src/main/resources/README.md
create mode 100644
wayang-benchmark/wayang-benchmark_2.11/src/main/scala/README.md
create mode 100644
wayang-benchmark/wayang-benchmark_2.11/src/test/resources/README.md
create mode 100644
wayang-benchmark/wayang-benchmark_2.11/src/test/scala/README.md
copy {wayang-plugins => wayang-benchmark/wayang-benchmark_2.12}/pom.xml (52%)
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-benchmark/wayang-benchmark_2.12/scala_2.12 (86%)
create mode 100644
wayang-benchmark/wayang-benchmark_2.12/src/main/resources/README.md
create mode 100644
wayang-benchmark/wayang-benchmark_2.12/src/main/scala/README.md
create mode 100644
wayang-benchmark/wayang-benchmark_2.12/src/test/resources/README.md
create mode 100644
wayang-benchmark/wayang-benchmark_2.12/src/test/scala/README.md
create mode 100644 wayang-commons/wayang-basic/src/test/resources/text.input
delete mode 100644 wayang-commons/wayang-basic/src/test/resources/ulysses.input
rename
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/{JSONArray.java
=> WayangJsonArray.java} (81%)
rename
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/{JSONObject.java
=> WayangJsonObj.java} (80%)
rename wayang-commons/wayang-utils-profile-db/{README.md => NOTICE} (67%)
delete mode 100644 wayang-distro/pom.xml
delete mode 100644 wayang-distro/src/assembly/distro.xml
delete mode 100644
wayang-docs/src/main/resources/assets/img/logo/Apache_Wayang/Apache_Wayang
Informe.txt
delete mode 100644
wayang-docs/src/main/resources/assets/img/logo/Apache_Wayang/Fonts/HVD Fonts -
BrandonText-Regular.otf
delete mode 100644
wayang-docs/src/main/resources/assets/img/logo/Apache_Wayang/Fonts/anguita-sans-bold.otf
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/ObjectFileSinkMapping.java
(100%)
rename wayang-platforms/wayang-flink/{src =>
code}/main/java/org/apache/wayang/flink/mapping/ObjectFileSourceMapping.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%)
create mode 100644 wayang-platforms/wayang-flink/wayang-flink_2.11/pom.xml
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-platforms/wayang-flink/wayang-flink_2.11/scala_2.11 (86%)
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.11/src/main/resources/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.11/src/main/scala/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.11/src/test/resources/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.11/src/test/scala/README.md
create mode 100644 wayang-platforms/wayang-flink/wayang-flink_2.12/pom.xml
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-platforms/wayang-flink/wayang-flink_2.12/scala_2.12 (86%)
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.12/src/main/resources/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.12/src/main/scala/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.12/src/test/resources/README.md
create mode 100644
wayang-platforms/wayang-flink/wayang-flink_2.12/src/test/scala/README.md
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/ObjectFileSinkMapping.java
(100%)
rename wayang-platforms/wayang-spark/{src =>
code}/main/java/org/apache/wayang/spark/mapping/ObjectFileSourceMapping.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%)
create mode 100644 wayang-platforms/wayang-spark/wayang-spark_2.11/pom.xml
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-platforms/wayang-spark/wayang-spark_2.11/scala_2.11 (86%)
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/resources/README.md
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.11/src/main/scala/README.md
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.11/src/test/resources/README.md
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.11/src/test/scala/README.md
copy {wayang-plugins =>
wayang-platforms/wayang-spark/wayang-spark_2.12}/pom.xml (50%)
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-platforms/wayang-spark/wayang-spark_2.12/scala_2.12 (86%)
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/resources/README.md
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.12/src/main/scala/README.md
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.12/src/test/resources/README.md
create mode 100644
wayang-platforms/wayang-spark/wayang-spark_2.12/src/test/scala/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-plugins/{ => wayang-iejoin/wayang-iejoin_2.11}/pom.xml (57%)
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/scala_2.11 (86%)
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/main/resources/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/main/scala/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/test/resources/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.11/src/test/scala/README.md
copy wayang-plugins/{ => wayang-iejoin/wayang-iejoin_2.12}/pom.xml (57%)
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/scala_2.12 (86%)
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/main/resources/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/main/scala/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/test/resources/README.md
create mode 100644
wayang-plugins/wayang-iejoin/wayang-iejoin_2.12/src/test/scala/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%)
create mode 100644 wayang-profiler/wayang-profiler_2.11/pom.xml
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-profiler/wayang-profiler_2.11/scala_2.11 (86%)
create mode 100644
wayang-profiler/wayang-profiler_2.11/src/main/resources/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.11/src/main/scala/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.11/src/test/resources/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.11/src/test/scala/README.md
copy {wayang-plugins => wayang-profiler/wayang-profiler_2.12}/pom.xml (57%)
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-profiler/wayang-profiler_2.12/scala_2.12 (86%)
create mode 100644
wayang-profiler/wayang-profiler_2.12/src/main/resources/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.12/src/main/scala/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.12/src/test/resources/README.md
create mode 100644
wayang-profiler/wayang-profiler_2.12/src/test/scala/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 (95%)
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%)
create mode 100644 wayang-tests-integration/code/test/resources/pagerank.input
create mode 100644
wayang-tests-integration/code/test/resources/pagerank_solution.input
rename wayang-tests-integration/{src =>
code}/test/resources/simplelogger.properties (100%)
rename wayang-tests-integration/{src => code}/test/resources/some-lines.input
(100%)
create mode 100644 wayang-tests-integration/code/test/resources/text.input
rename wayang-tests-integration/{src =>
code}/test/resources/wayang-hsqldb-defaults.properties (100%)
rename wayang-tests-integration/{src => code}/test/resources/wayang.properties
(100%)
delete mode 100644 wayang-tests-integration/src/test/resources/ulysses.input
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/pom.xml
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-tests-integration/wayang-tests-integration_2.11/scala_2.11 (86%)
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/src/main/resources/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/src/main/scala/README.md
rename wayang-tests-integration/{src_2_11 =>
wayang-tests-integration_2.11/src}/test/java/org/apache/wayang/test/GraphChiIntegrationIT.java
(100%)
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/src/test/resources/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.11/src/test/scala/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/pom.xml
copy
wayang-api/wayang-api-python/src/main/resources/wayang-api-python-defaults.properties
=> wayang-tests-integration/wayang-tests-integration_2.12/scala_2.12 (86%)
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/src/main/resources/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/src/main/scala/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/src/test/resources/README.md
create mode 100644
wayang-tests-integration/wayang-tests-integration_2.12/src/test/scala/README.md
