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:24 UTC
[beam] branch dsl-euphoria updated (e7913a9 -> eff3ffd)
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a change to branch dsl-euphoria
in repository https://gitbox.apache.org/repos/asf/beam.git.
from e7913a9 Merge pull request #5315 from mareksimunek/dsl-euphoria
add acf2ea3 [BEAM-3902] Fix license headers and remove unused poms.
add 5b6421c [BEAM-3902] Move euphoria to apache namespace.
add 4ad6de7 [BEAM-3902] Move euphoria to apache namespace.
new eff3ffd Merge pull request #5366 from dmvk/BEAM-3902
The 1 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:
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(-)
delete mode 100644 sdks/java/extensions/euphoria/euphoria-beam/pom.xml
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/BeamExecutor.java (69%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/BeamExecutorContext.java (75%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/BeamFlow.java (85%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/DoFnCollector.java (63%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/FlatMapTranslator.java (76%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/FlowTranslator.java (69%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/InputTranslator.java (66%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/LazyAccumulatorProvider.java (62%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/OperatorTranslator.java (64%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/ReduceByKeyTranslator.java (84%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/ReduceStateByKeyTranslator.java (80%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/SingleValueCollector.java (63%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/TypeUtils.java (68%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/UnionTranslator.java (64%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/WrappedPCollectionOperator.java (66%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/coder/PairCoder.java (85%)
copy sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/coder/package-info.java (93%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/io/BeamBoundedSource.java (79%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/io/BeamUnboundedSource.java (87%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/io/BeamWriteSink.java (77%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/io/KryoCoder.java (85%)
copy sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/io/package-info.java (93%)
copy sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/package-info.java (94%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/window/BeamWindow.java (73%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/window/BeamWindowFn.java (78%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/window/BeamWindowedElement.java (64%)
copy sdks/java/extensions/euphoria/euphoria-beam/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/window/package-info.java (93%)
delete mode 100644 sdks/java/extensions/euphoria/euphoria-beam/src/test/java/cz/seznam/euphoria/beam/testkit/BeamOperatorsTest.java
rename sdks/java/extensions/euphoria/euphoria-beam/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/BeamFlowTest.java (82%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/FlatMapTest.java (62%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/ReduceByKeyTest.java (74%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/testkit/BeamExecutorProvider.java (60%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/beam/testkit/BeamOperatorsSuite.java (52%)
rename sdks/java/extensions/euphoria/euphoria-beam/src/{main/java/cz/seznam/euphoria/beam/coder/package-info.java => test/java/org/apache/beam/sdk/extensions/euphoria/beam/testkit/BeamOperatorsTest.java} (81%)
delete mode 100644 sdks/java/extensions/euphoria/euphoria-beam/src/test/resources/log4j.properties
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/pom.xml
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/accumulators/Accumulator.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/accumulators/Counter.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/dataset/windowing/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/flow/Util.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/flow/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/BinaryFunctor.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/CombinableBinaryFunction.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/CombinableReduceFunction.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/Consumer.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/ExtractEventTime.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/ReduceFunction.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/SameArgsBinaryFunction.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/TernaryFunction.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/TypeHintAware.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/UnaryPredicate.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/VoidFunction.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/functional/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/io/BoundedReader.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/io/CloseableIterator.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/io/Context.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/io/ExternalIterable.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/io/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/lib/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/WindowAware.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/WindowingRequiredException.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/hint/ComputationHint.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/hint/OutputHint.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/hint/SizeHint.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/hint/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/state/MergingStorageDescriptor.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/state/StateContext.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/state/Storage.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/state/StorageDescriptor.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/state/ValueStorage.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/operator/state/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/triggers/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/type/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/client/util/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/executor/graph/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/executor/greduce/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/executor/io/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/executor/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/executor/util/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/time/Scheduler.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/time/TimeProviderAware.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/time/package-info.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/main/java/cz/seznam/euphoria/core/util/package-info.java
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/annotation/audience/Audience.java (68%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/annotation/audience/package-info.java (91%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/annotation/operator/Basic.java (63%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/annotation/operator/Derived.java (64%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/annotation/operator/Recommended.java (67%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/annotation/operator/StateComplexity.java (66%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/annotation/operator/package-info.java (91%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/annotation/stability/Experimental.java (68%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/annotation/stability}/package-info.java (91%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/Accumulator.java} (65%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/accumulators/AccumulatorProvider.java (70%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/Counter.java} (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/accumulators/Histogram.java (59%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/accumulators/Timer.java (63%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/accumulators/VoidAccumulatorProvider.java (82%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/accumulators}/package-info.java (91%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/Dataset.java (69%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/Datasets.java (65%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/InputDataset.java (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/OutputDataset.java (63%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/dataset}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/Count.java (62%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/GlobalWindowing.java (69%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/MergingWindowing.java (62%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/Session.java (81%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/Time.java (75%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/TimeInterval.java (79%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/TimeSliding.java (80%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/Window.java (67%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/WindowedElement.java (59%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/Windowing.java (65%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/dataset/windowing}/package-info.java (91%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/flow/Flow.java (88%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/flow/Util.java} (62%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/flow}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/functional/BinaryFunction.java (64%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/BinaryFunctor.java} (62%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/CombinableBinaryFunction.java} (70%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/CombinableReduceFunction.java} (66%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/functional/CompositeUnaryFunction.java (67%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/Consumer.java} (64%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/ExtractEventTime.java} (60%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/ReduceFunction.java} (65%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/functional/ReduceFunctor.java (62%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/SameArgsBinaryFunction.java} (68%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/TernaryFunction.java} (65%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/TypeHintAware.java} (58%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/functional/UnaryFunction.java (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/functional/UnaryFunctionEnv.java (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/functional/UnaryFunctor.java (57%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/UnaryPredicate.java} (71%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/VoidFunction.java} (69%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/functional}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/BoundedDataSource.java (77%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/io/BoundedReader.java} (66%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/io/CloseableIterator.java} (69%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/Collector.java (64%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/io/Context.java} (73%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/DataSink.java (76%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/DataSinks.java (72%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/DataSource.java (72%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/Environment.java (61%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/window/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/io/ExternalIterable.java} (65%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/ListDataSink.java (84%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/ListDataSource.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/MultiDataSink.java (88%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/SpillTools.java (80%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/StdoutSink.java (86%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/UnboundedDataSource.java (68%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/UnboundedPartition.java (64%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/UnboundedReader.java (75%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/UnsplittableBoundedSource.java (62%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/VoidSink.java (65%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/Writer.java (75%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/client/dataset => org/apache/beam/sdk/extensions/euphoria/core/client/io}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/lib/Split.java (77%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/lib}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/AssignEventTime.java (78%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/Builders.java (72%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/CountByKey.java (79%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/Distinct.java (81%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/ElementWiseOperator.java (55%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/Filter.java (79%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/FlatMap.java (86%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/FullJoin.java (80%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/Join.java (89%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/LeftJoin.java (81%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/MapElements.java (82%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/Operator.java (69%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/OptionalMethodBuilder.java (72%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/ReduceByKey.java (87%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/ReduceStateByKey.java (88%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/ReduceWindow.java (85%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/RightJoin.java (79%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/SingleInputOperator.java (60%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/StateAware.java (56%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/StateAwareWindowWiseOperator.java (58%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/StateAwareWindowWiseSingleInputOperator.java (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/StateSupport.java (60%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/SumByKey.java (84%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/TopPerKey.java (84%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/Union.java (86%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/WindowAware.java} (58%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/WindowWiseOperator.java (54%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/WindowingRequiredException.java} (61%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/hint/ComputationHint.java} (69%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/hint/OutputHint.java} (70%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/hint/SizeHint.java} (63%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/operator/hint}/package-info.java (91%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation => org/apache/beam/sdk/extensions/euphoria/core/client}/operator/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/state/ListStorage.java (62%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/state/ListStorageDescriptor.java (60%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/state/MergingStorageDescriptor.java} (56%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/state/State.java (62%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/state/StateContext.java} (55%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/state/StateFactory.java (59%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/state/StateMerger.java (61%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/state/Storage.java} (72%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/state/StorageDescriptor.java} (60%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/state/StorageProvider.java (68%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-core/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/state/ValueStorage.java} (62%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/state/ValueStorageDescriptor.java (81%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/operator/state}/package-info.java (91%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/triggers/AfterFirstCompositeTrigger.java (74%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/triggers/CountTrigger.java (63%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/triggers/NoopTrigger.java (65%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/triggers/PeriodicTimeTrigger.java (76%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/triggers/TimeTrigger.java (72%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/triggers/Trigger.java (83%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/triggers/TriggerContext.java (65%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/triggers}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/type/AbstractTypeAware.java (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/type/TypeAwareReduceFunctor.java (62%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/type/TypeAwareUnaryFunction.java (60%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/type/TypeAwareUnaryFunctor.java (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/type/TypeHint.java (79%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/type}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/util/Either.java (70%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/util/Fold.java (75%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/util/Max.java (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/util/Pair.java (87%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/util/Sums.java (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/util/Triple.java (72%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/client/util}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/AbstractExecutor.java (69%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/Constants.java (72%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/Executor.java (66%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/FlowUnfolder.java (89%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/FlowValidator.java (76%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/VectorClock.java (73%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/graph/DAG.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/graph/Node.java (83%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/executor/graph}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/greduce/GroupReducer.java (80%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/greduce/TimerSupport.java (82%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/greduce/TriggerStorage.java (73%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/executor/greduce}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/io/FsSpillingListStorage.java (87%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/io/GenericSpillTools.java (82%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/io/SerializerFactory.java (65%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/io/SpillFileFactory.java (72%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/executor/io}/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/client/accumulators => org/apache/beam/sdk/extensions/euphoria/core/executor}/package-info.java (93%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/util/InMemExternalIterable.java (58%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/util/MultiValueContext.java (69%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/util/OperatorTranslator.java (55%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/util/SingleValueContext.java (70%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/executor/util}/package-info.java (92%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator/package-info.java => org/apache/beam/sdk/extensions/euphoria/core/time/Scheduler.java} (61%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/time/TimeProvider.java (69%)
copy sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator/package-info.java => org/apache/beam/sdk/extensions/euphoria/core/time/TimeProviderAware.java} (76%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/time/TimeProviders.java (87%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/time/TimerScheduler.java (69%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/operator => org/apache/beam/sdk/extensions/euphoria/core/time}/package-info.java (93%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/util/ExceptionUtils.java (86%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/util/IOUtils.java (77%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/util/InstanceUtils.java (73%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/util/Settings.java (89%)
rename sdks/java/extensions/euphoria/euphoria-core/src/main/java/{cz/seznam/euphoria/core/annotation/stability => org/apache/beam/sdk/extensions/euphoria/core/util}/package-info.java (93%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/SessionTest.java (74%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/TimeSlidingTest.java (75%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/TimeTest.java (72%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/TimestampedElement.java (63%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/dataset/windowing/WindowingTest.java (88%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/flow/TestFlow.java (67%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/EmptyReader.java (68%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/ListDataSinkTest.java (67%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/MockStreamDataSource.java (70%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/io/MultiDataSinkTest.java (87%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/lib/SplitTest.java (75%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/CountByKeyTest.java (76%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/DistinctTest.java (76%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/FilterTest.java (69%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/FlatMapTest.java (81%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/HintTest.java (68%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/JoinTest.java (90%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/MapElementsTest.java (80%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/ReduceByKeyTest.java (88%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/ReduceStateByKeyTest.java (77%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/ReduceWindowTest.java (78%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/SumByKeyTest.java (75%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/TopPerKeyTest.java (78%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/UnionTest.java (82%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/operator/Util.java (63%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/client/util/IOUtilsTest.java (74%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/FlowUnfolderTest.java (78%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/graph/DAGTest.java (92%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/io/FsSpillingListStorageTest.java (90%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/io/GenericSpillToolsTest.java (81%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/io/JavaSerializationFactory.java (86%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/executor/io/TmpFolderSpillFileFactory.java (68%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/testing/DatasetAssert.java (76%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/time/TimeProvidersTest.java (85%)
rename sdks/java/extensions/euphoria/euphoria-core/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/core/util/SettingsTest.java (70%)
delete mode 100644 sdks/java/extensions/euphoria/euphoria-core/src/test/resources/logback-test.xml
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/build.gradle
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/pom.xml
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/main/java/cz/seznam/euphoria/examples/Executors.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/main/java/cz/seznam/euphoria/examples/HBaseStreamer.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/main/java/cz/seznam/euphoria/examples/HFileLoader.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/main/java/cz/seznam/euphoria/examples/Utils.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/main/java/cz/seznam/euphoria/examples/wordcount/AccessLogCount.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/main/java/cz/seznam/euphoria/examples/wordcount/SimpleWordCount.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/main/resources/log4j.properties
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/test/java/cz/seznam/euphoria/examples/wordcount/SimpleWordCountTest.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-examples/src/test/resources/avro/data.avro
delete mode 100644 sdks/java/extensions/euphoria/euphoria-fluent/pom.xml
delete mode 100644 sdks/java/extensions/euphoria/euphoria-fluent/src/main/java/cz/seznam/euphoria/fluent/Dataset.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-fluent/src/main/java/cz/seznam/euphoria/fluent/Flow.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-fluent/src/main/java/cz/seznam/euphoria/fluent/Fluent.java
create mode 100644 sdks/java/extensions/euphoria/euphoria-fluent/src/main/java/org/apache/beam/sdk/extensions/euphoria/fluent/Dataset.java
create mode 100644 sdks/java/extensions/euphoria/euphoria-fluent/src/main/java/org/apache/beam/sdk/extensions/euphoria/fluent/Flow.java
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-fluent/src/main/java/org/apache/beam/sdk/extensions/euphoria/fluent/Fluent.java} (59%)
rename sdks/java/extensions/euphoria/euphoria-fluent/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/fluent/package-info.java (93%)
rename sdks/java/extensions/euphoria/euphoria-fluent/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/fluent/FluentTest.java (66%)
delete mode 100644 sdks/java/extensions/euphoria/euphoria-local/pom.xml
delete mode 100644 sdks/java/extensions/euphoria/euphoria-local/src/main/java/cz/seznam/euphoria/executor/local/Collector.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-local/src/main/java/cz/seznam/euphoria/executor/local/ExecPath.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-local/src/main/java/cz/seznam/euphoria/executor/local/ProcessingTimeTriggerScheduler.java
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/AbstractTriggerScheduler.java (91%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/AttachedWindowing.java (52%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-local/src/main/java/org/apache/beam/sdk/extensions/euphoria/executor/local/Collector.java} (87%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/Datum.java (82%)
rename sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/package-info.java => euphoria-local/src/main/java/org/apache/beam/sdk/extensions/euphoria/executor/local/ExecPath.java} (56%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/ExecUnit.java (73%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/KeyedWindow.java (69%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/LocalExecutor.java (90%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/LocalSpillTools.java (62%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/LocalStateContext.java (52%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/LocalStorageProvider.java (64%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/NoopTriggerScheduler.java (64%)
rename sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/window/package-info.java => euphoria-local/src/main/java/org/apache/beam/sdk/extensions/euphoria/executor/local/ProcessingTimeTriggerScheduler.java} (72%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/ReduceStateByKeyReducer.java (91%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/TriggerScheduler.java (78%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/Triggerable.java (65%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/WatermarkEmitStrategy.java (72%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/WatermarkTriggerScheduler.java (88%)
rename sdks/java/extensions/euphoria/euphoria-local/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/WindowedElementCollector.java (60%)
rename sdks/java/extensions/euphoria/{euphoria-testing/src/main/java/cz/seznam/euphoria/testing => euphoria-local/src/main/java/org/apache/beam/sdk/extensions/euphoria/executor/local}/package-info.java (92%)
delete mode 100644 sdks/java/extensions/euphoria/euphoria-local/src/test/java/cz/seznam/euphoria/executor/local/testkit/LocalOperatorTest.java
rename sdks/java/extensions/euphoria/euphoria-local/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/BasicOperatorTest.java (88%)
rename sdks/java/extensions/euphoria/euphoria-local/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/JoinOperatorTest.java (78%)
rename sdks/java/extensions/euphoria/euphoria-local/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/LocalExecutorTest.java (85%)
rename sdks/java/extensions/euphoria/euphoria-local/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/Util.java (64%)
rename sdks/java/extensions/euphoria/euphoria-local/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/VectorClockTest.java (67%)
rename sdks/java/extensions/euphoria/euphoria-local/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/WindowingTest.java (84%)
rename sdks/java/extensions/euphoria/euphoria-local/src/test/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/executor/local/testkit/LocalExecutorProvider.java (51%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-local/src/test/java/org/apache/beam/sdk/extensions/euphoria/executor/local/testkit/LocalOperatorTest.java} (74%)
delete mode 100644 sdks/java/extensions/euphoria/euphoria-operator-testkit/pom.xml
delete mode 100644 sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/cz/seznam/euphoria/operator/test/accumulators/SnapshotProvider.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/cz/seznam/euphoria/operator/test/accumulators/Snapshotable.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/cz/seznam/euphoria/operator/test/junit/ExecutorEnvironment.java
delete mode 100644 sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/cz/seznam/euphoria/operator/test/junit/ExecutorProvider.java
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/AllOperatorsSuite.java (61%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/BroadcastHashJoinTest.java (80%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/CountByKeyTest.java (76%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/DistinctTest.java (75%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/FilterTest.java (59%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/FlatMapTest.java (72%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/IntWindow.java (62%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/JoinTest.java (88%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/JoinWindowEnforcementTest.java (79%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/MapElementsTest.java (71%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/ReduceByKeyTest.java (90%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/ReduceStateByKeyTest.java (89%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/ReduceWindowTest.java (69%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/SinkTest.java (70%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/SumByKeyTest.java (58%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/TopPerKeyTest.java (75%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/UnionTest.java (82%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/Util.java (55%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/WatermarkTest.java (67%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/WindowingTest.java (86%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/accumulators/LongCounter.java (60%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/accumulators/LongHistogram.java (62%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/accumulators/NanosecondTimer.java (66%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/accumulators/SingleJvmAccumulatorProvider.java (79%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-operator-testkit/src/main/java/org/apache/beam/sdk/extensions/euphoria/operator/test/accumulators/SnapshotProvider.java} (70%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-operator-testkit/src/main/java/org/apache/beam/sdk/extensions/euphoria/operator/test/accumulators/Snapshotable.java} (86%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/accumulators/package-info.java (91%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/junit/AbstractOperatorTest.java (85%)
copy sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-operator-testkit/src/main/java/org/apache/beam/sdk/extensions/euphoria/operator/test/junit/ExecutorEnvironment.java} (72%)
rename sdks/java/extensions/euphoria/{euphoria-beam/src/main/java/cz/seznam/euphoria/beam/io/package-info.java => euphoria-operator-testkit/src/main/java/org/apache/beam/sdk/extensions/euphoria/operator/test/junit/ExecutorProvider.java} (79%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/junit/ExecutorProviderRunner.java (94%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/junit/Processing.java (75%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/junit/package-info.java (92%)
rename sdks/java/extensions/euphoria/euphoria-operator-testkit/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/operator/test/package-info.java (85%)
delete mode 100644 sdks/java/extensions/euphoria/euphoria-testing/pom.xml
rename sdks/java/extensions/euphoria/euphoria-testing/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/testing/AbstractFlowTest.java (62%)
rename sdks/java/extensions/euphoria/euphoria-testing/src/main/java/{cz/seznam => org/apache/beam/sdk/extensions}/euphoria/testing/DatasetAssert.java (76%)
rename sdks/java/extensions/euphoria/{euphoria-local/src/main/java/cz/seznam/euphoria/executor/local => euphoria-testing/src/main/java/org/apache/beam/sdk/extensions/euphoria/testing}/package-info.java (93%)
--
To stop receiving notification emails like this one, please contact
jbonofre@apache.org.
[beam] 01/01: Merge pull request #5366 from dmvk/BEAM-3902
Posted by jb...@apache.org.
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.