You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2018/05/16 12:34:25 UTC
[beam] 01/01: Merge pull request #5366 from dmvk/BEAM-3902
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch dsl-euphoria
in repository https://gitbox.apache.org/repos/asf/beam.git
commit eff3ffd5d224c6628606b355e3a5b6d8bc40150b
Merge: e7913a9 4ad6de7
Author: Jean-Baptiste Onofré <jb...@apache.org>
AuthorDate: Wed May 16 14:34:18 2018 +0200
Merge pull request #5366 from dmvk/BEAM-3902
[BEAM-3902] Finish euphoria integration with gradle build system.
sdks/java/extensions/euphoria/README.md | 21 +-
.../extensions/euphoria/euphoria-beam/build.gradle | 18 ++
.../java/extensions/euphoria/euphoria-beam/pom.xml | 117 ---------
.../extensions}/euphoria/beam/BeamExecutor.java | 24 +-
.../euphoria/beam/BeamExecutorContext.java | 52 ++--
.../sdk/extensions}/euphoria/beam/BeamFlow.java | 32 +--
.../extensions}/euphoria/beam/DoFnCollector.java | 32 +--
.../euphoria/beam/FlatMapTranslator.java | 22 +-
.../extensions}/euphoria/beam/FlowTranslator.java | 42 ++--
.../extensions}/euphoria/beam/InputTranslator.java | 22 +-
.../euphoria/beam/LazyAccumulatorProvider.java | 24 +-
.../euphoria/beam/OperatorTranslator.java | 16 +-
.../euphoria/beam/ReduceByKeyTranslator.java | 30 +--
.../euphoria/beam/ReduceStateByKeyTranslator.java | 16 +-
.../euphoria/beam/SingleValueCollector.java | 26 +-
.../sdk/extensions}/euphoria/beam/TypeUtils.java | 14 +-
.../extensions}/euphoria/beam/UnionTranslator.java | 16 +-
.../euphoria/beam/WrappedPCollectionOperator.java | 20 +-
.../extensions}/euphoria/beam/coder/PairCoder.java | 16 +-
.../euphoria/beam/coder/package-info.java | 2 +-
.../euphoria/beam/io/BeamBoundedSource.java | 19 +-
.../euphoria/beam/io/BeamUnboundedSource.java | 18 +-
.../euphoria/beam/io/BeamWriteSink.java | 18 +-
.../extensions}/euphoria/beam/io/KryoCoder.java | 16 +-
.../extensions}/euphoria/beam/io/package-info.java | 2 +-
.../extensions}/euphoria/beam/package-info.java | 2 +-
.../euphoria/beam/window/BeamWindow.java | 16 +-
.../euphoria/beam/window/BeamWindowFn.java | 24 +-
.../euphoria/beam/window/BeamWindowedElement.java | 18 +-
.../euphoria/beam/window/package-info.java | 2 +-
.../euphoria/beam/testkit/BeamOperatorsTest.java | 23 --
.../extensions}/euphoria/beam/BeamFlowTest.java | 40 ++--
.../sdk/extensions}/euphoria/beam/FlatMapTest.java | 24 +-
.../extensions}/euphoria/beam/ReduceByKeyTest.java | 66 ++---
.../beam/testkit/BeamExecutorProvider.java | 22 +-
.../euphoria/beam/testkit/BeamOperatorsSuite.java | 29 ++-
.../euphoria/beam/testkit/BeamOperatorsTest.java} | 7 +-
.../src/test/resources/log4j.properties | 7 -
.../extensions/euphoria/euphoria-core/build.gradle | 18 ++
.../java/extensions/euphoria/euphoria-core/pom.xml | 76 ------
.../core/client/accumulators/Accumulator.java | 27 ---
.../euphoria/core/client/accumulators/Counter.java | 33 ---
.../client/dataset/windowing/package-info.java | 19 --
.../cz/seznam/euphoria/core/client/flow/Util.java | 41 ----
.../euphoria/core/client/flow/package-info.java | 19 --
.../core/client/functional/BinaryFunctor.java | 28 ---
.../functional/CombinableBinaryFunction.java | 23 --
.../functional/CombinableReduceFunction.java | 26 --
.../euphoria/core/client/functional/Consumer.java | 32 ---
.../core/client/functional/ExtractEventTime.java | 33 ---
.../core/client/functional/ReduceFunction.java | 26 --
.../client/functional/SameArgsBinaryFunction.java | 24 --
.../core/client/functional/TernaryFunction.java | 27 ---
.../core/client/functional/TypeHintAware.java | 33 ---
.../core/client/functional/UnaryPredicate.java | 23 --
.../core/client/functional/VoidFunction.java | 27 ---
.../core/client/functional/package-info.java | 19 --
.../euphoria/core/client/io/BoundedReader.java | 27 ---
.../euphoria/core/client/io/CloseableIterator.java | 24 --
.../cz/seznam/euphoria/core/client/io/Context.java | 22 --
.../euphoria/core/client/io/ExternalIterable.java | 28 ---
.../euphoria/core/client/io/package-info.java | 19 --
.../euphoria/core/client/lib/package-info.java | 19 --
.../euphoria/core/client/operator/WindowAware.java | 32 ---
.../operator/WindowingRequiredException.java | 29 ---
.../core/client/operator/hint/ComputationHint.java | 26 --
.../core/client/operator/hint/OutputHint.java | 23 --
.../core/client/operator/hint/SizeHint.java | 28 ---
.../core/client/operator/hint/package-info.java | 19 --
.../core/client/operator/package-info.java | 19 --
.../operator/state/MergingStorageDescriptor.java | 31 ---
.../core/client/operator/state/StateContext.java | 31 ---
.../core/client/operator/state/Storage.java | 26 --
.../client/operator/state/StorageDescriptor.java | 35 ---
.../core/client/operator/state/ValueStorage.java | 37 ---
.../core/client/operator/state/package-info.java | 19 --
.../core/client/triggers/package-info.java | 19 --
.../euphoria/core/client/type/package-info.java | 19 --
.../euphoria/core/client/util/package-info.java | 19 --
.../euphoria/core/executor/graph/package-info.java | 19 --
.../core/executor/greduce/package-info.java | 19 --
.../euphoria/core/executor/io/package-info.java | 19 --
.../euphoria/core/executor/package-info.java | 19 --
.../euphoria/core/executor/util/package-info.java | 19 --
.../cz/seznam/euphoria/core/time/Scheduler.java | 35 ---
.../euphoria/core/time/TimeProviderAware.java | 25 --
.../cz/seznam/euphoria/core/time/package-info.java | 19 --
.../cz/seznam/euphoria/core/util/package-info.java | 19 --
.../core/annotation/audience/Audience.java | 14 +-
.../core/annotation/audience/package-info.java | 2 +-
.../euphoria/core/annotation/operator/Basic.java | 14 +-
.../euphoria/core/annotation/operator/Derived.java | 14 +-
.../core/annotation/operator/Recommended.java | 14 +-
.../core/annotation/operator/StateComplexity.java | 14 +-
.../core/annotation/operator/package-info.java | 2 +-
.../core/annotation/stability/Experimental.java | 14 +-
.../core/annotation/stability}/package-info.java | 2 +-
.../core/client/accumulators/Accumulator.java} | 11 +-
.../client/accumulators/AccumulatorProvider.java | 18 +-
.../core/client/accumulators/Counter.java} | 21 +-
.../core/client/accumulators/Histogram.java | 16 +-
.../euphoria/core/client/accumulators/Timer.java | 16 +-
.../accumulators/VoidAccumulatorProvider.java | 18 +-
.../core/client/accumulators}/package-info.java | 2 +-
.../euphoria/core/client/dataset/Dataset.java | 24 +-
.../euphoria/core/client/dataset/Datasets.java | 22 +-
.../euphoria/core/client/dataset/InputDataset.java | 24 +-
.../core/client/dataset/OutputDataset.java | 24 +-
.../core/client/dataset}/package-info.java | 2 +-
.../core/client/dataset/windowing/Count.java | 20 +-
.../client/dataset/windowing/GlobalWindowing.java | 25 +-
.../client/dataset/windowing/MergingWindowing.java | 18 +-
.../core/client/dataset/windowing/Session.java | 28 ++-
.../core/client/dataset/windowing/Time.java | 24 +-
.../client/dataset/windowing/TimeInterval.java | 16 +-
.../core/client/dataset/windowing/TimeSliding.java | 22 +-
.../core/client/dataset/windowing/Window.java | 16 +-
.../client/dataset/windowing/WindowedElement.java | 16 +-
.../core/client/dataset/windowing/Windowing.java | 18 +-
.../client/dataset/windowing}/package-info.java | 2 +-
.../euphoria/core/client/flow/Flow.java | 32 +--
.../euphoria/core/client/flow/Util.java} | 29 ++-
.../euphoria/core/client/flow}/package-info.java | 2 +-
.../core/client/functional/BinaryFunction.java | 16 +-
.../core/client/functional/BinaryFunctor.java} | 16 +-
.../functional/CombinableBinaryFunction.java} | 11 +-
.../functional/CombinableReduceFunction.java} | 10 +-
.../client/functional/CompositeUnaryFunction.java | 16 +-
.../euphoria/core/client/functional/Consumer.java} | 20 +-
.../core/client/functional/ExtractEventTime.java} | 21 +-
.../core/client/functional/ReduceFunction.java} | 10 +-
.../core/client/functional/ReduceFunctor.java | 16 +-
.../client/functional/SameArgsBinaryFunction.java} | 12 +-
.../core/client/functional/TernaryFunction.java} | 15 +-
.../core/client/functional/TypeHintAware.java} | 21 +-
.../core/client/functional/UnaryFunction.java | 16 +-
.../core/client/functional/UnaryFunctionEnv.java | 18 +-
.../core/client/functional/UnaryFunctor.java | 18 +-
.../core/client/functional/UnaryPredicate.java} | 11 +-
.../core/client/functional/VoidFunction.java} | 15 +-
.../core/client/functional}/package-info.java | 2 +-
.../euphoria/core/client/io/BoundedDataSource.java | 16 +-
.../euphoria/core/client/io/BoundedReader.java} | 11 +-
.../core/client/io/CloseableIterator.java} | 12 +-
.../euphoria/core/client/io/Collector.java | 16 +-
.../euphoria/core/client/io/Context.java} | 10 +-
.../euphoria/core/client/io/DataSink.java | 18 +-
.../euphoria/core/client/io/DataSinks.java | 20 +-
.../euphoria/core/client/io/DataSource.java | 16 +-
.../euphoria/core/client/io/Environment.java | 24 +-
.../euphoria/core/client/io/ExternalIterable.java} | 16 +-
.../euphoria/core/client/io/ListDataSink.java | 20 +-
.../euphoria/core/client/io/ListDataSource.java | 16 +-
.../euphoria/core/client/io/MultiDataSink.java | 18 +-
.../euphoria/core/client/io/SpillTools.java | 18 +-
.../euphoria/core/client/io/StdoutSink.java | 16 +-
.../core/client/io/UnboundedDataSource.java | 16 +-
.../core/client/io/UnboundedPartition.java | 16 +-
.../euphoria/core/client/io/UnboundedReader.java | 16 +-
.../core/client/io/UnsplittableBoundedSource.java | 16 +-
.../euphoria/core/client/io/VoidSink.java | 16 +-
.../euphoria/core/client/io/Writer.java | 16 +-
.../euphoria/core/client/io}/package-info.java | 2 +-
.../euphoria/core/client/lib/Split.java | 28 ++-
.../euphoria/core/client/lib}/package-info.java | 2 +-
.../core/client/operator/AssignEventTime.java | 30 +--
.../euphoria/core/client/operator/Builders.java | 32 +--
.../euphoria/core/client/operator/CountByKey.java | 36 +--
.../euphoria/core/client/operator/Distinct.java | 38 +--
.../core/client/operator/ElementWiseOperator.java | 22 +-
.../euphoria/core/client/operator/Filter.java | 30 +--
.../euphoria/core/client/operator/FlatMap.java | 32 +--
.../euphoria/core/client/operator/FullJoin.java | 28 ++-
.../euphoria/core/client/operator/Join.java | 54 +++--
.../euphoria/core/client/operator/LeftJoin.java | 28 ++-
.../euphoria/core/client/operator/MapElements.java | 32 +--
.../euphoria/core/client/operator/Operator.java | 26 +-
.../client/operator/OptionalMethodBuilder.java | 18 +-
.../euphoria/core/client/operator/ReduceByKey.java | 74 +++---
.../core/client/operator/ReduceStateByKey.java | 49 ++--
.../core/client/operator/ReduceWindow.java | 46 ++--
.../euphoria/core/client/operator/RightJoin.java | 30 +--
.../core/client/operator/SingleInputOperator.java | 20 +-
.../euphoria/core/client/operator/StateAware.java | 18 +-
.../operator/StateAwareWindowWiseOperator.java | 24 +-
.../StateAwareWindowWiseSingleInputOperator.java | 28 ++-
.../core/client/operator/StateSupport.java | 18 +-
.../euphoria/core/client/operator/SumByKey.java | 38 +--
.../euphoria/core/client/operator/TopPerKey.java | 50 ++--
.../euphoria/core/client/operator/Union.java | 26 +-
.../core/client/operator/WindowAware.java} | 16 +-
.../core/client/operator/WindowWiseOperator.java | 22 +-
.../operator/WindowingRequiredException.java} | 13 +-
.../client/operator/hint/ComputationHint.java} | 14 +-
.../core/client/operator/hint/OutputHint.java} | 11 +-
.../core/client/operator/hint/SizeHint.java} | 16 +-
.../core/client/operator/hint}/package-info.java | 2 +-
.../core/client}/operator/package-info.java | 2 +-
.../core/client/operator/state/ListStorage.java | 16 +-
.../operator/state/ListStorageDescriptor.java | 16 +-
.../operator/state/MergingStorageDescriptor.java} | 15 +-
.../euphoria/core/client/operator/state/State.java | 18 +-
.../core/client/operator/state/StateContext.java} | 19 +-
.../core/client/operator/state/StateFactory.java | 20 +-
.../core/client/operator/state/StateMerger.java | 22 +-
.../core/client/operator/state/Storage.java} | 14 +-
.../client/operator/state/StorageDescriptor.java} | 23 +-
.../client/operator/state/StorageProvider.java | 16 +-
.../core/client/operator/state/ValueStorage.java} | 21 +-
.../operator/state/ValueStorageDescriptor.java | 18 +-
.../core/client/operator/state}/package-info.java | 2 +-
.../triggers/AfterFirstCompositeTrigger.java | 18 +-
.../core/client/triggers/CountTrigger.java | 22 +-
.../euphoria/core/client/triggers/NoopTrigger.java | 18 +-
.../core/client/triggers/PeriodicTimeTrigger.java | 22 +-
.../euphoria/core/client/triggers/TimeTrigger.java | 18 +-
.../euphoria/core/client/triggers/Trigger.java | 24 +-
.../core/client/triggers/TriggerContext.java | 22 +-
.../core/client/triggers}/package-info.java | 2 +-
.../core/client/type/AbstractTypeAware.java | 16 +-
.../core/client/type/TypeAwareReduceFunctor.java | 18 +-
.../core/client/type/TypeAwareUnaryFunction.java | 18 +-
.../core/client/type/TypeAwareUnaryFunctor.java | 18 +-
.../euphoria/core/client/type/TypeHint.java | 16 +-
.../euphoria/core/client/type}/package-info.java | 2 +-
.../euphoria/core/client/util/Either.java | 16 +-
.../euphoria/core/client/util/Fold.java | 26 +-
.../extensions}/euphoria/core/client/util/Max.java | 20 +-
.../euphoria/core/client/util/Pair.java | 16 +-
.../euphoria/core/client/util/Sums.java | 18 +-
.../euphoria/core/client/util/Triple.java | 16 +-
.../euphoria/core/client/util}/package-info.java | 2 +-
.../euphoria/core/executor/AbstractExecutor.java | 16 +-
.../euphoria/core/executor/Constants.java | 16 +-
.../euphoria/core/executor/Executor.java | 30 +--
.../euphoria/core/executor/FlowUnfolder.java | 30 +--
.../euphoria/core/executor/FlowValidator.java | 36 +--
.../euphoria/core/executor/VectorClock.java | 16 +-
.../euphoria/core/executor/graph/DAG.java | 18 +-
.../euphoria/core/executor/graph/Node.java | 16 +-
.../core/executor/graph}/package-info.java | 2 +-
.../core/executor/greduce/GroupReducer.java | 67 +++---
.../core/executor/greduce/TimerSupport.java | 18 +-
.../core/executor/greduce/TriggerStorage.java | 32 +--
.../core/executor/greduce}/package-info.java | 2 +-
.../core/executor/io/FsSpillingListStorage.java | 20 +-
.../core/executor/io/GenericSpillTools.java | 24 +-
.../core/executor/io/SerializerFactory.java | 16 +-
.../core/executor/io/SpillFileFactory.java | 16 +-
.../euphoria/core/executor/io}/package-info.java | 2 +-
.../euphoria/core/executor}/package-info.java | 2 +-
.../core/executor/util/InMemExternalIterable.java | 18 +-
.../core/executor/util/MultiValueContext.java | 28 ++-
.../core/executor/util/OperatorTranslator.java | 28 ++-
.../core/executor/util/SingleValueContext.java | 28 ++-
.../euphoria/core/executor/util}/package-info.java | 2 +-
.../extensions/euphoria/core/time/Scheduler.java} | 20 +-
.../euphoria/core/time/TimeProvider.java | 16 +-
.../euphoria/core/time/TimeProviderAware.java} | 10 +-
.../euphoria/core/time/TimeProviders.java | 16 +-
.../euphoria/core/time/TimerScheduler.java | 16 +-
.../euphoria/core/time}/package-info.java | 2 +-
.../euphoria/core/util/ExceptionUtils.java | 14 +-
.../extensions}/euphoria/core/util/IOUtils.java | 14 +-
.../euphoria/core/util/InstanceUtils.java | 16 +-
.../extensions}/euphoria/core/util/Settings.java | 18 +-
.../euphoria/core/util}/package-info.java | 2 +-
.../core/client/dataset/windowing/SessionTest.java | 16 +-
.../client/dataset/windowing/TimeSlidingTest.java | 14 +-
.../core/client/dataset/windowing/TimeTest.java | 14 +-
.../dataset/windowing/TimestampedElement.java | 14 +-
.../client/dataset/windowing/WindowingTest.java | 18 +-
.../euphoria/core/client/flow/TestFlow.java | 24 +-
.../euphoria/core/client/io/EmptyReader.java | 14 +-
.../euphoria/core/client/io/ListDataSinkTest.java | 16 +-
.../core/client/io/MockStreamDataSource.java | 14 +-
.../euphoria/core/client/io/MultiDataSinkTest.java | 14 +-
.../euphoria/core/client/lib/SplitTest.java | 26 +-
.../core/client/operator/CountByKeyTest.java | 22 +-
.../core/client/operator/DistinctTest.java | 20 +-
.../euphoria/core/client/operator/FilterTest.java | 18 +-
.../euphoria/core/client/operator/FlatMapTest.java | 20 +-
.../euphoria/core/client/operator/HintTest.java | 38 +--
.../euphoria/core/client/operator/JoinTest.java | 26 +-
.../core/client/operator/MapElementsTest.java | 20 +-
.../core/client/operator/ReduceByKeyTest.java | 22 +-
.../core/client/operator/ReduceStateByKeyTest.java | 32 +--
.../core/client/operator/ReduceWindowTest.java | 26 +-
.../core/client/operator/SumByKeyTest.java | 22 +-
.../core/client/operator/TopPerKeyTest.java | 22 +-
.../euphoria/core/client/operator/UnionTest.java | 18 +-
.../euphoria/core/client/operator/Util.java | 22 +-
.../euphoria/core/client/util/IOUtilsTest.java | 16 +-
.../euphoria/core/executor/FlowUnfolderTest.java | 54 +++--
.../euphoria/core/executor/graph/DAGTest.java | 14 +-
.../executor/io/FsSpillingListStorageTest.java | 14 +-
.../core/executor/io/GenericSpillToolsTest.java | 16 +-
.../core/executor/io/JavaSerializationFactory.java | 14 +-
.../executor/io/TmpFolderSpillFileFactory.java | 14 +-
.../euphoria/core/testing/DatasetAssert.java | 14 +-
.../euphoria/core/time/TimeProvidersTest.java | 14 +-
.../euphoria/core/util/SettingsTest.java | 14 +-
.../src/test/resources/logback-test.xml | 21 --
.../euphoria/euphoria-examples/build.gradle | 32 ---
.../extensions/euphoria/euphoria-examples/pom.xml | 140 -----------
.../cz/seznam/euphoria/examples/Executors.java | 127 ----------
.../cz/seznam/euphoria/examples/HBaseStreamer.java | 106 --------
.../cz/seznam/euphoria/examples/HFileLoader.java | 157 ------------
.../java/cz/seznam/euphoria/examples/Utils.java | 164 -------------
.../examples/wordcount/AccessLogCount.java | 266 ---------------------
.../examples/wordcount/SimpleWordCount.java | 213 -----------------
.../src/main/resources/log4j.properties | 7 -
.../examples/wordcount/SimpleWordCountTest.java | 84 -------
.../src/test/resources/avro/data.avro | Bin 272 -> 0 bytes
.../euphoria/euphoria-fluent/build.gradle | 18 ++
.../extensions/euphoria/euphoria-fluent/pom.xml | 62 -----
.../java/cz/seznam/euphoria/fluent/Dataset.java | 72 ------
.../main/java/cz/seznam/euphoria/fluent/Flow.java | 42 ----
.../java/cz/seznam/euphoria/fluent/Fluent.java | 34 ---
.../sdk/extensions/euphoria/fluent/Dataset.java | 76 ++++++
.../beam/sdk/extensions/euphoria/fluent/Flow.java | 45 ++++
.../sdk/extensions/euphoria/fluent/Fluent.java} | 23 +-
.../extensions}/euphoria/fluent/package-info.java | 2 +-
.../extensions}/euphoria/fluent/FluentTest.java | 28 ++-
.../euphoria/euphoria-local/build.gradle | 18 ++
.../extensions/euphoria/euphoria-local/pom.xml | 70 ------
.../seznam/euphoria/executor/local/Collector.java | 21 --
.../seznam/euphoria/executor/local/ExecPath.java | 39 ---
.../local/ProcessingTimeTriggerScheduler.java | 25 --
.../executor/local/AbstractTriggerScheduler.java | 14 +-
.../euphoria/executor/local/AttachedWindowing.java | 24 +-
.../euphoria/executor/local/Collector.java} | 9 +-
.../extensions}/euphoria/executor/local/Datum.java | 18 +-
.../euphoria/executor/local/ExecPath.java} | 27 ++-
.../euphoria/executor/local/ExecUnit.java | 22 +-
.../euphoria/executor/local/KeyedWindow.java | 16 +-
.../euphoria/executor/local/LocalExecutor.java | 74 +++---
.../euphoria/executor/local/LocalSpillTools.java | 20 +-
.../euphoria/executor/local/LocalStateContext.java | 20 +-
.../executor/local/LocalStorageProvider.java | 24 +-
.../executor/local/NoopTriggerScheduler.java | 16 +-
.../local/ProcessingTimeTriggerScheduler.java} | 13 +-
.../executor/local/ReduceStateByKeyReducer.java | 62 ++---
.../euphoria/executor/local/TriggerScheduler.java | 16 +-
.../euphoria/executor/local/Triggerable.java | 16 +-
.../executor/local/WatermarkEmitStrategy.java | 14 +-
.../executor/local/WatermarkTriggerScheduler.java | 18 +-
.../executor/local/WindowedElementCollector.java | 34 +--
.../euphoria/executor/local}/package-info.java | 2 +-
.../executor/local/testkit/LocalOperatorTest.java | 23 --
.../euphoria/executor/local/BasicOperatorTest.java | 54 +++--
.../euphoria/executor/local/JoinOperatorTest.java | 46 ++--
.../euphoria/executor/local/LocalExecutorTest.java | 78 +++---
.../extensions}/euphoria/executor/local/Util.java | 14 +-
.../euphoria/executor/local/VectorClockTest.java | 16 +-
.../euphoria/executor/local/WindowingTest.java | 50 ++--
.../local/testkit/LocalExecutorProvider.java | 24 +-
.../executor/local/testkit/LocalOperatorTest.java} | 7 +-
.../euphoria-operator-testkit/build.gradle | 18 ++
.../euphoria/euphoria-operator-testkit/pom.xml | 96 --------
.../test/accumulators/SnapshotProvider.java | 31 ---
.../operator/test/accumulators/Snapshotable.java | 20 --
.../operator/test/junit/ExecutorEnvironment.java | 28 ---
.../operator/test/junit/ExecutorProvider.java | 24 --
.../euphoria/operator/test/AllOperatorsSuite.java | 18 +-
.../operator/test/BroadcastHashJoinTest.java | 34 +--
.../euphoria/operator/test/CountByKeyTest.java | 30 +--
.../euphoria/operator/test/DistinctTest.java | 30 +--
.../euphoria/operator/test/FilterTest.java | 22 +-
.../euphoria/operator/test/FlatMapTest.java | 28 ++-
.../euphoria/operator/test/IntWindow.java | 16 +-
.../euphoria/operator/test/JoinTest.java | 60 ++---
.../operator/test/JoinWindowEnforcementTest.java | 38 +--
.../euphoria/operator/test/MapElementsTest.java | 28 ++-
.../euphoria/operator/test/ReduceByKeyTest.java | 80 ++++---
.../operator/test/ReduceStateByKeyTest.java | 72 +++---
.../euphoria/operator/test/ReduceWindowTest.java | 28 ++-
.../euphoria/operator/test/SinkTest.java | 32 +--
.../euphoria/operator/test/SumByKeyTest.java | 26 +-
.../euphoria/operator/test/TopPerKeyTest.java | 24 +-
.../euphoria/operator/test/UnionTest.java | 28 ++-
.../extensions}/euphoria/operator/test/Util.java | 22 +-
.../euphoria/operator/test/WatermarkTest.java | 36 +--
.../euphoria/operator/test/WindowingTest.java | 68 +++---
.../operator/test/accumulators/LongCounter.java | 16 +-
.../operator/test/accumulators/LongHistogram.java | 16 +-
.../test/accumulators/NanosecondTimer.java | 16 +-
.../accumulators/SingleJvmAccumulatorProvider.java | 28 ++-
.../test/accumulators/SnapshotProvider.java} | 15 +-
.../operator/test/accumulators/Snapshotable.java} | 8 +-
.../operator/test/accumulators/package-info.java | 2 +-
.../operator/test/junit/AbstractOperatorTest.java | 35 +--
.../operator/test/junit/ExecutorEnvironment.java} | 12 +-
.../operator/test/junit/ExecutorProvider.java} | 8 +-
.../test/junit/ExecutorProviderRunner.java | 16 +-
.../euphoria/operator/test/junit/Processing.java | 14 +-
.../euphoria/operator/test/junit/package-info.java | 2 +-
.../euphoria/operator/test/package-info.java | 4 +-
.../euphoria/euphoria-testing/build.gradle | 18 ++
.../extensions/euphoria/euphoria-testing/pom.xml | 64 -----
.../euphoria/testing/AbstractFlowTest.java | 22 +-
.../euphoria/testing/DatasetAssert.java | 14 +-
.../extensions/euphoria/testing}/package-info.java | 2 +-
403 files changed, 3906 insertions(+), 6228 deletions(-)
--
To stop receiving notification emails like this one, please contact
jbonofre@apache.org.