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é <[email protected]> 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 [email protected].
