You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wayang.apache.org by rp...@apache.org on 2021/02/09 18:44:09 UTC
[incubator-wayang] branch main updated (5f5715d -> 7e7ce7e)
This is an automated email from the ASF dual-hosted git repository.
rpardomeza pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git.
from 5f5715d - Added a Jenkinsfile to build Wayang on Apache Jenkins
new 69d3882 [WAYANG-1][WAYANG-2] Parent artifact and modification code structure
new 8d5c8c9 merge with remote/main
new 2747a66 remove the variable in the version of wayang components
new 7e7ce7e Merge pull request #3 from berttty/main
The 1114 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
pom.xml | 1429 ++++++++++++--------
wayang-api/pom.xml | 104 +-
wayang-commons/pom.xml | 221 +++
.../wayang-basic}/pom.xml | 10 +-
.../java/org/apache/wayang/basic/WayangBasics.java | 0
.../apache/wayang/basic/channels/FileChannel.java | 0
.../java/org/apache/wayang/basic/data/Record.java | 0
.../java/org/apache/wayang/basic/data/Tuple2.java | 0
.../java/org/apache/wayang/basic/data/Tuple5.java | 0
.../basic/function/ProjectionDescriptor.java | 0
.../wayang/basic/mapping/GlobalReduceMapping.java | 0
.../org/apache/wayang/basic/mapping/Mappings.java | 0
.../basic/mapping/MaterializedGroupByMapping.java | 0
.../wayang/basic/mapping/PageRankMapping.java | 0
.../wayang/basic/mapping/ReduceByMapping.java | 0
.../apache/wayang/basic/mapping/RepeatMapping.java | 0
.../wayang/basic/operators/CartesianOperator.java | 0
.../wayang/basic/operators/CoGroupOperator.java | 0
.../wayang/basic/operators/CollectionSource.java | 0
.../wayang/basic/operators/CountOperator.java | 0
.../wayang/basic/operators/DistinctOperator.java | 0
.../wayang/basic/operators/DoWhileOperator.java | 0
.../wayang/basic/operators/FilterOperator.java | 0
.../wayang/basic/operators/FlatMapOperator.java | 0
.../operators/GlobalMaterializedGroupOperator.java | 0
.../basic/operators/GlobalReduceOperator.java | 0
.../wayang/basic/operators/GroupByOperator.java | 0
.../wayang/basic/operators/IntersectOperator.java | 0
.../wayang/basic/operators/JoinOperator.java | 0
.../wayang/basic/operators/LocalCallbackSink.java | 0
.../wayang/basic/operators/LoopOperator.java | 0
.../apache/wayang/basic/operators/MapOperator.java | 0
.../basic/operators/MapPartitionsOperator.java | 0
.../operators/MaterializedGroupByOperator.java | 0
.../wayang/basic/operators/PageRankOperator.java | 0
.../wayang/basic/operators/ReduceByOperator.java | 0
.../wayang/basic/operators/ReduceOperator.java | 0
.../wayang/basic/operators/RepeatOperator.java | 0
.../wayang/basic/operators/SampleOperator.java | 0
.../wayang/basic/operators/SortOperator.java | 0
.../apache/wayang/basic/operators/TableSource.java | 0
.../wayang/basic/operators/TextFileSink.java | 0
.../wayang/basic/operators/TextFileSource.java | 0
.../wayang/basic/operators/UnionAllOperator.java | 0
.../wayang/basic/operators/ZipWithIdOperator.java | 0
.../apache/wayang/basic/plugin/WayangBasic.java | 0
.../wayang/basic/plugin/WayangBasicGraph.java | 0
.../org/apache/wayang/basic/types/RecordType.java | 0
.../resources/wayang-basic-defaults.properties | 0
.../basic/function/ProjectionDescriptorTest.java | 0
.../wayang/basic/mapping/ReduceByMappingTest.java | 0
.../operators/MaterializedGroupByOperatorTest.java | 0
.../wayang/basic/operators/TextFileSourceTest.java | 0
.../wayang/basic/operators/test/TestSink.java | 0
.../wayang/basic/operators/test/TestSource.java | 0
.../apache/wayang/basic/types/RecordTypeTest.java | 0
.../wayang-basic}/src/test/resources/ulysses.txt | 0
.../wayang-core}/pom.xml | 31 +-
.../antlr4/org/apache/wayang/core/mathex/MathEx.g4 | 0
.../org/apache/wayang/core/api/Configuration.java | 0
.../main/java/org/apache/wayang/core/api/Job.java | 0
.../org/apache/wayang/core/api/WayangContext.java | 0
.../core/api/configuration/CollectionProvider.java | 0
.../api/configuration/ConstantValueProvider.java | 0
.../configuration/ExplicitCollectionProvider.java | 0
.../FunctionalCollectionProvider.java | 0
.../configuration/FunctionalKeyValueProvider.java | 0
.../api/configuration/FunctionalValueProvider.java | 0
.../core/api/configuration/KeyValueProvider.java | 0
.../configuration/MapBasedKeyValueProvider.java | 0
.../core/api/configuration/ValueProvider.java | 0
.../wayang/core/api/exception/WayangException.java | 0
.../core/function/AggregationDescriptor.java | 0
.../wayang/core/function/ConsumerDescriptor.java | 0
.../wayang/core/function/ExecutionContext.java | 0
.../wayang/core/function/ExtendedFunction.java | 0
.../wayang/core/function/FlatMapDescriptor.java | 0
.../wayang/core/function/FunctionDescriptor.java | 0
.../core/function/MapPartitionsDescriptor.java | 0
.../wayang/core/function/PredicateDescriptor.java | 0
.../wayang/core/function/ReduceDescriptor.java | 0
.../core/function/TransformationDescriptor.java | 0
.../org/apache/wayang/core/mapping/Mapping.java | 0
.../apache/wayang/core/mapping/OperatorMatch.java | 0
.../wayang/core/mapping/OperatorPattern.java | 0
.../wayang/core/mapping/PlanTransformation.java | 0
.../core/mapping/ReplacementSubplanFactory.java | 0
.../apache/wayang/core/mapping/SubplanMatch.java | 0
.../apache/wayang/core/mapping/SubplanPattern.java | 0
.../wayang/core/monitor/DisabledMonitor.java | 0
.../apache/wayang/core/monitor/FileMonitor.java | 0
.../apache/wayang/core/monitor/HttpMonitor.java | 0
.../org/apache/wayang/core/monitor/Monitor.java | 0
.../apache/wayang/core/monitor/ZeroMQMonitor.java | 0
.../optimizer/AggregateOptimizationContext.java | 0
.../core/optimizer/DefaultOptimizationContext.java | 0
.../wayang/core/optimizer/OptimizationContext.java | 0
.../wayang/core/optimizer/OptimizationUtils.java | 0
.../optimizer/ProbabilisticDoubleInterval.java | 0
.../optimizer/ProbabilisticIntervalEstimate.java | 0
.../wayang/core/optimizer/SanityChecker.java | 0
.../AbstractAlternativeCardinalityPusher.java | 0
.../AggregatingCardinalityEstimator.java | 0
.../optimizer/cardinality/CardinalityEstimate.java | 0
.../CardinalityEstimationTraversal.java | 0
.../cardinality/CardinalityEstimator.java | 0
.../cardinality/CardinalityEstimatorManager.java | 0
.../optimizer/cardinality/CardinalityPusher.java | 0
.../cardinality/DefaultCardinalityEstimator.java | 0
.../cardinality/DefaultCardinalityPusher.java | 0
.../cardinality/FallbackCardinalityEstimator.java | 0
.../cardinality/FixedSizeCardinalityEstimator.java | 0
.../LoopHeadAlternativeCardinalityPusher.java | 0
.../cardinality/LoopSubplanCardinalityPusher.java | 0
.../OperatorAlternativeCardinalityPusher.java | 0
.../cardinality/SubplanCardinalityPusher.java | 0
.../SwitchForwardCardinalityEstimator.java | 0
.../core/optimizer/channels/ChannelConversion.java | 0
.../optimizer/channels/ChannelConversionGraph.java | 0
.../channels/DefaultChannelConversion.java | 0
.../costs/ConstantLoadProfileEstimator.java | 0
.../core/optimizer/costs/DefaultLoadEstimator.java | 0
.../core/optimizer/costs/EstimationContext.java | 0
.../optimizer/costs/IntervalLoadEstimator.java | 0
.../wayang/core/optimizer/costs/LoadEstimate.java | 0
.../wayang/core/optimizer/costs/LoadEstimator.java | 0
.../wayang/core/optimizer/costs/LoadProfile.java | 0
.../core/optimizer/costs/LoadProfileEstimator.java | 0
.../optimizer/costs/LoadProfileEstimators.java | 0
.../costs/LoadProfileToTimeConverter.java | 0
.../core/optimizer/costs/LoadToTimeConverter.java | 0
.../costs/NestableLoadProfileEstimator.java | 0
.../optimizer/costs/SimpleEstimationContext.java | 0
.../wayang/core/optimizer/costs/TimeEstimate.java | 0
.../core/optimizer/costs/TimeToCostConverter.java | 0
.../optimizer/enumeration/ExecutionTaskFlow.java | 0
.../enumeration/ExecutionTaskFlowCompiler.java | 0
.../enumeration/LatentOperatorPruningStrategy.java | 0
.../core/optimizer/enumeration/LoopEnumerator.java | 0
.../optimizer/enumeration/LoopImplementation.java | 0
.../optimizer/enumeration/PlanEnumeration.java | 0
.../PlanEnumerationPruningStrategy.java | 0
.../core/optimizer/enumeration/PlanEnumerator.java | 0
.../optimizer/enumeration/PlanImplementation.java | 0
.../enumeration/RandomPruningStrategy.java | 0
.../enumeration/SinglePlatformPruningStrategy.java | 0
.../enumeration/StageAssignmentTraversal.java | 0
.../optimizer/enumeration/TopKPruningStrategy.java | 0
.../partition/EnumerationAlternative.java | 0
.../optimizer/partition/EnumerationBranch.java | 0
.../wayang/core/plan/executionplan/Channel.java | 0
.../plan/executionplan/ChannelInitializer.java | 0
.../core/plan/executionplan/ExecutionPlan.java | 0
.../core/plan/executionplan/ExecutionStage.java | 0
.../plan/executionplan/ExecutionStageLoop.java | 0
.../core/plan/executionplan/ExecutionTask.java | 0
.../core/plan/executionplan/PlatformExecution.java | 0
.../core/plan/wayangplan/ActualOperator.java | 0
.../plan/wayangplan/BinaryToUnaryOperator.java | 0
.../core/plan/wayangplan/CompositeOperator.java | 0
.../core/plan/wayangplan/ElementaryOperator.java | 0
.../plan/wayangplan/EstimationContextProperty.java | 0
.../core/plan/wayangplan/ExecutionOperator.java | 0
.../wayang/core/plan/wayangplan/InputSlot.java | 0
.../core/plan/wayangplan/LoopHeadAlternative.java | 0
.../core/plan/wayangplan/LoopHeadOperator.java | 0
.../wayang/core/plan/wayangplan/LoopIsolator.java | 0
.../wayang/core/plan/wayangplan/LoopSubplan.java | 0
.../wayang/core/plan/wayangplan/Operator.java | 0
.../core/plan/wayangplan/OperatorAlternative.java | 0
.../wayang/core/plan/wayangplan/OperatorBase.java | 0
.../core/plan/wayangplan/OperatorContainer.java | 0
.../core/plan/wayangplan/OperatorContainers.java | 0
.../wayang/core/plan/wayangplan/Operators.java | 0
.../wayang/core/plan/wayangplan/OutputSlot.java | 0
.../wayang/core/plan/wayangplan/PlanMetrics.java | 0
.../wayang/core/plan/wayangplan/PlanTraversal.java | 0
.../apache/wayang/core/plan/wayangplan/Slot.java | 0
.../wayang/core/plan/wayangplan/SlotMapping.java | 0
.../wayang/core/plan/wayangplan/Subplan.java | 0
.../core/plan/wayangplan/TopDownPlanVisitor.java | 0
.../wayang/core/plan/wayangplan/UnarySink.java | 0
.../wayang/core/plan/wayangplan/UnarySource.java | 0
.../core/plan/wayangplan/UnaryToUnaryOperator.java | 0
.../wayang/core/plan/wayangplan/WayangPlan.java | 0
.../traversal/AbstractTopologicalTraversal.java | 0
.../core/platform/AbstractChannelInstance.java | 0
.../wayang/core/platform/AtomicExecution.java | 0
.../wayang/core/platform/AtomicExecutionGroup.java | 0
.../apache/wayang/core/platform/Breakpoint.java | 0
.../core/platform/CardinalityBreakpoint.java | 0
.../wayang/core/platform/ChannelDescriptor.java | 0
.../wayang/core/platform/ChannelInstance.java | 0
.../core/platform/CompositeExecutionResource.java | 0
.../core/platform/ConjunctiveBreakpoint.java | 0
.../core/platform/CrossPlatformExecutor.java | 0
.../wayang/core/platform/ExecutionResource.java | 0
.../core/platform/ExecutionResourceTemplate.java | 0
.../wayang/core/platform/ExecutionState.java | 0
.../org/apache/wayang/core/platform/Executor.java | 0
.../wayang/core/platform/ExecutorTemplate.java | 0
.../apache/wayang/core/platform/FixBreakpoint.java | 0
.../org/apache/wayang/core/platform/Junction.java | 0
.../core/platform/NoIterationBreakpoint.java | 0
.../wayang/core/platform/PartialExecution.java | 0
.../org/apache/wayang/core/platform/Platform.java | 0
.../wayang/core/platform/PushExecutorTemplate.java | 0
.../core/platform/lineage/ChannelLineageNode.java | 0
.../platform/lineage/ExecutionLineageNode.java | 0
.../platform/lineage/LazyExecutionLineageNode.java | 0
.../apache/wayang/core/plugin/DynamicPlugin.java | 0
.../java/org/apache/wayang/core/plugin/Plugin.java | 0
.../core/profiling/CardinalityRepository.java | 0
.../wayang/core/profiling/CostMeasurement.java | 0
.../apache/wayang/core/profiling/ExecutionLog.java | 0
.../core/profiling/ExecutionPlanMeasurement.java | 0
.../profiling/FullInstrumentationStrategy.java | 0
.../core/profiling/InstrumentationStrategy.java | 0
.../core/profiling/NoInstrumentationStrategy.java | 0
.../profiling/OutboundInstrumentationStrategy.java | 0
.../profiling/PartialExecutionMeasurement.java | 0
.../apache/wayang/core/profiling/ProfileDBs.java | 0
.../wayang/core/types/BasicDataUnitType.java | 0
.../org/apache/wayang/core/types/DataSetType.java | 0
.../wayang/core/types/DataUnitGroupType.java | 0
.../org/apache/wayang/core/types/DataUnitType.java | 0
.../core/util/AbstractReferenceCountable.java | 0
.../java/org/apache/wayang/core/util/Action.java | 0
.../java/org/apache/wayang/core/util/Actions.java | 0
.../java/org/apache/wayang/core/util/Bitmask.java | 0
.../org/apache/wayang/core/util/Canonicalizer.java | 0
.../wayang/core/util/ConsumerIteratorAdapter.java | 0
.../java/org/apache/wayang/core/util/Copyable.java | 0
.../java/org/apache/wayang/core/util/Counter.java | 0
.../wayang/core/util/CrossProductIterable.java | 0
.../java/org/apache/wayang/core/util/Formats.java | 0
.../org/apache/wayang/core/util/Iterators.java | 0
.../apache/wayang/core/util/JsonSerializable.java | 0
.../apache/wayang/core/util/JsonSerializables.java | 0
.../apache/wayang/core/util/JsonSerializer.java | 0
.../org/apache/wayang/core/util/JuelUtils.java | 0
.../wayang/core/util/LimitedInputStream.java | 0
.../java/org/apache/wayang/core/util/Logging.java | 0
.../java/org/apache/wayang/core/util/LruCache.java | 0
.../java/org/apache/wayang/core/util/MultiMap.java | 0
.../apache/wayang/core/util/OneTimeExecutable.java | 0
.../java/org/apache/wayang/core/util/Optional.java | 0
.../wayang/core/util/ReferenceCountable.java | 0
.../apache/wayang/core/util/ReflectionUtils.java | 0
.../java/org/apache/wayang/core/util/Tuple.java | 0
.../org/apache/wayang/core/util/WayangArrays.java | 0
.../apache/wayang/core/util/WayangCollections.java | 0
.../org/apache/wayang/core/util/fs/FileSystem.java | 0
.../apache/wayang/core/util/fs/FileSystems.java | 0
.../org/apache/wayang/core/util/fs/FileUtils.java | 0
.../wayang/core/util/fs/HadoopFileSystem.java | 0
.../wayang/core/util/fs/LocalFileSystem.java | 0
.../apache/wayang/core/util/mathex/Context.java | 0
.../wayang/core/util/mathex/DefaultContext.java | 0
.../apache/wayang/core/util/mathex/Expression.java | 0
.../wayang/core/util/mathex/ExpressionBuilder.java | 0
.../mathex/exceptions/EvaluationException.java | 0
.../util/mathex/exceptions/MathExException.java | 0
.../util/mathex/exceptions/ParseException.java | 0
.../core/util/mathex/model/BinaryOperation.java | 0
.../core/util/mathex/model/CompiledFunction.java | 0
.../wayang/core/util/mathex/model/Constant.java | 0
.../core/util/mathex/model/NamedFunction.java | 0
.../core/util/mathex/model/UnaryOperation.java | 0
.../wayang/core/util/mathex/model/Variable.java | 0
.../main/resources/wayang-core-defaults.properties | 0
.../test/java/org/apache/wayang/core/SlotTest.java | 0
.../wayang/core/mapping/OperatorPatternTest.java | 0
.../core/mapping/PlanTransformationTest.java | 0
.../wayang/core/mapping/SubplanPatternTest.java | 0
.../wayang/core/mapping/test/TestSinkMapping.java | 0
.../mapping/test/TestSinkToTestSink2Factory.java | 0
.../AggregatingCardinalityEstimatorTest.java | 0
.../DefaultCardinalityEstimatorTest.java | 0
.../LoopSubplanCardinalityPusherTest.java | 0
.../cardinality/SubplanCardinalityPusherTest.java | 0
.../channels/ChannelConversionGraphTest.java | 0
.../costs/NestableLoadProfileEstimatorTest.java | 0
.../enumeration/StageAssignmentTraversalTest.java | 0
.../core/plan/executionplan/test/TestChannel.java | 0
.../core/plan/wayangplan/LoopIsolatorTest.java | 0
.../wayang/core/plan/wayangplan/OperatorTest.java | 0
.../core/plan/wayangplan/SlotMappingTest.java | 0
.../wayangplan/test/TestCustomMapOperator.java | 0
.../plan/wayangplan/test/TestFilterOperator.java | 0
.../wayang/core/plan/wayangplan/test/TestJoin.java | 0
.../core/plan/wayangplan/test/TestLoopHead.java | 0
.../core/plan/wayangplan/test/TestMapOperator.java | 0
.../wayang/core/plan/wayangplan/test/TestSink.java | 0
.../core/plan/wayangplan/test/TestSink2.java | 0
.../core/plan/wayangplan/test/TestSource.java | 0
.../wayang/core/platform/PartialExecutionTest.java | 0
.../wayang/core/plugin/DynamicPluginTest.java | 0
.../wayang/core/test/DummyExecutionOperator.java | 0
.../core/test/DummyExternalReusableChannel.java | 0
.../wayang/core/test/DummyNonReusableChannel.java | 0
.../org/apache/wayang/core/test/DummyPlatform.java | 0
.../wayang/core/test/DummyReusableChannel.java | 0
.../org/apache/wayang/core/test/MockFactory.java | 0
.../test/SerializableDummyExecutionOperator.java | 0
.../org/apache/wayang/core/test/TestDataUnit.java | 0
.../org/apache/wayang/core/test/TestDataUnit2.java | 0
.../org/apache/wayang/core/util/BitmaskTest.java | 0
.../core/util/ConsumerIteratorAdapterTest.java | 0
.../wayang/core/util/CrossProductIterableTest.java | 0
.../wayang/core/util/LimitedInputStreamTest.java | 0
.../wayang/core/util/ReflectionUtilsTest.java | 0
.../wayang/core/util/WayangCollectionsTest.java | 0
.../core/util/mathex/ExpressionBuilderTest.java | 0
.../wayang/core/util/mathex/ExpressionTest.java | 0
.../src/test/resources/empty-plugin.yaml | 0
.../src/test/resources/partial-plugin.yaml | 0
.../src/test/resources/simplelogger.properties | 0
.../src/test/resources/test-plugin.yaml | 0
wayang-distro/pom.xml | 24 +-
wayang-extensions/pom.xml | 9 +-
wayang-extensions/wayang-iejoin/pom.xml | 22 +-
wayang-platforms/pom.xml | 14 +-
wayang-platforms/wayang-flink/pom.xml | 24 +-
wayang-platforms/wayang-giraph/pom.xml | 45 +-
wayang-platforms/wayang-graphchi/pom.xml | 23 +-
wayang-platforms/wayang-java/pom.xml | 19 +-
wayang-platforms/wayang-jdbc-template/pom.xml | 28 +-
wayang-platforms/wayang-postgres/pom.xml | 20 +-
wayang-platforms/wayang-spark/pom.xml | 41 +-
wayang-platforms/wayang-sqlite3/pom.xml | 24 +-
wayang-profiler/pom.xml | 42 +-
.../app.properties | 0
wayang-tests-integration/pom.xml | 270 ++++
.../apache/wayang/tests/FlinkIntegrationIT.java | 0
.../org/apache/wayang/tests/FullIntegrationIT.java | 0
.../apache/wayang/tests/GiraphIntegrationIT.java | 3 +-
.../apache/wayang/tests/GraphChiIntegrationIT.java | 0
.../org/apache/wayang/tests/JavaIntegrationIT.java | 0
.../apache/wayang/tests/PostgresIntegrationIT.java | 0
.../java/org/apache/wayang/tests/RegressionIT.java | 0
.../apache/wayang/tests/SparkIntegrationIT.java | 0
.../java/org/apache/wayang/tests/WayangPlans.java | 0
.../apache/wayang/tests/WayangPlansOperators.java | 0
.../java/org/apache/wayang/tests/WordCountIT.java | 0
.../wayang/tests/platform/MyMadeUpPlatform.java | 0
.../src/test/resources/lines-with-key1.txt | 0
.../src/test/resources/lines-with-key2.txt | 0
.../src/test/resources/other-lines.txt | 0
.../src/test/resources/simplelogger.properties | 0
.../src/test/resources/some-lines.txt | 0
.../src/test/resources/ulysses.txt | 0
.../resources/wayang-hsqldb-defaults.properties | 0
.../src/test/resources/wayang.properties | 0
wayang-tests/pom.xml | 169 ---
355 files changed, 1660 insertions(+), 912 deletions(-)
create mode 100644 wayang-commons/pom.xml
rename {wayang-basic => wayang-commons/wayang-basic}/pom.xml (82%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/WayangBasics.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/channels/FileChannel.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/data/Record.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/data/Tuple2.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/data/Tuple5.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/function/ProjectionDescriptor.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/mapping/GlobalReduceMapping.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/mapping/Mappings.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/mapping/MaterializedGroupByMapping.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/mapping/PageRankMapping.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/mapping/ReduceByMapping.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/mapping/RepeatMapping.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/CartesianOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/CoGroupOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/CollectionSource.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/CountOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/DistinctOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/DoWhileOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/FilterOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/FlatMapOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/GlobalMaterializedGroupOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/GlobalReduceOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/GroupByOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/IntersectOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/JoinOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/LocalCallbackSink.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/LoopOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/MapOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/MapPartitionsOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/MaterializedGroupByOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/PageRankOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/ReduceByOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/ReduceOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/RepeatOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/SampleOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/SortOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/TableSource.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/TextFileSink.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/TextFileSource.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/UnionAllOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/operators/ZipWithIdOperator.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/plugin/WayangBasic.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/plugin/WayangBasicGraph.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/java/org/apache/wayang/basic/types/RecordType.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/main/resources/wayang-basic-defaults.properties (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/test/java/org/apache/wayang/basic/function/ProjectionDescriptorTest.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/test/java/org/apache/wayang/basic/mapping/ReduceByMappingTest.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/test/java/org/apache/wayang/basic/operators/MaterializedGroupByOperatorTest.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/test/java/org/apache/wayang/basic/operators/TextFileSourceTest.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/test/java/org/apache/wayang/basic/operators/test/TestSink.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/test/java/org/apache/wayang/basic/operators/test/TestSource.java (100%)
rename {wayang-basic => wayang-commons/wayang-basic}/src/test/java/org/apache/wayang/basic/types/RecordTypeTest.java (100%)
rename {wayang-tests => wayang-commons/wayang-basic}/src/test/resources/ulysses.txt (100%)
rename {wayang-core => wayang-commons/wayang-core}/pom.xml (76%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/antlr4/org/apache/wayang/core/mathex/MathEx.g4 (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/Configuration.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/Job.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/WayangContext.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/CollectionProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/ConstantValueProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/ExplicitCollectionProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/FunctionalCollectionProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/FunctionalKeyValueProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/FunctionalValueProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/KeyValueProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/MapBasedKeyValueProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/configuration/ValueProvider.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/api/exception/WayangException.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/AggregationDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/ConsumerDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/ExecutionContext.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/ExtendedFunction.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/FlatMapDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/FunctionDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/MapPartitionsDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/PredicateDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/ReduceDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/function/TransformationDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/mapping/Mapping.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/mapping/OperatorMatch.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/mapping/OperatorPattern.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/mapping/PlanTransformation.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/mapping/ReplacementSubplanFactory.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/mapping/SubplanMatch.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/mapping/SubplanPattern.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/monitor/DisabledMonitor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/monitor/FileMonitor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/monitor/HttpMonitor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/monitor/Monitor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/monitor/ZeroMQMonitor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/AggregateOptimizationContext.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/DefaultOptimizationContext.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/OptimizationContext.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/OptimizationUtils.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticDoubleInterval.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticIntervalEstimate.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/SanityChecker.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/AbstractAlternativeCardinalityPusher.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/AggregatingCardinalityEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimate.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimationTraversal.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimatorManager.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityPusher.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityPusher.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/FallbackCardinalityEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/FixedSizeCardinalityEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/LoopHeadAlternativeCardinalityPusher.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/LoopSubplanCardinalityPusher.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/OperatorAlternativeCardinalityPusher.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/SubplanCardinalityPusher.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/cardinality/SwitchForwardCardinalityEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversion.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraph.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/channels/DefaultChannelConversion.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/ConstantLoadProfileEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultLoadEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/EstimationContext.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/IntervalLoadEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimate.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfile.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimators.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileToTimeConverter.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/LoadToTimeConverter.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/NestableLoadProfileEstimator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/SimpleEstimationContext.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/TimeEstimate.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/costs/TimeToCostConverter.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlow.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlowCompiler.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/LatentOperatorPruningStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/LoopEnumerator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/LoopImplementation.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumeration.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerationPruningStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanImplementation.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/RandomPruningStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/SinglePlatformPruningStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversal.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/enumeration/TopKPruningStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/partition/EnumerationAlternative.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/optimizer/partition/EnumerationBranch.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/executionplan/Channel.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/executionplan/ChannelInitializer.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionPlan.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStage.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStageLoop.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionTask.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/executionplan/PlatformExecution.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/ActualOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/BinaryToUnaryOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/CompositeOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/ElementaryOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/EstimationContextProperty.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/ExecutionOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/InputSlot.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopHeadAlternative.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopHeadOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopIsolator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopSubplan.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorAlternative.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorBase.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainer.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainers.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/Operators.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/OutputSlot.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanMetrics.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanTraversal.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/Slot.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/SlotMapping.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/Subplan.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/TopDownPlanVisitor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySink.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySource.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/UnaryToUnaryOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/WayangPlan.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plan/wayangplan/traversal/AbstractTopologicalTraversal.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/AbstractChannelInstance.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/AtomicExecution.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/AtomicExecutionGroup.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/Breakpoint.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/CardinalityBreakpoint.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/ChannelDescriptor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/ChannelInstance.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/CompositeExecutionResource.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/ConjunctiveBreakpoint.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/CrossPlatformExecutor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/ExecutionResource.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/ExecutionResourceTemplate.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/ExecutionState.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/Executor.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/ExecutorTemplate.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/FixBreakpoint.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/Junction.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/NoIterationBreakpoint.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/PartialExecution.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/Platform.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/PushExecutorTemplate.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/lineage/ChannelLineageNode.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/lineage/ExecutionLineageNode.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/platform/lineage/LazyExecutionLineageNode.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plugin/DynamicPlugin.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/plugin/Plugin.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/CardinalityRepository.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/CostMeasurement.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/ExecutionLog.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/ExecutionPlanMeasurement.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/FullInstrumentationStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/InstrumentationStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/NoInstrumentationStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/OutboundInstrumentationStrategy.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/PartialExecutionMeasurement.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/profiling/ProfileDBs.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/types/BasicDataUnitType.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/types/DataSetType.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/types/DataUnitGroupType.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/types/DataUnitType.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/AbstractReferenceCountable.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Action.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Actions.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Bitmask.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Canonicalizer.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/ConsumerIteratorAdapter.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Copyable.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Counter.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/CrossProductIterable.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Formats.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Iterators.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/JsonSerializable.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/JsonSerializables.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/JsonSerializer.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/JuelUtils.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/LimitedInputStream.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Logging.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/LruCache.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/MultiMap.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/OneTimeExecutable.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Optional.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/ReferenceCountable.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/ReflectionUtils.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/Tuple.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/WayangArrays.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/WayangCollections.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/fs/FileSystem.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/fs/FileSystems.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/fs/FileUtils.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/fs/HadoopFileSystem.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/fs/LocalFileSystem.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/Context.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/DefaultContext.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/Expression.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/ExpressionBuilder.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/exceptions/EvaluationException.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/exceptions/MathExException.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/exceptions/ParseException.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/model/BinaryOperation.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/model/CompiledFunction.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/model/Constant.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/model/NamedFunction.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/model/UnaryOperation.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/java/org/apache/wayang/core/util/mathex/model/Variable.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/main/resources/wayang-core-defaults.properties (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/SlotTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/mapping/OperatorPatternTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/mapping/PlanTransformationTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/mapping/SubplanPatternTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/mapping/test/TestSinkMapping.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/mapping/test/TestSinkToTestSink2Factory.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/optimizer/cardinality/AggregatingCardinalityEstimatorTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityEstimatorTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/optimizer/cardinality/LoopSubplanCardinalityPusherTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/optimizer/cardinality/SubplanCardinalityPusherTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraphTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/optimizer/costs/NestableLoadProfileEstimatorTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversalTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/executionplan/test/TestChannel.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/LoopIsolatorTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/OperatorTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/SlotMappingTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestCustomMapOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestFilterOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestJoin.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestLoopHead.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestMapOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestSink.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestSink2.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestSource.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/platform/PartialExecutionTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/plugin/DynamicPluginTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/DummyExecutionOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/DummyExternalReusableChannel.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/DummyNonReusableChannel.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/DummyPlatform.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/DummyReusableChannel.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/MockFactory.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/SerializableDummyExecutionOperator.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/TestDataUnit.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/test/TestDataUnit2.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/util/BitmaskTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/util/ConsumerIteratorAdapterTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/util/CrossProductIterableTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/util/LimitedInputStreamTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/util/ReflectionUtilsTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/util/WayangCollectionsTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/util/mathex/ExpressionBuilderTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/java/org/apache/wayang/core/util/mathex/ExpressionTest.java (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/resources/empty-plugin.yaml (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/resources/partial-plugin.yaml (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/resources/simplelogger.properties (100%)
rename {wayang-core => wayang-commons/wayang-core}/src/test/resources/test-plugin.yaml (100%)
rename {wayang-tests => wayang-tests-integration}/app.properties (100%)
create mode 100644 wayang-tests-integration/pom.xml
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/FlinkIntegrationIT.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/FullIntegrationIT.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/GiraphIntegrationIT.java (98%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/GraphChiIntegrationIT.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/JavaIntegrationIT.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/PostgresIntegrationIT.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/RegressionIT.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/SparkIntegrationIT.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/WayangPlans.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/WayangPlansOperators.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/WordCountIT.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/java/org/apache/wayang/tests/platform/MyMadeUpPlatform.java (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/resources/lines-with-key1.txt (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/resources/lines-with-key2.txt (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/resources/other-lines.txt (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/resources/simplelogger.properties (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/resources/some-lines.txt (100%)
rename {wayang-basic => wayang-tests-integration}/src/test/resources/ulysses.txt (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/resources/wayang-hsqldb-defaults.properties (100%)
rename {wayang-tests => wayang-tests-integration}/src/test/resources/wayang.properties (100%)
delete mode 100644 wayang-tests/pom.xml