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