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 e7913a92f88aa1d4d3d4d926c04217640b853b5b
Merge: e7a3578 8d70a5d
Author: Jean-Baptiste Onofré <jbono...@apache.org>
AuthorDate: Tue May 15 14:26:17 2018 +0200
Merge pull request #5315 from mareksimunek/dsl-euphoria
[BEAM-3901] Euphoria: Initial import from github
.../core/construction/PTransformTranslation.java | 6 +
.../java/org/apache/beam/runners/direct/Clock.java | 5 +-
.../beam/runners/direct/WatermarkManager.java | 17 +-
.../runners/direct/portable/BundleFactory.java | 9 +-
.../runners/direct/portable/CommittedBundle.java | 5 +-
.../runners/direct/portable/CommittedResult.java | 7 +-
.../direct/portable/CompletionCallback.java | 4 +-
.../direct/portable/DirectExecutionContext.java | 5 +-
...DirectGBKIntoKeyedWorkItemsOverrideFactory.java | 45 -
.../portable/DirectGroupByKeyOverrideFactory.java | 50 -
.../direct/portable/DirectTimerInternals.java | 7 +-
.../direct/portable/DirectTransformExecutor.java | 10 +-
.../runners/direct/portable/EvaluationContext.java | 71 +-
.../portable/ExecutorServiceParallelExecutor.java | 19 +-
.../direct/portable/FlattenEvaluatorFactory.java | 22 +-
.../GroupAlsoByWindowEvaluatorFactory.java | 48 +-
.../portable/GroupByKeyOnlyEvaluatorFactory.java | 41 +-
.../portable/ImmutableListBundleFactory.java | 15 +-
.../direct/portable/ImpulseEvaluatorFactory.java | 25 +-
.../portable/PassthroughTransformEvaluator.java | 8 +-
.../runners/direct/portable/PipelineExecutor.java | 12 +-
.../direct/{ => portable}/PortableGraph.java | 3 +-
.../runners/direct/portable/QuiescenceDriver.java | 49 +-
.../runners/direct/portable/RootInputProvider.java | 19 +-
.../direct/portable/RootProviderRegistry.java | 17 +-
.../beam/runners/direct/portable/StepAndKey.java | 10 +-
.../direct/portable/StepTransformResult.java | 14 +-
.../direct/portable/TransformEvaluatorFactory.java | 6 +-
.../portable/TransformEvaluatorRegistry.java | 6 +-
.../direct/portable/TransformExecutorFactory.java | 4 +-
.../runners/direct/portable/TransformResult.java | 10 +-
.../runners/direct/portable/UncommittedBundle.java | 3 +-
.../direct/portable/WatermarkCallbackExecutor.java | 26 +-
.../runners/direct/portable/WatermarkManager.java | 1568 ------------------
.../direct/portable/WindowEvaluatorFactory.java | 35 +-
.../runners/direct/DirectRunnerApiSurfaceTest.java | 4 +
.../direct/portable/CommittedResultTest.java | 69 +-
.../direct/portable/DirectTimerInternalsTest.java | 6 +-
.../portable/DirectTransformExecutorTest.java | 53 +-
.../direct/portable/EvaluationContextTest.java | 68 +-
.../direct/portable/ExecutableGraphBuilder.java | 82 +
.../portable/FlattenEvaluatorFactoryTest.java | 92 +-
.../portable/GroupByKeyEvaluatorFactoryTest.java | 177 --
.../GroupByKeyOnlyEvaluatorFactoryTest.java | 57 +-
.../portable/ImmutableListBundleFactoryTest.java | 24 +-
.../portable/ImpulseEvaluatorFactoryTest.java | 42 +-
.../beam/runners/direct/portable/MockClock.java | 1 +
.../direct/{ => portable}/PortableGraphTest.java | 2 +-
.../direct/portable/StepTransformResultTest.java | 23 +-
.../portable/WatermarkCallbackExecutorTest.java | 40 +-
.../direct/portable/WatermarkManagerTest.java | 1688 --------------------
.../portable/WindowEvaluatorFactoryTest.java | 61 +-
sdks/java/extensions/euphoria/README.md | 142 ++
.../extensions/euphoria/euphoria-beam/build.gradle | 22 +
.../java/extensions/euphoria/euphoria-beam/pom.xml | 117 ++
.../java/cz/seznam/euphoria/beam/BeamExecutor.java | 78 +
.../seznam/euphoria/beam/BeamExecutorContext.java | 209 +++
.../java/cz/seznam/euphoria/beam/BeamFlow.java | 245 +++
.../cz/seznam/euphoria/beam/DoFnCollector.java | 95 ++
.../cz/seznam/euphoria/beam/FlatMapTranslator.java | 86 +
.../cz/seznam/euphoria/beam/FlowTranslator.java | 120 ++
.../cz/seznam/euphoria/beam/InputTranslator.java | 55 +
.../euphoria/beam/LazyAccumulatorProvider.java | 62 +
.../seznam/euphoria/beam/OperatorTranslator.java | 37 +
.../euphoria/beam/ReduceByKeyTranslator.java | 164 ++
.../euphoria/beam/ReduceStateByKeyTranslator.java | 68 +
.../seznam/euphoria/beam/SingleValueCollector.java | 71 +
.../java/cz/seznam/euphoria/beam/TypeUtils.java | 38 +
.../cz/seznam/euphoria/beam/UnionTranslator.java | 35 +
.../euphoria/beam/WrappedPCollectionOperator.java | 59 +
.../cz/seznam/euphoria/beam/coder/PairCoder.java | 111 ++
.../seznam/euphoria/beam/coder/package-info.java | 12 +-
.../seznam/euphoria/beam/io/BeamBoundedSource.java | 116 ++
.../euphoria/beam/io/BeamUnboundedSource.java | 181 +++
.../cz/seznam/euphoria/beam/io/BeamWriteSink.java | 85 +
.../java/cz/seznam/euphoria/beam/io/KryoCoder.java | 104 ++
.../cz/seznam/euphoria/beam/io/package-info.java | 27 +-
.../java/cz/seznam/euphoria/beam/package-info.java | 12 +-
.../cz/seznam/euphoria/beam/window/BeamWindow.java | 64 +
.../seznam/euphoria/beam/window/BeamWindowFn.java | 108 ++
.../euphoria/beam/window/BeamWindowedElement.java | 55 +
.../seznam/euphoria/beam/window/package-info.java | 12 +-
.../java/cz/seznam/euphoria/beam/BeamFlowTest.java | 196 +++
.../java/cz/seznam/euphoria/beam/FlatMapTest.java | 53 +
.../cz/seznam/euphoria/beam/ReduceByKeyTest.java | 271 ++++
.../beam/testkit/BeamExecutorProvider.java | 48 +
.../euphoria/beam/testkit/BeamOperatorsSuite.java | 50 +
.../euphoria/beam/testkit/BeamOperatorsTest.java | 23 +
.../src/test/resources/log4j.properties | 7 +
.../extensions/euphoria/euphoria-core/build.gradle | 12 +
.../java/extensions/euphoria/euphoria-core/pom.xml | 76 +
.../core/annotation/audience/Audience.java | 43 +
.../core/annotation/audience/package-info.java | 14 +-
.../euphoria/core/annotation/operator/Basic.java | 35 +
.../euphoria/core/annotation/operator/Derived.java | 35 +
.../core/annotation/operator/Recommended.java | 41 +
.../core/annotation/operator/StateComplexity.java | 38 +
.../core/annotation/operator/package-info.java | 15 +-
.../core/annotation/stability/Experimental.java | 42 +
.../core/annotation/stability/package-info.java | 15 +-
.../core/client/accumulators/Accumulator.java | 27 +
.../client/accumulators/AccumulatorProvider.java | 62 +
.../euphoria/core/client/accumulators/Counter.java | 33 +
.../core/client/accumulators/Histogram.java | 38 +
.../euphoria/core/client/accumulators/Timer.java | 45 +
.../accumulators/VoidAccumulatorProvider.java | 131 ++
.../core/client/accumulators/package-info.java | 15 +-
.../euphoria/core/client/dataset/Dataset.java | 80 +
.../euphoria/core/client/dataset/Datasets.java | 53 +
.../euphoria/core/client/dataset/InputDataset.java | 71 +
.../core/client/dataset/OutputDataset.java | 80 +
.../euphoria/core/client/dataset/package-info.java | 15 +-
.../core/client/dataset/windowing/Count.java | 60 +
.../client/dataset/windowing/GlobalWindowing.java | 93 ++
.../client/dataset/windowing/MergingWindowing.java | 38 +
.../core/client/dataset/windowing/Session.java | 158 ++
.../core/client/dataset/windowing/Time.java | 103 ++
.../client/dataset/windowing/TimeInterval.java | 98 ++
.../core/client/dataset/windowing/TimeSliding.java | 134 ++
.../core/client/dataset/windowing/Window.java | 45 +
.../client/dataset/windowing/WindowedElement.java | 38 +
.../core/client/dataset/windowing/Windowing.java | 38 +
.../client/dataset/windowing/package-info.java | 15 +-
.../cz/seznam/euphoria/core/client/flow/Flow.java | 297 ++++
.../cz/seznam/euphoria/core/client/flow/Util.java | 41 +
.../euphoria/core/client/flow/package-info.java | 15 +-
.../core/client/functional/BinaryFunction.java | 40 +
.../core/client/functional/BinaryFunctor.java | 28 +
.../functional/CombinableBinaryFunction.java | 23 +
.../functional/CombinableReduceFunction.java | 26 +
.../client/functional/CompositeUnaryFunction.java | 42 +
.../euphoria/core/client/functional/Consumer.java | 32 +
.../core/client/functional/ExtractEventTime.java | 33 +
.../core/client/functional/ReduceFunction.java | 26 +
.../core/client/functional/ReduceFunctor.java | 38 +
.../client/functional/SameArgsBinaryFunction.java | 24 +
.../core/client/functional/TernaryFunction.java | 27 +
.../core/client/functional/TypeHintAware.java | 33 +
.../core/client/functional/UnaryFunction.java | 38 +
.../core/client/functional/UnaryFunctionEnv.java | 40 +
.../core/client/functional/UnaryFunctor.java | 37 +
.../core/client/functional/UnaryPredicate.java | 23 +
.../core/client/functional/VoidFunction.java | 27 +
.../core/client/functional/package-info.java | 15 +-
.../euphoria/core/client/io/BoundedDataSource.java | 74 +
.../euphoria/core/client/io/BoundedReader.java | 27 +
.../euphoria/core/client/io/CloseableIterator.java | 24 +
.../seznam/euphoria/core/client/io/Collector.java | 42 +
.../cz/seznam/euphoria/core/client/io/Context.java | 22 +
.../seznam/euphoria/core/client/io/DataSink.java | 74 +
.../seznam/euphoria/core/client/io/DataSinks.java | 69 +
.../seznam/euphoria/core/client/io/DataSource.java | 55 +
.../euphoria/core/client/io/Environment.java | 61 +
.../euphoria/core/client/io/ExternalIterable.java | 28 +
.../euphoria/core/client/io/ListDataSink.java | 150 ++
.../euphoria/core/client/io/ListDataSource.java | 279 ++++
.../euphoria/core/client/io/MultiDataSink.java | 172 ++
.../seznam/euphoria/core/client/io/SpillTools.java | 87 +
.../seznam/euphoria/core/client/io/StdoutSink.java | 131 ++
.../core/client/io/UnboundedDataSource.java | 49 +
.../core/client/io/UnboundedPartition.java | 38 +
.../euphoria/core/client/io/UnboundedReader.java | 57 +
.../core/client/io/UnsplittableBoundedSource.java | 36 +
.../seznam/euphoria/core/client/io/VoidSink.java | 54 +
.../cz/seznam/euphoria/core/client/io/Writer.java | 68 +
.../euphoria/core/client/io/package-info.java | 15 +-
.../cz/seznam/euphoria/core/client/lib/Split.java | 119 ++
.../euphoria/core/client/lib/package-info.java | 15 +-
.../core/client/operator/AssignEventTime.java | 153 ++
.../euphoria/core/client/operator/Builders.java | 115 ++
.../euphoria/core/client/operator/CountByKey.java | 179 +++
.../euphoria/core/client/operator/Distinct.java | 216 +++
.../core/client/operator/ElementWiseOperator.java | 44 +
.../euphoria/core/client/operator/Filter.java | 163 ++
.../euphoria/core/client/operator/FlatMap.java | 240 +++
.../euphoria/core/client/operator/FullJoin.java | 128 ++
.../seznam/euphoria/core/client/operator/Join.java | 572 +++++++
.../euphoria/core/client/operator/LeftJoin.java | 139 ++
.../euphoria/core/client/operator/MapElements.java | 194 +++
.../euphoria/core/client/operator/Operator.java | 88 +
.../client/operator/OptionalMethodBuilder.java | 62 +
.../euphoria/core/client/operator/ReduceByKey.java | 634 ++++++++
.../core/client/operator/ReduceStateByKey.java | 400 +++++
.../core/client/operator/ReduceWindow.java | 338 ++++
.../euphoria/core/client/operator/RightJoin.java | 129 ++
.../core/client/operator/SingleInputOperator.java | 45 +
.../euphoria/core/client/operator/StateAware.java | 33 +
.../operator/StateAwareWindowWiseOperator.java | 54 +
.../StateAwareWindowWiseSingleInputOperator.java | 73 +
.../core/client/operator/StateSupport.java | 41 +
.../euphoria/core/client/operator/SumByKey.java | 260 +++
.../euphoria/core/client/operator/TopPerKey.java | 347 ++++
.../euphoria/core/client/operator/Union.java | 200 +++
.../euphoria/core/client/operator/WindowAware.java | 32 +
.../core/client/operator/WindowWiseOperator.java | 41 +
.../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 | 15 +-
.../core/client/operator/package-info.java | 15 +-
.../core/client/operator/state/ListStorage.java | 52 +
.../operator/state/ListStorageDescriptor.java | 38 +
.../operator/state/MergingStorageDescriptor.java | 31 +
.../euphoria/core/client/operator/state/State.java | 44 +
.../core/client/operator/state/StateContext.java | 31 +
.../core/client/operator/state/StateFactory.java | 42 +
.../core/client/operator/state/StateMerger.java | 44 +
.../core/client/operator/state/Storage.java | 26 +
.../client/operator/state/StorageDescriptor.java | 35 +
.../client/operator/state/StorageProvider.java | 42 +
.../core/client/operator/state/ValueStorage.java | 37 +
.../operator/state/ValueStorageDescriptor.java | 101 ++
.../core/client/operator/state/package-info.java | 15 +-
.../triggers/AfterFirstCompositeTrigger.java | 82 +
.../core/client/triggers/CountTrigger.java | 62 +
.../euphoria/core/client/triggers/NoopTrigger.java | 54 +
.../core/client/triggers/PeriodicTimeTrigger.java | 92 ++
.../euphoria/core/client/triggers/TimeTrigger.java | 66 +
.../euphoria/core/client/triggers/Trigger.java | 158 ++
.../core/client/triggers/TriggerContext.java | 55 +
.../core/client/triggers/package-info.java | 15 +-
.../core/client/type/AbstractTypeAware.java | 40 +
.../core/client/type/TypeAwareReduceFunctor.java | 39 +
.../core/client/type/TypeAwareUnaryFunction.java | 39 +
.../core/client/type/TypeAwareUnaryFunctor.java | 38 +
.../seznam/euphoria/core/client/type/TypeHint.java | 83 +
.../euphoria/core/client/type/package-info.java | 15 +-
.../seznam/euphoria/core/client/util/Either.java | 65 +
.../cz/seznam/euphoria/core/client/util/Fold.java | 111 ++
.../cz/seznam/euphoria/core/client/util/Max.java | 45 +
.../cz/seznam/euphoria/core/client/util/Pair.java | 142 ++
.../cz/seznam/euphoria/core/client/util/Sums.java | 40 +
.../seznam/euphoria/core/client/util/Triple.java | 70 +
.../euphoria/core/client/util/package-info.java | 15 +-
.../euphoria/core/executor/AbstractExecutor.java | 45 +
.../seznam/euphoria/core/executor/Constants.java | 44 +
.../cz/seznam/euphoria/core/executor/Executor.java | 81 +
.../euphoria/core/executor/FlowUnfolder.java | 275 ++++
.../euphoria/core/executor/FlowValidator.java | 143 ++
.../seznam/euphoria/core/executor/VectorClock.java | 69 +
.../seznam/euphoria/core/executor/graph/DAG.java | 252 +++
.../seznam/euphoria/core/executor/graph/Node.java | 123 ++
.../euphoria/core/executor/graph/package-info.java | 15 +-
.../core/executor/greduce/GroupReducer.java | 385 +++++
.../core/executor/greduce/TimerSupport.java | 121 ++
.../core/executor/greduce/TriggerStorage.java | 150 ++
.../core/executor/greduce/package-info.java | 15 +-
.../core/executor/io/FsSpillingListStorage.java | 189 +++
.../core/executor/io/GenericSpillTools.java | 140 ++
.../core/executor/io/SerializerFactory.java | 55 +
.../core/executor/io/SpillFileFactory.java | 59 +
.../euphoria/core/executor/io/package-info.java | 15 +-
.../euphoria/core/executor/package-info.java | 15 +-
.../core/executor/util/InMemExternalIterable.java | 44 +
.../core/executor/util/MultiValueContext.java | 112 ++
.../core/executor/util/OperatorTranslator.java | 49 +
.../core/executor/util/SingleValueContext.java | 113 ++
.../euphoria/core/executor/util/package-info.java | 15 +-
.../cz/seznam/euphoria/core/time/Scheduler.java | 35 +
.../cz/seznam/euphoria/core/time/TimeProvider.java | 52 +
.../euphoria/core/time/TimeProviderAware.java | 25 +
.../seznam/euphoria/core/time/TimeProviders.java | 144 ++
.../seznam/euphoria/core/time/TimerScheduler.java | 54 +
.../cz/seznam/euphoria/core/time/package-info.java | 15 +-
.../seznam/euphoria/core/util/ExceptionUtils.java | 113 ++
.../java/cz/seznam/euphoria/core/util/IOUtils.java | 60 +
.../seznam/euphoria/core/util/InstanceUtils.java | 55 +
.../cz/seznam/euphoria/core/util/Settings.java | 195 +++
.../cz/seznam/euphoria/core/util/package-info.java | 15 +-
.../core/client/dataset/windowing/SessionTest.java | 55 +
.../client/dataset/windowing/TimeSlidingTest.java | 53 +
.../core/client/dataset/windowing/TimeTest.java | 45 +
.../dataset/windowing/TimestampedElement.java | 41 +
.../client/dataset/windowing/WindowingTest.java | 169 ++
.../seznam/euphoria/core/client/flow/TestFlow.java | 68 +
.../euphoria/core/client/io/EmptyReader.java | 51 +
.../euphoria/core/client/io/ListDataSinkTest.java | 50 +
.../core/client/io/MockStreamDataSource.java | 47 +
.../euphoria/core/client/io/MultiDataSinkTest.java | 110 ++
.../seznam/euphoria/core/client/lib/SplitTest.java | 90 ++
.../core/client/operator/CountByKeyTest.java | 93 ++
.../core/client/operator/DistinctTest.java | 81 +
.../euphoria/core/client/operator/FilterTest.java | 55 +
.../euphoria/core/client/operator/FlatMapTest.java | 111 ++
.../euphoria/core/client/operator/HintTest.java | 109 ++
.../euphoria/core/client/operator/JoinTest.java | 297 ++++
.../core/client/operator/MapElementsTest.java | 99 ++
.../core/client/operator/ReduceByKeyTest.java | 200 +++
.../core/client/operator/ReduceStateByKeyTest.java | 151 ++
.../core/client/operator/ReduceWindowTest.java | 111 ++
.../core/client/operator/SumByKeyTest.java | 91 ++
.../core/client/operator/TopPerKeyTest.java | 102 ++
.../euphoria/core/client/operator/UnionTest.java | 93 ++
.../seznam/euphoria/core/client/operator/Util.java | 65 +
.../euphoria/core/client/util/IOUtilsTest.java | 67 +
.../euphoria/core/executor/FlowUnfolderTest.java | 235 +++
.../euphoria/core/executor/graph/DAGTest.java | 169 ++
.../executor/io/FsSpillingListStorageTest.java | 135 ++
.../core/executor/io/GenericSpillToolsTest.java | 89 ++
.../core/executor/io/JavaSerializationFactory.java | 139 ++
.../executor/io/TmpFolderSpillFileFactory.java | 48 +
.../euphoria/core/testing/DatasetAssert.java | 53 +
.../euphoria/core/time/TimeProvidersTest.java | 91 ++
.../cz/seznam/euphoria/core/util/SettingsTest.java | 47 +
.../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 0 -> 272 bytes
.../euphoria/euphoria-fluent/build.gradle | 8 +
.../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 +
.../cz/seznam/euphoria/fluent/package-info.java | 14 +-
.../java/cz/seznam/euphoria/fluent/FluentTest.java | 70 +
.../euphoria/euphoria-local/build.gradle | 10 +
.../extensions/euphoria/euphoria-local/pom.xml | 70 +
.../executor/local/AbstractTriggerScheduler.java | 171 ++
.../euphoria/executor/local/AttachedWindowing.java | 51 +
.../seznam/euphoria/executor/local/Collector.java | 21 +
.../cz/seznam/euphoria/executor/local/Datum.java | 151 ++
.../seznam/euphoria/executor/local/ExecPath.java | 39 +
.../seznam/euphoria/executor/local/ExecUnit.java | 84 +
.../euphoria/executor/local/KeyedWindow.java | 63 +
.../euphoria/executor/local/LocalExecutor.java | 893 +++++++++++
.../euphoria/executor/local/LocalSpillTools.java | 46 +
.../euphoria/executor/local/LocalStateContext.java | 38 +
.../executor/local/LocalStorageProvider.java | 86 +
.../executor/local/NoopTriggerScheduler.java | 50 +
.../local/ProcessingTimeTriggerScheduler.java | 25 +
.../executor/local/ReduceStateByKeyReducer.java | 846 ++++++++++
.../euphoria/executor/local/TriggerScheduler.java | 69 +
.../euphoria/executor/local/Triggerable.java | 39 +
.../executor/local/WatermarkEmitStrategy.java | 45 +
.../executor/local/WatermarkTriggerScheduler.java | 160 ++
.../executor/local/WindowedElementCollector.java | 91 ++
.../euphoria/executor/local/package-info.java | 12 +-
.../euphoria/executor/local/BasicOperatorTest.java | 484 ++++++
.../euphoria/executor/local/JoinOperatorTest.java | 241 +++
.../euphoria/executor/local/LocalExecutorTest.java | 600 +++++++
.../cz/seznam/euphoria/executor/local/Util.java | 40 +
.../euphoria/executor/local/VectorClockTest.java | 49 +
.../euphoria/executor/local/WindowingTest.java | 319 ++++
.../local/testkit/LocalExecutorProvider.java | 45 +
.../executor/local/testkit/LocalOperatorTest.java | 23 +
.../src/test/resources/log4j.properties | 22 +
.../euphoria-operator-testkit/build.gradle | 9 +
.../euphoria/euphoria-operator-testkit/pom.xml | 96 ++
.../euphoria/operator/test/AllOperatorsSuite.java | 42 +
.../operator/test/BroadcastHashJoinTest.java | 164 ++
.../euphoria/operator/test/CountByKeyTest.java | 127 ++
.../euphoria/operator/test/DistinctTest.java | 129 ++
.../seznam/euphoria/operator/test/FilterTest.java | 51 +
.../seznam/euphoria/operator/test/FlatMapTest.java | 101 ++
.../seznam/euphoria/operator/test/IntWindow.java | 53 +
.../cz/seznam/euphoria/operator/test/JoinTest.java | 563 +++++++
.../operator/test/JoinWindowEnforcementTest.java | 179 +++
.../euphoria/operator/test/MapElementsTest.java | 99 ++
.../euphoria/operator/test/ReduceByKeyTest.java | 935 +++++++++++
.../operator/test/ReduceStateByKeyTest.java | 772 +++++++++
.../euphoria/operator/test/ReduceWindowTest.java | 90 ++
.../cz/seznam/euphoria/operator/test/SinkTest.java | 97 ++
.../euphoria/operator/test/SumByKeyTest.java | 57 +
.../euphoria/operator/test/TopPerKeyTest.java | 111 ++
.../seznam/euphoria/operator/test/UnionTest.java | 150 ++
.../cz/seznam/euphoria/operator/test/Util.java | 43 +
.../euphoria/operator/test/WatermarkTest.java | 91 ++
.../euphoria/operator/test/WindowingTest.java | 484 ++++++
.../operator/test/accumulators/LongCounter.java | 47 +
.../operator/test/accumulators/LongHistogram.java | 44 +
.../test/accumulators/NanosecondTimer.java | 47 +
.../accumulators/SingleJvmAccumulatorProvider.java | 140 ++
.../test/accumulators/SnapshotProvider.java | 31 +
.../operator/test/accumulators/Snapshotable.java | 20 +
.../operator/test/accumulators/package-info.java | 12 +-
.../operator/test/junit/AbstractOperatorTest.java | 252 +++
.../operator/test/junit/ExecutorEnvironment.java | 28 +
.../operator/test/junit/ExecutorProvider.java | 24 +
.../test/junit/ExecutorProviderRunner.java | 292 ++++
.../euphoria/operator/test/junit/Processing.java | 61 +
.../euphoria/operator/test/junit/package-info.java | 12 +-
.../euphoria/operator/test/package-info.java | 13 +-
.../euphoria/euphoria-testing/build.gradle | 7 +
.../extensions/euphoria/euphoria-testing/pom.xml | 64 +
.../seznam/euphoria/testing/AbstractFlowTest.java | 53 +
.../cz/seznam/euphoria/testing/DatasetAssert.java | 55 +
.../cz/seznam/euphoria/testing/package-info.java | 12 +-
sdks/python/apache_beam/options/value_provider.py | 3 +
.../apache_beam/options/value_provider_test.py | 11 +
settings.gradle | 15 +
399 files changed, 33814 insertions(+), 4506 deletions(-)
--
To stop receiving notification emails like this one, please contact
jbono...@apache.org.
