You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by an...@apache.org on 2018/10/24 16:18:58 UTC
[beam] branch master updated (5b57fb1 -> 2e759fe)
This is an automated email from the ASF dual-hosted git repository.
anton pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 5b57fb1 Merge pull request #6726: [BEAM-2918] Add state support for streaming in portable FlinkRunner
add 3ad145e Upgrade gradle-spotless to 3.15.0
add 07f725d Add missing package to WindowingTest
add 72642e2 Add licenseHeader to gradle-spotless
add 2e759fe Merge pull request #6791 from kanterov/kanterov/spotless_licenseheader
No new revisions were added by this update.
Summary of changes:
buildSrc/build.gradle | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 24 ++++++++++++++-
.../java/org/apache/beam/examples/WordCountIT.java | 1 -
.../org/apache/beam/examples/complete/TfIdfIT.java | 1 -
.../examples/complete/TopWikipediaSessionsIT.java | 1 -
.../examples/complete/TrafficMaxLaneFlowIT.java | 1 -
.../beam/examples/complete/TrafficRoutesIT.java | 1 -
.../examples/complete/game/LeaderBoardTest.java | 1 -
.../complete/game/StatefulTeamScoreTest.java | 1 -
.../examples/cookbook/BigQueryTornadoesIT.java | 1 -
.../beam/runners/apex/ApexPipelineOptions.java | 1 -
.../beam/runners/apex/ApexRunnerRegistrar.java | 1 -
.../apex/translation/ApexPipelineTranslator.java | 1 -
.../apex/translation/CreateValuesTranslator.java | 1 -
.../translation/FlattenPCollectionTranslator.java | 1 -
.../apex/translation/GroupByKeyTranslator.java | 1 -
.../runners/apex/translation/ParDoTranslator.java | 1 -
.../apex/translation/ReadUnboundedTranslator.java | 1 -
.../apex/translation/TransformTranslator.java | 1 -
.../apex/translation/WindowAssignTranslator.java | 1 -
.../operators/ApexReadUnboundedInputOperator.java | 1 -
.../apex/translation/utils/ValuesSource.java | 1 -
.../runners/apex/examples/UnboundedTextSource.java | 1 -
.../FlattenPCollectionTranslatorTest.java | 1 -
.../apex/translation/GroupByKeyTranslatorTest.java | 1 -
.../apex/translation/ParDoTranslatorTest.java | 1 -
.../translation/ReadUnboundTranslatorTest.java | 1 -
.../apex/translation/SideInputTranslationTest.java | 1 -
.../apex/translation/utils/CollectionSource.java | 1 -
.../core/construction/ArtifactServiceStager.java | 1 -
.../core/construction/CoderTranslation.java | 1 -
.../runners/core/construction/CoderTranslator.java | 1 -
.../construction/CoderTranslatorRegistrar.java | 1 -
.../core/construction/CoderTranslators.java | 1 -
.../core/construction/CombineTranslation.java | 1 -
.../CreatePCollectionViewTranslation.java | 1 -
.../construction/DeduplicatedFlattenFactory.java | 1 -
.../core/construction/DisplayDataTranslation.java | 1 -
.../construction/EmptyFlattenAsCreateFactory.java | 1 -
.../runners/core/construction/Environments.java | 1 -
.../construction/ExecutableStageTranslation.java | 1 -
.../core/construction/FlattenTranslator.java | 1 -
.../core/construction/GroupByKeyTranslation.java | 1 -
.../core/construction/ImpulseTranslation.java | 1 -
.../core/construction/JavaReadViaImpulse.java | 1 -
.../core/construction/ModelCoderRegistrar.java | 1 -
.../runners/core/construction/ModelCoders.java | 1 -
.../core/construction/PCollectionTranslation.java | 1 -
.../construction/PCollectionViewTranslation.java | 1 -
.../core/construction/PTransformReplacements.java | 1 -
.../core/construction/PTransformTranslation.java | 1 -
.../core/construction/ParDoTranslation.java | 1 -
.../construction/PipelineOptionsTranslation.java | 1 -
.../core/construction/PipelineTranslation.java | 1 -
.../runners/core/construction/PrimitiveCreate.java | 1 -
.../runners/core/construction/ReadTranslation.java | 1 -
.../core/construction/RehydratedComponents.java | 1 -
.../core/construction/RunnerPCollectionView.java | 1 -
.../runners/core/construction/SdkComponents.java | 1 -
.../construction/SerializablePipelineOptions.java | 1 -
.../SingleInputOutputOverrideFactory.java | 1 -
.../core/construction/SyntheticComponents.java | 1 -
.../core/construction/TestStreamTranslation.java | 1 -
.../runners/core/construction/TransformInputs.java | 1 -
.../TransformPayloadTranslatorRegistrar.java | 1 -
.../runners/core/construction/UnconsumedReads.java | 1 -
.../construction/UnsupportedOverrideFactory.java | 1 -
.../core/construction/WindowIntoTranslation.java | 1 -
.../core/construction/WriteFilesTranslation.java | 1 -
.../core/construction/graph/ExecutableStage.java | 1 -
.../core/construction/graph/FusedPipeline.java | 1 -
.../graph/GreedyPCollectionFusers.java | 1 -
.../construction/graph/GreedyPipelineFuser.java | 1 -
.../core/construction/graph/GreedyStageFuser.java | 1 -
.../graph/ImmutableExecutableStage.java | 1 -
.../construction/graph/OutputDeduplicator.java | 1 -
.../core/construction/graph/PipelineNode.java | 1 -
.../core/construction/graph/PipelineValidator.java | 22 +++++++------
.../core/construction/graph/ProtoOverrides.java | 1 -
.../core/construction/graph/QueryablePipeline.java | 1 -
.../construction/graph/UserStateReference.java | 1 -
.../core/construction/metrics/MetricFiltering.java | 1 -
.../core/construction/metrics/MetricKey.java | 1 -
.../construction/ArtifactServiceStagerTest.java | 1 -
.../core/construction/CoderTranslationTest.java | 1 -
.../core/construction/CombineTranslationTest.java | 1 -
.../CreatePCollectionViewTranslationTest.java | 1 -
.../DeduplicatedFlattenFactoryTest.java | 1 -
.../EmptyFlattenAsCreateFactoryTest.java | 1 -
.../core/construction/EnvironmentsTest.java | 1 -
.../construction/GroupByKeyTranslationTest.java | 1 -
.../InMemoryArtifactStagerService.java | 1 -
.../core/construction/JavaReadViaImpulseTest.java | 1 -
.../runners/core/construction/ModelCodersTest.java | 1 -
.../construction/PCollectionTranslationTest.java | 1 -
.../PCollectionViewTranslationTest.java | 1 -
.../core/construction/PTransformMatchersTest.java | 1 -
.../construction/PTransformReplacementsTest.java | 1 -
.../construction/PTransformTranslationTest.java | 1 -
.../core/construction/ParDoTranslationTest.java | 1 -
.../PipelineOptionsTranslationTest.java | 1 -
.../core/construction/PipelineTranslationTest.java | 1 -
.../core/construction/ReadTranslationTest.java | 1 -
.../construction/RehydratedComponentsTest.java | 1 -
.../core/construction/ReplacementOutputsTest.java | 1 -
.../core/construction/SdkComponentsTest.java | 1 -
.../SerializablePipelineOptionsTest.java | 1 -
.../SingleInputOutputOverrideFactoryTest.java | 1 -
.../construction/TestStreamTranslationTest.java | 1 -
.../core/construction/TransformInputsTest.java | 1 -
.../core/construction/UnconsumedReadsTest.java | 1 -
.../UnsupportedOverrideFactoryTest.java | 1 -
.../construction/WindowIntoTranslationTest.java | 1 -
.../construction/WriteFilesTranslationTest.java | 1 -
.../construction/graph/ExecutableStageMatcher.java | 1 -
.../construction/graph/ExecutableStageTest.java | 1 -
.../core/construction/graph/FusedPipelineTest.java | 1 -
.../graph/GreedyPipelineFuserTest.java | 1 -
.../construction/graph/GreedyStageFuserTest.java | 1 -
.../core/construction/graph/NetworksTest.java | 1 -
.../construction/graph/OutputDeduplicatorTest.java | 1 -
.../construction/graph/ProtoOverridesTest.java | 1 -
.../construction/graph/QueryablePipelineTest.java | 1 -
.../construction/metrics/MetricFilteringTest.java | 1 -
.../runners/core/ReadyCheckingSideInputReader.java | 1 -
.../beam/runners/core/metrics/CounterCell.java | 1 -
.../beam/runners/core/metrics/DirtyState.java | 1 -
.../runners/core/metrics/DistributionCell.java | 1 -
.../runners/core/metrics/DistributionData.java | 1 -
.../beam/runners/core/metrics/GaugeCell.java | 1 -
.../beam/runners/core/metrics/GaugeData.java | 1 -
.../beam/runners/core/metrics/MetricCell.java | 1 -
.../beam/runners/core/metrics/MetricUpdates.java | 1 -
.../runners/core/metrics/MetricsContainerImpl.java | 1 -
.../core/metrics/MetricsContainerStepMap.java | 1 -
.../beam/runners/core/metrics/MetricsMap.java | 1 -
.../beam/runners/core/metrics/MetricsPusher.java | 1 -
.../runners/core/metrics/MetricsTranslation.java | 1 -
.../beam/runners/core/LateDataUtilsTest.java | 1 -
.../beam/runners/core/metrics/CounterCellTest.java | 1 -
.../beam/runners/core/metrics/DirtyStateTest.java | 1 -
.../runners/core/metrics/DistributionCellTest.java | 1 -
.../beam/runners/core/metrics/GaugeCellTest.java | 1 -
.../runners/core/metrics/MetricUpdateMatchers.java | 1 -
.../core/metrics/MetricsContainerImplTest.java | 1 -
.../core/metrics/MetricsContainerStepMapTest.java | 1 -
.../beam/runners/core/metrics/MetricsMapTest.java | 1 -
.../runners/core/metrics/MetricsPusherTest.java | 1 -
.../core/metrics/MetricsTranslationTest.java | 1 -
.../beam/runners/core/metrics/TestMetricsSink.java | 1 -
.../beam/runners/direct/BundleProcessor.java | 1 -
.../beam/runners/direct/CloningBundleFactory.java | 1 -
.../beam/runners/direct/CommittedBundle.java | 1 -
.../beam/runners/direct/CommittedResult.java | 1 -
.../beam/runners/direct/DirectGroupByKey.java | 1 -
.../beam/runners/direct/DoFnLifecycleManager.java | 1 -
...LifecycleManagerRemovingTransformEvaluator.java | 1 -
.../beam/runners/direct/DoFnLifecycleManagers.java | 1 -
.../beam/runners/direct/ExecutableGraph.java | 1 -
.../beam/runners/direct/MultiStepCombine.java | 1 -
.../beam/runners/direct/PCollectionViewWriter.java | 1 -
.../beam/runners/direct/QuiescenceDriver.java | 1 -
.../beam/runners/direct/RootInputProvider.java | 1 -
.../runners/direct/TestStreamEvaluatorFactory.java | 1 -
.../beam/runners/direct/TransformExecutor.java | 1 -
.../runners/direct/TransformExecutorFactory.java | 1 -
.../beam/runners/direct/UncommittedBundle.java | 1 -
.../beam/runners/direct/ViewOverrideFactory.java | 1 -
.../runners/direct/WriteWithShardingFactory.java | 1 -
.../BundleFactoryOutputReceiverFactory.java | 1 -
.../runners/direct/portable/BundleProcessor.java | 1 -
.../runners/direct/portable/CommittedBundle.java | 1 -
.../runners/direct/portable/CommittedResult.java | 1 -
.../runners/direct/portable/DirectGroupByKey.java | 1 -
.../direct/portable/DirectStateAndTimers.java | 1 -
.../direct/portable/PCollectionViewWriter.java | 1 -
.../runners/direct/portable/PortableGraph.java | 1 -
.../runners/direct/portable/QuiescenceDriver.java | 1 -
.../runners/direct/portable/ReferenceRunner.java | 1 -
.../portable/RemoteStageEvaluatorFactory.java | 1 -
.../runners/direct/portable/RootInputProvider.java | 1 -
.../SplittableRemoteStageEvaluatorFactory.java | 1 -
.../direct/portable/StepStateAndTimers.java | 1 -
.../runners/direct/portable/TransformExecutor.java | 1 -
.../direct/portable/TransformExecutorFactory.java | 1 -
.../runners/direct/portable/UncommittedBundle.java | 1 -
.../artifact/LocalArtifactStagingLocation.java | 1 -
.../LocalFileSystemArtifactRetrievalService.java | 1 -
.../LocalFileSystemArtifactStagerService.java | 1 -
.../UnsupportedArtifactRetrievalService.java | 1 -
.../runners/direct/portable/job/PreparingJob.java | 1 -
.../portable/job/ReferenceRunnerJobService.java | 1 -
.../runners/direct/CloningBundleFactoryTest.java | 1 -
.../beam/runners/direct/CommittedResultTest.java | 1 -
.../DirectGroupByKeyOverrideFactoryTest.java | 1 -
.../beam/runners/direct/DirectMetricsTest.java | 1 -
.../runners/direct/DirectRunnerApiSurfaceTest.java | 1 -
...cycleManagerRemovingTransformEvaluatorTest.java | 1 -
.../runners/direct/DoFnLifecycleManagerTest.java | 1 -
.../runners/direct/DoFnLifecycleManagersTest.java | 1 -
.../ExecutorServiceParallelExecutorTest.java | 8 ++---
.../direct/ImpulseEvaluatorFactoryTest.java | 1 -
.../beam/runners/direct/MultiStepCombineTest.java | 1 -
.../runners/direct/StepTransformResultTest.java | 1 -
.../direct/TestStreamEvaluatorFactoryTest.java | 1 -
.../runners/direct/ViewOverrideFactoryTest.java | 1 -
.../direct/WriteWithShardingFactoryTest.java | 1 -
.../BundleFactoryOutputReceiverFactoryTest.java | 1 -
.../direct/portable/CommittedResultTest.java | 1 -
.../runners/direct/portable/DirectMetricsTest.java | 1 -
.../direct/portable/ExecutableGraphBuilder.java | 1 -
.../portable/ImpulseEvaluatorFactoryTest.java | 1 -
.../runners/direct/portable/PortableGraphTest.java | 1 -
.../direct/portable/ReferenceRunnerTest.java | 1 -
.../portable/RemoteStageEvaluatorFactoryTest.java | 1 -
.../direct/portable/StepTransformResultTest.java | 1 -
.../artifact/LocalArtifactStagingLocationTest.java | 1 -
...ocalFileSystemArtifactRetrievalServiceTest.java | 1 -
.../LocalFileSystemArtifactStagerServiceTest.java | 1 -
.../UnsupportedArtifactRetrievalServiceTest.java | 1 -
.../job/ReferenceRunnerJobServiceTest.java | 2 +-
.../extensions/metrics/MetricsGraphiteSink.java | 1 -
.../extensions/metrics/MetricsHttpSink.java | 1 -
.../metrics/MetricsGraphiteSinkTest.java | 1 -
.../extensions/metrics/MetricsHttpSinkTest.java | 1 -
.../extensions/metrics/NetworkMockServer.java | 15 ++++-----
.../beam/runners/flink/FlinkRunnerRegistrar.java | 1 -
.../flink/FlinkStreamingTransformTranslators.java | 1 -
.../functions/ImpulseSourceFunction.java | 1 -
.../flink/FlinkExecutionEnvironmentsTest.java | 1 -
.../runners/flink/FlinkRunnerRegistrarTest.java | 1 -
.../beam/runners/flink/PortableExecutionTest.java | 1 -
.../functions/ImpulseSourceFunctionTest.java | 1 -
.../runners/gearpump/GearpumpPipelineOptions.java | 1 -
.../runners/gearpump/GearpumpRunnerRegistrar.java | 1 -
.../beam/runners/gearpump/TestGearpumpRunner.java | 1 -
.../CreateGearpumpPCollectionViewTranslator.java | 1 -
.../translators/FlattenPCollectionsTranslator.java | 1 -
.../translators/GearpumpPipelineTranslator.java | 1 -
.../gearpump/translators/GroupByKeyTranslator.java | 1 -
.../translators/ParDoMultiOutputTranslator.java | 1 -
.../translators/ReadBoundedTranslator.java | 1 -
.../translators/ReadUnboundedTranslator.java | 1 -
.../gearpump/translators/TransformTranslator.java | 1 -
.../gearpump/translators/TranslationContext.java | 1 -
.../translators/WindowAssignTranslator.java | 1 -
.../translators/functions/DoFnFunction.java | 1 -
.../translators/io/BoundedSourceWrapper.java | 1 -
.../gearpump/translators/io/GearpumpSource.java | 1 -
.../translators/io/UnboundedSourceWrapper.java | 1 -
.../gearpump/translators/io/ValuesSource.java | 1 -
.../translators/utils/DoFnRunnerFactory.java | 1 -
.../translators/utils/NoOpStepContext.java | 1 -
.../translators/utils/TranslatorUtils.java | 1 -
.../gearpump/GearpumpRunnerRegistrarTest.java | 1 -
...reateGearpumpPCollectionViewTranslatorTest.java | 1 -
.../FlattenPCollectionsTranslatorTest.java | 1 -
.../translators/GroupByKeyTranslatorTest.java | 1 -
.../translators/ReadBoundedTranslatorTest.java | 1 -
.../translators/ReadUnboundedTranslatorTest.java | 1 -
.../translators/WindowAssignTranslatorTest.java | 1 -
.../translators/io/GearpumpSourceTest.java | 1 -
.../translators/utils/TranslatorUtilsTest.java | 1 -
.../beam/runners/dataflow/CreateDataflowView.java | 1 -
.../dataflow/PrimitiveParDoSingleFactory.java | 1 -
.../runners/dataflow/ReshuffleOverrideFactory.java | 1 -
.../runners/dataflow/StreamingViewOverrides.java | 1 -
.../util/AvroCoderCloudObjectTranslator.java | 1 -
.../runners/dataflow/util/CloudObjectKinds.java | 1 -
.../dataflow/util/CloudObjectTranslator.java | 1 -
.../dataflow/util/CloudObjectTranslators.java | 1 -
.../beam/runners/dataflow/util/CloudObjects.java | 1 -
.../util/CoderCloudObjectTranslatorRegistrar.java | 1 -
.../runners/dataflow/util/DataflowTemplateJob.java | 23 ++++++++------
...DefaultCoderCloudObjectTranslatorRegistrar.java | 1 -
.../SerializableCoderCloudObjectTranslator.java | 1 -
.../dataflow/BatchStatefulParDoOverridesTest.java | 1 -
.../runners/dataflow/BatchViewOverridesTest.java | 1 -
.../dataflow/PrimitiveParDoSingleFactoryTest.java | 1 -
.../runners/dataflow/util/CloudObjectsTest.java | 1 -
.../dataflow/worker/DataflowRunnerHarness.java | 1 -
.../dataflow/harness/util/ThrowingBiConsumer.java | 1 -
.../dataflow/harness/util/ThrowingBiFunction.java | 1 -
.../dataflow/harness/util/ThrowingConsumer.java | 1 -
.../dataflow/harness/util/ThrowingFunction.java | 1 -
.../dataflow/harness/util/ThrowingRunnable.java | 1 -
.../dataflow/worker/ApplianceShuffleCounters.java | 1 -
.../worker/ApplianceShuffleEntryReader.java | 1 -
.../dataflow/worker/ApplianceShuffleReader.java | 1 -
.../dataflow/worker/ApplianceShuffleWriter.java | 1 -
.../worker/AssignWindowsParDoFnFactory.java | 1 -
.../runners/dataflow/worker/AvroByteReader.java | 1 -
.../dataflow/worker/AvroByteReaderFactory.java | 1 -
.../beam/runners/dataflow/worker/AvroByteSink.java | 1 -
.../dataflow/worker/AvroByteSinkFactory.java | 1 -
.../dataflow/worker/BatchDataflowWorker.java | 1 -
.../dataflow/worker/BatchModeExecutionContext.java | 1 -
.../worker/BatchModeUngroupingParDoFn.java | 1 -
.../worker/BeamFnMapTaskExecutorFactory.java | 1 -
.../worker/ChunkingShuffleBatchReader.java | 1 -
.../beam/runners/dataflow/worker/CombinePhase.java | 1 -
.../dataflow/worker/CombineValuesFnFactory.java | 1 -
.../beam/runners/dataflow/worker/ConcatReader.java | 1 -
.../dataflow/worker/ConcatReaderFactory.java | 1 -
.../dataflow/worker/CounterShortIdCache.java | 1 -
.../CreateIsmShardKeyAndSortKeyDoFnFactory.java | 1 -
.../runners/dataflow/worker/DataflowApiUtils.java | 1 -
.../worker/DataflowBatchWorkerHarness.java | 1 -
.../worker/DataflowElementExecutionTracker.java | 1 -
.../dataflow/worker/DataflowExecutionContext.java | 1 -
.../dataflow/worker/DataflowMapTaskExecutor.java | 1 -
.../worker/DataflowMapTaskExecutorFactory.java | 1 -
.../dataflow/worker/DataflowMetricsContainer.java | 1 -
.../dataflow/worker/DataflowOperationContext.java | 1 -
.../dataflow/worker/DataflowOutputCounter.java | 1 -
.../worker/DataflowPortabilityPCollectionView.java | 1 -
.../dataflow/worker/DataflowRunnerHarness.java | 1 -
.../worker/DataflowSideInputReadCounter.java | 1 -
.../dataflow/worker/DataflowSystemMetrics.java | 1 -
.../dataflow/worker/DataflowWorkExecutor.java | 1 -
.../dataflow/worker/DataflowWorkUnitClient.java | 1 -
.../worker/DataflowWorkerHarnessHelper.java | 1 -
.../dataflow/worker/DefaultParDoFnFactory.java | 1 -
.../runners/dataflow/worker/DeltaCounterCell.java | 1 -
.../dataflow/worker/DeltaDistributionCell.java | 1 -
.../dataflow/worker/DoFnInstanceManager.java | 1 -
.../dataflow/worker/DoFnInstanceManagers.java | 1 -
.../runners/dataflow/worker/DoFnRunnerFactory.java | 1 -
.../runners/dataflow/worker/ExecutionStateKey.java | 1 -
.../dataflow/worker/ExecutionStateRegistry.java | 1 -
.../runners/dataflow/worker/ExperimentContext.java | 1 -
...FetchAndFilterStreamingSideInputsOperation.java | 1 -
.../beam/runners/dataflow/worker/Filepatterns.java | 1 -
.../dataflow/worker/FnApiWindowMappingFn.java | 1 -
.../runners/dataflow/worker/ForwardingParDoFn.java | 1 -
.../worker/GroupAlsoByWindowParDoFnFactory.java | 1 -
.../dataflow/worker/GroupAlsoByWindowsParDoFn.java | 1 -
.../dataflow/worker/GroupingShuffleReader.java | 1 -
.../worker/GroupingShuffleReaderFactory.java | 1 -
...ingShuffleReaderWithFaultyBytesReadCounter.java | 1 -
.../runners/dataflow/worker/InMemoryReader.java | 1 -
.../dataflow/worker/InMemoryReaderFactory.java | 1 -
.../dataflow/worker/IntrinsicMapTaskExecutor.java | 1 -
.../worker/IntrinsicMapTaskExecutorFactory.java | 1 -
.../beam/runners/dataflow/worker/IsmReader.java | 1 -
.../runners/dataflow/worker/IsmReaderFactory.java | 1 -
.../runners/dataflow/worker/IsmReaderImpl.java | 1 -
.../dataflow/worker/IsmSideInputReader.java | 1 -
.../beam/runners/dataflow/worker/IsmSink.java | 1 -
.../runners/dataflow/worker/IsmSinkFactory.java | 1 -
.../dataflow/worker/KeyTokenInvalidException.java | 1 -
.../worker/LazilyInitializedSideInputReader.java | 1 -
.../worker/MetricTrackingWindmillServerStub.java | 1 -
.../dataflow/worker/MetricsContainerRegistry.java | 1 -
.../worker/MetricsToCounterUpdateConverter.java | 1 -
.../worker/NoOpSourceOperationExecutor.java | 1 -
.../dataflow/worker/NoopSideInputReadCounter.java | 1 -
.../beam/runners/dataflow/worker/OrderedCode.java | 1 -
.../worker/PairWithConstantKeyDoFnFactory.java | 1 -
.../runners/dataflow/worker/ParDoFnFactory.java | 1 -
.../dataflow/worker/PartialGroupByKeyParDoFns.java | 1 -
.../dataflow/worker/PartitioningShuffleReader.java | 1 -
.../worker/PartitioningShuffleReaderFactory.java | 1 -
.../beam/runners/dataflow/worker/PubsubReader.java | 1 -
.../beam/runners/dataflow/worker/PubsubSink.java | 1 -
.../beam/runners/dataflow/worker/ReaderCache.java | 1 -
.../runners/dataflow/worker/ReaderFactory.java | 1 -
.../runners/dataflow/worker/ReaderRegistry.java | 1 -
.../beam/runners/dataflow/worker/ReaderUtils.java | 1 -
.../ReifyTimestampAndWindowsParDoFnFactory.java | 1 -
...HarnessCoderCloudObjectTranslatorRegistrar.java | 1 -
.../dataflow/worker/SdkHarnessRegistries.java | 1 -
.../dataflow/worker/SdkHarnessRegistry.java | 1 -
.../runners/dataflow/worker/ShuffleLibrary.java | 1 -
.../runners/dataflow/worker/ShuffleReader.java | 1 -
.../beam/runners/dataflow/worker/ShuffleSink.java | 1 -
.../dataflow/worker/ShuffleSinkFactory.java | 1 -
.../runners/dataflow/worker/ShuffleWriter.java | 1 -
.../dataflow/worker/SideInputReadCounter.java | 1 -
.../worker/SideInputTrackingIsmReader.java | 1 -
.../dataflow/worker/SimpleDoFnRunnerFactory.java | 1 -
.../runners/dataflow/worker/SimpleParDoFn.java | 1 -
.../beam/runners/dataflow/worker/SinkFactory.java | 1 -
.../beam/runners/dataflow/worker/SinkRegistry.java | 1 -
.../dataflow/worker/SizeReportingSinkWrapper.java | 1 -
.../dataflow/worker/SourceOperationExecutor.java | 1 -
.../worker/SourceOperationExecutorFactory.java | 1 -
.../dataflow/worker/SourceTranslationUtils.java | 1 -
.../worker/SplittableProcessFnFactory.java | 1 -
.../beam/runners/dataflow/worker/StateFetcher.java | 1 -
.../dataflow/worker/StreamingDataflowWorker.java | 1 -
.../StreamingGroupAlsoByWindowReshuffleFn.java | 1 -
.../worker/StreamingGroupAlsoByWindowsDoFns.java | 1 -
.../StreamingKeyedWorkItemSideInputDoFnRunner.java | 1 -
.../worker/StreamingModeExecutionContext.java | 1 -
.../StreamingPCollectionViewWriterDoFnFactory.java | 1 -
.../StreamingPCollectionViewWriterParDoFn.java | 1 -
.../worker/StreamingSideInputDoFnRunner.java | 1 -
.../dataflow/worker/StreamingSideInputFetcher.java | 1 -
.../worker/ToIsmRecordForMultimapDoFnFactory.java | 1 -
.../worker/UngroupedShuffleReaderFactory.java | 1 -
.../dataflow/worker/UngroupedWindmillReader.java | 1 -
.../dataflow/worker/UserParDoFnFactory.java | 1 -
.../runners/dataflow/worker/ValuesDoFnFactory.java | 1 -
.../beam/runners/dataflow/worker/Weighers.java | 1 -
.../dataflow/worker/WindmillKeyedWorkItem.java | 1 -
.../dataflow/worker/WindmillNamespacePrefix.java | 1 -
.../worker/WindmillReaderIteratorBase.java | 1 -
.../beam/runners/dataflow/worker/WindmillSink.java | 1 -
.../dataflow/worker/WindmillStateCache.java | 1 -
.../dataflow/worker/WindmillStateInternals.java | 1 -
.../dataflow/worker/WindmillTimerInternals.java | 1 -
.../dataflow/worker/WindowingWindmillReader.java | 1 -
.../dataflow/worker/WorkItemStatusClient.java | 1 -
.../runners/dataflow/worker/WorkUnitClient.java | 1 -
.../WorkerCustomSourceOperationExecutor.java | 1 -
.../dataflow/worker/WorkerCustomSources.java | 1 -
.../worker/WorkerUncaughtExceptionHandler.java | 1 -
.../runners/dataflow/worker/apiary/Apiary.java | 1 -
.../FixMultiOutputInfosOnParDoInstructions.java | 1 -
.../dataflow/worker/counters/CounterFactory.java | 1 -
.../counters/DataflowCounterUpdateExtractor.java | 1 -
.../dataflow/worker/counters/NameContext.java | 1 -
.../dataflow/worker/fn/BeamFnControlService.java | 1 -
.../runners/dataflow/worker/fn/IdGenerator.java | 1 -
.../runners/dataflow/worker/fn/ServerFactory.java | 1 -
.../dataflow/worker/fn/SocketAddressFactory.java | 1 -
.../worker/fn/control/BeamFnMapTaskExecutor.java | 1 -
.../control/RegisterAndProcessBundleOperation.java | 1 -
.../worker/fn/data/BeamFnDataGrpcService.java | 1 -
.../fn/data/RemoteGrpcPortReadOperation.java | 1 -
.../fn/data/RemoteGrpcPortWriteOperation.java | 1 -
.../dataflow/worker/fn/grpc/BeamFnService.java | 1 -
.../worker/fn/logging/BeamFnLoggingService.java | 1 -
.../fn/stream/ServerStreamObserverFactory.java | 1 -
.../graph/CreateRegisterFnOperationFunction.java | 1 -
.../beam/runners/dataflow/worker/graph/Edges.java | 1 -
.../worker/graph/LengthPrefixUnknownCoders.java | 1 -
.../worker/graph/MapTaskToNetworkFunction.java | 1 -
.../runners/dataflow/worker/graph/Networks.java | 1 -
.../beam/runners/dataflow/worker/graph/Nodes.java | 1 -
.../worker/graph/RegisterNodeFunction.java | 1 -
.../graph/RemoveFlattenInstructionsFunction.java | 1 -
.../logging/DataflowWorkerLoggingHandler.java | 1 -
.../logging/DataflowWorkerLoggingInitializer.java | 1 -
.../worker/logging/DataflowWorkerLoggingMDC.java | 1 -
.../JulHandlerPrintStreamAdapterFactory.java | 1 -
.../options/StreamingDataflowWorkerOptions.java | 1 -
.../runners/dataflow/worker/profiler/Profiler.java | 1 -
.../dataflow/worker/status/DebugCapture.java | 1 -
.../dataflow/worker/status/HealthzServlet.java | 1 -
.../dataflow/worker/status/HeapzServlet.java | 1 -
.../dataflow/worker/status/ThreadzServlet.java | 1 -
.../dataflow/worker/status/WorkerStatusPages.java | 1 -
.../util/BatchGroupAlsoByWindowAndCombineFn.java | 1 -
.../util/BatchGroupAlsoByWindowReshuffleFn.java | 1 -
.../util/BatchGroupAlsoByWindowViaIteratorsFn.java | 1 -
.../worker/util/BatchGroupAlsoByWindowsDoFns.java | 1 -
.../dataflow/worker/util/BoundedQueueExecutor.java | 1 -
.../dataflow/worker/util/CloudSourceUtils.java | 1 -
.../dataflow/worker/util/MemoryMonitor.java | 1 -
.../dataflow/worker/util/ScalableBloomFilter.java | 1 -
.../dataflow/worker/util/ValueInEmptyWindows.java | 1 -
.../dataflow/worker/util/WorkerPropertyNames.java | 1 -
.../worker/util/common/ForwardingReiterator.java | 1 -
.../worker/util/common/TaggedReiteratorList.java | 1 -
.../common/worker/CachingShuffleBatchReader.java | 1 -
.../worker/util/common/worker/ElementCounter.java | 1 -
.../common/worker/ElementExecutionTracker.java | 1 -
.../util/common/worker/ExecutionStateSampler.java | 1 -
.../util/common/worker/FlattenOperation.java | 1 -
.../worker/util/common/worker/GroupingTable.java | 1 -
.../worker/util/common/worker/GroupingTables.java | 1 -
.../worker/util/common/worker/JvmRuntime.java | 1 -
.../common/worker/KeyGroupedShuffleEntries.java | 1 -
.../worker/util/common/worker/MapTaskExecutor.java | 1 -
.../worker/util/common/worker/Operation.java | 1 -
.../util/common/worker/OperationContext.java | 1 -
.../common/worker/OutputObjectAndByteCounter.java | 1 -
.../worker/util/common/worker/OutputReceiver.java | 1 -
.../worker/util/common/worker/ParDoFn.java | 1 -
.../worker/util/common/worker/ParDoOperation.java | 1 -
.../worker/util/common/worker/ProgressTracker.java | 1 -
.../util/common/worker/ProgressTrackerGroup.java | 1 -
.../common/worker/ProgressTrackingReiterator.java | 1 -
.../worker/util/common/worker/ReadOperation.java | 1 -
.../worker/util/common/worker/Receiver.java | 1 -
.../util/common/worker/ReceivingOperation.java | 1 -
.../util/common/worker/ShuffleBatchReader.java | 1 -
.../worker/util/common/worker/ShuffleEntry.java | 1 -
.../util/common/worker/ShuffleEntryReader.java | 1 -
.../worker/util/common/worker/ShufflePosition.java | 1 -
.../util/common/worker/ShuffleReadCounter.java | 1 -
.../common/worker/ShuffleReadCounterFactory.java | 1 -
.../worker/SimplePartialGroupByKeyParDoFn.java | 1 -
.../dataflow/worker/util/common/worker/Sink.java | 1 -
.../worker/util/common/worker/WorkExecutor.java | 1 -
.../util/common/worker/WorkProgressUpdater.java | 1 -
.../worker/util/common/worker/WriteOperation.java | 1 -
.../worker/windmill/DirectStreamObserver.java | 1 -
.../windmill/ForwardingClientResponseObserver.java | 1 -
.../worker/windmill/GrpcWindmillServer.java | 1 -
.../worker/windmill/StreamObserverFactory.java | 1 -
.../worker/windmill/WindmillServerStub.java | 1 -
.../dataflow/harness/test/TestExecutors.java | 1 -
.../dataflow/harness/test/TestExecutorsTest.java | 1 -
.../runners/dataflow/harness/test/TestStreams.java | 1 -
.../dataflow/harness/test/TestStreamsTest.java | 1 -
.../worker/ApplianceShuffleCountersTest.java | 5 ++-
.../dataflow/worker/AvroByteReaderFactoryTest.java | 5 ++-
.../dataflow/worker/AvroByteReaderTest.java | 5 ++-
.../dataflow/worker/AvroByteSinkFactoryTest.java | 5 ++-
.../runners/dataflow/worker/AvroByteSinkTest.java | 5 ++-
.../dataflow/worker/BatchDataflowWorkerTest.java | 1 -
.../worker/BatchModeExecutionContextTest.java | 4 +--
.../worker/CombineValuesFnFactoryTest.java | 5 ++-
.../dataflow/worker/ConcatReaderFactoryTest.java | 1 -
.../runners/dataflow/worker/ConcatReaderTest.java | 1 -
.../dataflow/worker/CounterShortIdCacheTest.java | 1 -
...CreateIsmShardKeyAndSortKeyDoFnFactoryTest.java | 4 +--
.../worker/DataflowBatchWorkerHarnessTest.java | 4 +--
.../DataflowElementExecutionTrackerTest.java | 1 -
.../runners/dataflow/worker/DataflowMatchers.java | 1 -
.../worker/DataflowOperationContextTest.java | 4 +--
.../DataflowPortabilityPCollectionViewTest.java | 1 -
.../worker/DataflowSideInputReadCounterTest.java | 1 -
.../worker/DataflowWorkProgressUpdaterTest.java | 5 ++-
.../worker/DataflowWorkUnitClientTest.java | 1 -
.../worker/DataflowWorkerHarnessHelperTest.java | 5 ++-
.../dataflow/worker/DefaultParDoFnFactoryTest.java | 1 -
.../dataflow/worker/DeltaCounterCellTest.java | 4 +--
.../dataflow/worker/DoFnInstanceManagersTest.java | 1 -
.../dataflow/worker/ExperimentContextTest.java | 1 -
.../dataflow/worker/FakeWindmillServer.java | 5 ++-
.../runners/dataflow/worker/FilepatternsTest.java | 1 -
.../dataflow/worker/FnApiWindowMappingFnTest.java | 4 +--
.../GroupAlsoByWindowParDoFnFactoryTest.java | 5 ++-
.../dataflow/worker/GroupingShuffleReaderTest.java | 5 ++-
.../dataflow/worker/InMemoryReaderFactoryTest.java | 5 ++-
.../dataflow/worker/InMemoryReaderTest.java | 1 -
.../IntrinsicMapTaskExecutorFactoryTest.java | 5 ++-
.../worker/IntrinsicMapTaskExecutorTest.java | 5 ++-
.../runners/dataflow/worker/IsmFormatTest.java | 4 +--
.../dataflow/worker/IsmReaderFactoryTest.java | 1 -
.../runners/dataflow/worker/IsmReaderTest.java | 4 +--
.../dataflow/worker/IsmSideInputReaderTest.java | 5 ++-
.../beam/runners/dataflow/worker/IsmSinkTest.java | 4 +--
.../worker/KeyTokenInvalidExceptionTest.java | 1 -
.../LazilyInitializedSideInputReaderTest.java | 4 +--
.../runners/dataflow/worker/LogRecordMatcher.java | 1 -
.../dataflow/worker/LogRecordMatcherTest.java | 1 -
.../beam/runners/dataflow/worker/LogSaver.java | 1 -
.../beam/runners/dataflow/worker/LogSaverTest.java | 1 -
.../dataflow/worker/NameContextsForTests.java | 1 -
.../worker/NoOpSourceOperationExecutorTest.java | 5 ++-
.../runners/dataflow/worker/OrderedCodeTest.java | 5 ++-
.../worker/PairWithConstantKeyDoFnFactoryTest.java | 4 +--
.../worker/PartialGroupByKeyParDoFnsTest.java | 5 ++-
.../worker/PartitioningShuffleReaderTest.java | 5 ++-
.../runners/dataflow/worker/PubsubReaderTest.java | 1 -
.../runners/dataflow/worker/PubsubSinkTest.java | 5 ++-
.../runners/dataflow/worker/ReaderCacheTest.java | 5 ++-
.../runners/dataflow/worker/ReaderFactoryTest.java | 4 +--
.../runners/dataflow/worker/ReaderTestUtils.java | 1 -
...ReifyTimestampAndWindowsParDoFnFactoryTest.java | 5 ++-
...essCoderCloudObjectTranslatorRegistrarTest.java | 1 -
.../dataflow/worker/SdkHarnessRegistryTest.java | 1 -
.../dataflow/worker/ShuffleReaderFactoryTest.java | 5 ++-
.../dataflow/worker/ShuffleSinkFactoryTest.java | 5 ++-
.../runners/dataflow/worker/ShuffleSinkTest.java | 5 ++-
.../runners/dataflow/worker/SimpleParDoFnTest.java | 1 -
.../runners/dataflow/worker/SinkRegistryTest.java | 5 ++-
.../worker/SourceOperationExecutorFactoryTest.java | 5 ++-
.../runners/dataflow/worker/StateFetcherTest.java | 1 -
.../worker/StepContextStateInternalsFactory.java | 5 ++-
.../worker/StreamingDataflowWorkerTest.java | 5 ++-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 1 -
...reamingGroupAlsoByWindowsReshuffleDoFnTest.java | 5 ++-
...eamingKeyedWorkItemSideInputDoFnRunnerTest.java | 1 -
.../worker/StreamingModeExecutionContextTest.java | 5 ++-
...eamingPCollectionViewWriterDoFnFactoryTest.java | 4 +--
.../worker/StreamingSideInputDoFnRunnerTest.java | 1 -
.../worker/StreamingSideInputFetcherTest.java | 1 -
.../worker/StreamingStepMetricsContainerTest.java | 1 -
.../dataflow/worker/TestOperationContext.java | 1 -
.../worker/TestShuffleReadCounterFactory.java | 1 -
.../runners/dataflow/worker/TestShuffleReader.java | 5 ++-
.../dataflow/worker/TestShuffleReaderTest.java | 5 ++-
.../runners/dataflow/worker/TestShuffleWriter.java | 5 ++-
.../ToIsmRecordForMultimapDoFnFactoryTest.java | 4 +--
.../worker/UngroupedShuffleReaderTest.java | 5 ++-
.../dataflow/worker/UserParDoFnFactoryTest.java | 1 -
.../dataflow/worker/ValuesDoFnFactoryTest.java | 4 +--
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 4 +--
.../worker/WindmillReaderIteratorBaseTest.java | 4 +--
.../dataflow/worker/WindmillStateCacheTest.java | 4 +--
.../worker/WindmillStateInternalsTest.java | 4 +--
.../dataflow/worker/WindmillStateReaderTest.java | 4 +--
.../dataflow/worker/WindmillStateTestUtils.java | 4 +--
.../dataflow/worker/WindmillTimeUtilsTest.java | 1 -
.../worker/WindmillTimerInternalsTest.java | 1 -
.../dataflow/worker/WorkItemStatusClientTest.java | 1 -
.../WorkerCustomSourcesSplitOnlySourceTest.java | 4 +--
.../dataflow/worker/WorkerCustomSourcesTest.java | 4 +--
.../worker/WorkerPipelineOptionsFactoryTest.java | 1 -
.../worker/WorkerUncaughtExceptionHandlerTest.java | 4 +--
.../runners/dataflow/worker/apiary/ApiaryTest.java | 1 -
...FixMultiOutputInfosOnParDoInstructionsTest.java | 1 -
.../worker/counters/CounterFactoryTest.java | 1 -
.../worker/fn/BeamFnControlServiceTest.java | 1 -
.../dataflow/worker/fn/IdGeneratorTest.java | 1 -
.../dataflow/worker/fn/ServerFactoryTest.java | 1 -
.../worker/fn/SocketAddressFactoryTest.java | 1 -
.../fn/control/BeamFnMapTaskExecutorTest.java | 1 -
.../RegisterAndProcessBundleOperationTest.java | 1 -
.../SingularProcessBundleProgressTrackerTest.java | 1 -
.../worker/fn/data/BeamFnDataGrpcServiceTest.java | 1 -
.../fn/data/RemoteGrpcPortReadOperationTest.java | 1 -
.../fn/data/RemoteGrpcPortWriteOperationTest.java | 1 -
.../fn/logging/BeamFnLoggingServiceTest.java | 1 -
.../fn/stream/ServerStreamObserverFactoryTest.java | 1 -
.../graph/CloneAmbiguousFlattensFunctionTest.java | 1 -
.../CreateRegisterFnOperationFunctionTest.java | 1 -
.../graph/DeduceFlattenLocationsFunctionTest.java | 1 -
.../graph/DeduceNodeLocationsFunctionTest.java | 1 -
.../runners/dataflow/worker/graph/EdgesTest.java | 1 -
...tFetchAndFilterStreamingSideInputNodesTest.java | 1 -
.../graph/LengthPrefixUnknownCodersTest.java | 1 -
.../worker/graph/MapTaskToNetworkFunctionTest.java | 1 -
.../dataflow/worker/graph/NetworksTest.java | 1 -
.../runners/dataflow/worker/graph/NodesTest.java | 1 -
.../RemoveFlattenInstructionsFunctionTest.java | 1 -
.../ReplacePgbkWithPrecombineFunctionTest.java | 1 -
.../DataflowWorkerLoggingInitializerTest.java | 1 -
.../JulHandlerPrintStreamAdapterFactoryTest.java | 1 -
.../worker/profiler/ScopedProfilerTest.java | 1 -
.../dataflow/worker/status/DebugCaptureTest.java | 1 -
.../dataflow/worker/status/ThreadzServletTest.java | 1 -
.../worker/status/WorkerStatusPagesTest.java | 1 -
.../worker/testing/RestoreDataflowLoggingMDC.java | 5 ++-
.../testing/RestoreDataflowLoggingMDCTest.java | 1 -
.../worker/util/BatchGroupAlsoByWindowFnsTest.java | 1 -
.../BatchGroupAlsoByWindowReshuffleDoFnTest.java | 5 ++-
.../dataflow/worker/util/CloudSourceUtilsTest.java | 1 -
...gGroupAlsoByWindowsViaOutputBufferDoFnTest.java | 1 -
.../worker/util/CounterHamcrestMatchers.java | 1 -
.../util/DataflowCounterUpdateExtractorTest.java | 1 -
.../GroupAlsoByWindowViaIteratorsDoFnTest.java | 5 ++-
.../util/GroupAlsoByWindowsAndCombineDoFnTest.java | 1 -
.../dataflow/worker/util/ListOutputManager.java | 1 -
.../dataflow/worker/util/MemoryMonitorTest.java | 4 +--
.../worker/util/ScalableBloomFilterTest.java | 4 +--
.../dataflow/worker/util/TimerOrElementTest.java | 1 -
.../util/common/TaggedReiteratorListTest.java | 1 -
.../worker/BatchingShuffleEntryReaderTest.java | 1 -
.../worker/CachingShuffleBatchReaderTest.java | 1 -
.../common/worker/ExecutionStateSamplerTest.java | 1 -
.../util/common/worker/ExecutorTestUtils.java | 5 ++-
.../util/common/worker/FlattenOperationTest.java | 1 -
.../worker/GroupingShuffleEntryIteratorTest.java | 1 -
.../worker/GroupingShuffleRangeTrackerTest.java | 1 -
.../util/common/worker/GroupingTablesTest.java | 1 -
.../util/common/worker/MapTaskExecutorTest.java | 4 +--
.../worker/OutputObjectAndByteCounterTest.java | 1 -
.../util/common/worker/OutputReceiverTest.java | 1 -
.../util/common/worker/ParDoOperationTest.java | 1 -
.../util/common/worker/ReadOperationTest.java | 1 -
.../util/common/worker/ShuffleEntryTest.java | 1 -
.../worker/util/common/worker/StubbedExecutor.java | 1 -
.../util/common/worker/TestOutputReceiver.java | 1 -
.../common/worker/WorkProgressUpdaterTest.java | 1 -
.../util/common/worker/WriteOperationTest.java | 1 -
.../worker/windmill/GrpcWindmillServerTest.java | 1 -
.../apache/beam/runners/fnexecution/FnService.java | 1 -
.../GrpcContextHeaderAccessorProvider.java | 1 -
.../beam/runners/fnexecution/GrpcFnServer.java | 1 -
.../beam/runners/fnexecution/HeaderAccessor.java | 1 -
.../fnexecution/InProcessServerFactory.java | 1 -
.../beam/runners/fnexecution/ServerFactory.java | 1 -
.../artifact/ArtifactRetrievalService.java | 1 -
.../BeamFileSystemArtifactRetrievalService.java | 1 -
.../fnexecution/control/JobBundleFactory.java | 1 -
.../fnexecution/control/OutputReceiverFactory.java | 1 -
.../control/ProcessBundleDescriptors.java | 1 -
.../runners/fnexecution/control/RemoteBundle.java | 1 -
.../fnexecution/control/RemoteOutputReceiver.java | 1 -
.../SingleEnvironmentInstanceJobBundleFactory.java | 1 -
.../fnexecution/control/StageBundleFactory.java | 1 -
.../runners/fnexecution/data/FnDataService.java | 1 -
.../runners/fnexecution/data/GrpcDataService.java | 1 -
.../fnexecution/data/RemoteInputDestination.java | 1 -
.../environment/EmbeddedEnvironmentFactory.java | 3 +-
.../environment/EnvironmentFactory.java | 1 -
.../environment/ProcessEnvironment.java | 1 -
.../fnexecution/environment/ProcessManager.java | 1 -
.../fnexecution/environment/RemoteEnvironment.java | 1 -
.../fnexecution/logging/GrpcLoggingService.java | 1 -
.../runners/fnexecution/logging/LogWriter.java | 1 -
.../fnexecution/logging/Slf4jLogWriter.java | 1 -
.../runners/fnexecution/provisioning/JobInfo.java | 1 -
.../provisioning/StaticGrpcProvisionService.java | 1 -
.../fnexecution/state/StateRequestHandlers.java | 1 -
.../wire/LengthPrefixUnknownCoders.java | 23 +++++++-------
.../runners/fnexecution/EmbeddedSdkHarness.java | 1 -
.../GrpcContextHeaderAccessorProviderTest.java | 1 -
.../runners/fnexecution/ServerFactoryTest.java | 1 -
.../fnexecution/control/RemoteExecutionTest.java | 1 -
...gleEnvironmentInstanceJobBundleFactoryTest.java | 1 -
.../fnexecution/data/GrpcDataServiceTest.java | 1 -
.../data/RemoteInputDestinationTest.java | 1 -
.../environment/ProcessEnvironmentTest.java | 1 -
.../environment/ProcessManagerTest.java | 1 -
.../environment/RemoteEnvironmentTest.java | 1 -
.../jobsubmission/InMemoryJobServiceTest.java | 1 -
.../logging/GrpcLoggingServiceTest.java | 1 -
.../StaticGrpcProvisionServiceTest.java | 1 -
.../state/StateRequestHandlersTest.java | 1 -
.../wire/LengthPrefixUnknownCodersTest.java | 22 +++++++------
.../java/org/apache/beam/runners/local/Bundle.java | 1 -
.../apache/beam/runners/local/ExecutionDriver.java | 1 -
.../runners/local/PipelineMessageReceiver.java | 1 -
.../apache/beam/runners/local/StructuralKey.java | 1 -
.../beam/runners/local/StructuralKeyTest.java | 1 -
.../beam/runners/samza/SamzaExecutionContext.java | 1 -
.../beam/runners/samza/SamzaPipelineOptions.java | 1 -
.../samza/SamzaPipelineOptionsValidator.java | 1 -
.../beam/runners/samza/SamzaPipelineResult.java | 1 -
.../org/apache/beam/runners/samza/SamzaRunner.java | 1 -
.../beam/runners/samza/SamzaRunnerRegistrar.java | 1 -
.../apache/beam/runners/samza/TestSamzaRunner.java | 1 -
.../runners/samza/adapter/BoundedSourceSystem.java | 1 -
.../samza/adapter/UnboundedSourceSystem.java | 1 -
.../samza/container/BeamContainerRunner.java | 1 -
.../samza/container/ContainerCfgFactory.java | 1 -
.../samza/metrics/DoFnRunnerWithMetrics.java | 1 -
.../samza/metrics/FnWithMetricsWrapper.java | 1 -
.../samza/metrics/SamzaMetricsContainer.java | 1 -
.../apache/beam/runners/samza/runtime/DoFnOp.java | 1 -
.../runtime/DoFnRunnerWithKeyedInternals.java | 1 -
.../beam/runners/samza/runtime/GroupByKeyOp.java | 1 -
.../beam/runners/samza/runtime/KeyedInternals.java | 1 -
.../beam/runners/samza/runtime/KeyedTimerData.java | 1 -
.../runners/samza/runtime/KvToKeyedWorkItemOp.java | 1 -
.../org/apache/beam/runners/samza/runtime/Op.java | 1 -
.../beam/runners/samza/runtime/OpAdapter.java | 1 -
.../beam/runners/samza/runtime/OpEmitter.java | 1 -
.../beam/runners/samza/runtime/OpMessage.java | 1 -
.../samza/runtime/OutputManagerFactory.java | 1 -
.../runners/samza/runtime/SamzaAssignContext.java | 1 -
.../samza/runtime/SamzaStoreStateInternals.java | 1 -
.../samza/runtime/SamzaTimerInternalsFactory.java | 1 -
.../samza/runtime/SingletonKeyedWorkItem.java | 1 -
.../beam/runners/samza/runtime/TimerKey.java | 1 -
.../beam/runners/samza/runtime/WindowAssignOp.java | 1 -
.../beam/runners/samza/state/SamzaMapState.java | 1 -
.../beam/runners/samza/state/SamzaSetState.java | 1 -
.../runners/samza/translation/ConfigBuilder.java | 1 -
.../runners/samza/translation/ConfigContext.java | 1 -
.../translation/FlattenPCollectionsTranslator.java | 1 -
.../samza/translation/GroupByKeyTranslator.java | 1 -
.../runners/samza/translation/PViewToIdMapper.java | 1 -
.../translation/ParDoBoundMultiTranslator.java | 1 -
.../runners/samza/translation/ReadTranslator.java | 1 -
.../samza/translation/SamzaPipelineTranslator.java | 1 -
.../samza/translation/SamzaPublishView.java | 1 -
.../SamzaPublishViewTransformOverride.java | 1 -
.../translation/SamzaPublishViewTranslator.java | 1 -
.../samza/translation/SamzaTransformOverrides.java | 1 -
.../translation/SamzaTranslatorRegistrar.java | 1 -
.../translation/TransformConfigGenerator.java | 1 -
.../samza/translation/TransformTranslator.java | 1 -
.../samza/translation/TranslationContext.java | 1 -
.../samza/translation/WindowAssignTranslator.java | 1 -
.../beam/runners/samza/util/Base64Serializer.java | 1 -
.../runners/samza/util/PipelineDotRenderer.java | 1 -
.../beam/runners/samza/util/SamzaCoders.java | 1 -
.../samza/adapter/BoundedSourceSystemTest.java | 1 -
.../runners/samza/adapter/TestBoundedSource.java | 1 -
.../runners/samza/adapter/TestCheckpointMark.java | 1 -
.../runners/samza/adapter/TestSourceHelpers.java | 1 -
.../runners/samza/adapter/TestUnboundedSource.java | 1 -
.../samza/adapter/UnboundedSourceSystemTest.java | 1 -
.../runtime/SamzaStoreStateInternalsTest.java | 1 -
.../beam/runners/spark/SparkContextOptions.java | 1 -
.../runners/spark/SparkNativePipelineVisitor.java | 1 -
.../beam/runners/spark/SparkPipelineOptions.java | 1 -
.../beam/runners/spark/SparkPipelineResult.java | 1 -
.../org/apache/beam/runners/spark/SparkRunner.java | 1 -
.../beam/runners/spark/SparkRunnerDebugger.java | 1 -
.../beam/runners/spark/SparkRunnerRegistrar.java | 1 -
.../apache/beam/runners/spark/TestSparkRunner.java | 1 -
.../runners/spark/aggregators/AggAccumParam.java | 1 -
.../spark/aggregators/AggregatorsAccumulator.java | 1 -
.../spark/aggregators/NamedAggregators.java | 1 -
.../spark/coders/BeamSparkRunnerRegistrator.java | 1 -
.../beam/runners/spark/coders/CoderHelpers.java | 1 -
.../spark/coders/StatelessJavaSerializer.java | 1 -
.../beam/runners/spark/io/EmptyCheckpointMark.java | 1 -
.../beam/runners/spark/io/MicrobatchSource.java | 1 -
.../beam/runners/spark/io/SourceDStream.java | 1 -
.../apache/beam/runners/spark/io/SourceRDD.java | 1 -
.../runners/spark/io/SparkUnboundedSource.java | 1 -
.../runners/spark/metrics/AggregatorMetric.java | 1 -
.../spark/metrics/AggregatorMetricSource.java | 1 -
.../runners/spark/metrics/CompositeSource.java | 1 -
.../runners/spark/metrics/MetricsAccumulator.java | 1 -
.../spark/metrics/MetricsAccumulatorParam.java | 1 -
.../runners/spark/metrics/SparkBeamMetric.java | 1 -
.../spark/metrics/SparkBeamMetricSource.java | 1 -
.../runners/spark/metrics/WithMetricsSupport.java | 1 -
.../beam/runners/spark/metrics/sink/CsvSink.java | 1 -
.../runners/spark/metrics/sink/GraphiteSink.java | 1 -
.../runners/spark/stateful/StateSpecFunctions.java | 1 -
.../runners/spark/translation/BoundedDataset.java | 1 -
.../beam/runners/spark/translation/Dataset.java | 1 -
.../spark/translation/DoFnRunnerWithMetrics.java | 1 -
.../spark/translation/EvaluationContext.java | 1 -
.../spark/translation/GroupCombineFunctions.java | 1 -
.../spark/translation/MultiDoFnFunction.java | 1 -
.../ReifyTimestampsAndWindowsFunction.java | 1 -
.../spark/translation/SparkAbstractCombineFn.java | 1 -
.../spark/translation/SparkAssignWindowFn.java | 1 -
.../spark/translation/SparkContextFactory.java | 1 -
.../spark/translation/SparkGlobalCombineFn.java | 1 -
.../SparkGroupAlsoByWindowViaOutputBufferFn.java | 1 -
.../spark/translation/SparkKeyedCombineFn.java | 1 -
.../spark/translation/SparkProcessContext.java | 1 -
.../spark/translation/TransformEvaluator.java | 1 -
.../spark/translation/TransformTranslator.java | 1 -
.../spark/translation/TranslationUtils.java | 1 -
.../spark/translation/WindowingHelpers.java | 1 -
.../spark/translation/streaming/Checkpoint.java | 1 -
.../SparkRunnerStreamingContextFactory.java | 1 -
.../translation/streaming/UnboundedDataset.java | 1 -
.../runners/spark/util/GlobalWatermarkHolder.java | 1 -
.../runners/spark/util/SideInputBroadcast.java | 1 -
.../runners/spark/util/SparkSideInputReader.java | 1 -
.../beam/runners/spark/ClearWatermarksRule.java | 1 -
.../beam/runners/spark/SparkPipelineStateTest.java | 1 -
.../runners/spark/SparkRunnerDebuggerTest.java | 1 -
.../runners/spark/SparkRunnerRegistrarTest.java | 1 -
.../spark/TestSparkPipelineOptionsRegistrar.java | 1 -
.../aggregators/metrics/sink/InMemoryMetrics.java | 1 -
.../metrics/sink/InMemoryMetricsSinkRule.java | 1 -
.../beam/runners/spark/io/AvroPipelineTest.java | 1 -
.../beam/runners/spark/io/NumShardsTest.java | 1 -
.../spark/io/ReaderToIteratorAdapterTest.java | 1 -
.../runners/spark/metrics/SparkBeamMetricTest.java | 1 -
.../spark/metrics/SparkMetricsPusherTest.java | 1 -
.../streaming/SparkCoGroupByKeyStreamingTest.java | 1 -
.../streaming/StreamingSourceMetricsTest.java | 1 -
.../org/apache/beam/sdk/annotations/Internal.java | 1 -
.../org/apache/beam/sdk/coders/AtomicCoder.java | 1 -
.../beam/sdk/coders/BigEndianShortCoder.java | 1 -
.../apache/beam/sdk/coders/RowCoderGenerator.java | 1 -
.../apache/beam/sdk/coders/ShardedKeyCoder.java | 1 -
.../beam/sdk/io/ConstantAvroDestination.java | 1 -
.../beam/sdk/io/DynamicAvroDestinations.java | 1 -
.../beam/sdk/io/DynamicFileDestinations.java | 1 -
.../beam/sdk/io/SerializableAvroCodecFactory.java | 1 -
.../java/org/apache/beam/sdk/io/WriteFiles.java | 1 -
.../org/apache/beam/sdk/io/WriteFilesResult.java | 1 -
.../java/org/apache/beam/sdk/metrics/Metric.java | 1 -
.../apache/beam/sdk/metrics/MetricsContainer.java | 1 -
.../org/apache/beam/sdk/metrics/MetricsSink.java | 1 -
.../options/DefaultPipelineOptionsRegistrar.java | 1 -
.../apache/beam/sdk/runners/PTransformMatcher.java | 1 -
.../beam/sdk/runners/PTransformOverride.java | 1 -
.../sdk/runners/PTransformOverrideFactory.java | 2 --
.../org/apache/beam/sdk/schemas/DefaultSchema.java | 1 -
.../beam/sdk/schemas/FieldAccessDescriptor.java | 1 -
.../apache/beam/sdk/schemas/FieldValueGetter.java | 1 -
.../beam/sdk/schemas/FieldValueGetterFactory.java | 1 -
.../apache/beam/sdk/schemas/FieldValueSetter.java | 1 -
.../beam/sdk/schemas/FieldValueSetterFactory.java | 1 -
.../sdk/schemas/GetterBasedSchemaProvider.java | 1 -
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 1 -
.../apache/beam/sdk/schemas/JavaFieldSchema.java | 1 -
.../beam/sdk/schemas/NoSuchSchemaException.java | 1 -
.../org/apache/beam/sdk/schemas/SchemaCoder.java | 1 -
.../apache/beam/sdk/schemas/SchemaProvider.java | 1 -
.../beam/sdk/schemas/SchemaProviderRegistrar.java | 17 ++++++++++
.../apache/beam/sdk/schemas/SchemaRegistry.java | 1 -
.../beam/sdk/schemas/transforms/Convert.java | 1 -
.../apache/beam/sdk/schemas/transforms/Filter.java | 1 -
.../apache/beam/sdk/schemas/transforms/Group.java | 1 -
.../sdk/schemas/transforms/SchemaAggregateFn.java | 1 -
.../apache/beam/sdk/schemas/transforms/Select.java | 1 -
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 1 -
.../sdk/schemas/utils/JavaBeanGetterFactory.java | 1 -
.../sdk/schemas/utils/JavaBeanSetterFactory.java | 1 -
.../beam/sdk/schemas/utils/JavaBeanUtils.java | 1 -
.../apache/beam/sdk/schemas/utils/POJOUtils.java | 1 -
.../sdk/schemas/utils/PojoValueGetterFactory.java | 1 -
.../sdk/schemas/utils/PojoValueSetterFactory.java | 1 -
.../beam/sdk/schemas/utils/ReflectUtils.java | 1 -
.../org/apache/beam/sdk/testing/Annotations.java | 1 -
.../apache/beam/sdk/testing/CrashingRunner.java | 1 -
.../beam/sdk/testing/FileChecksumMatcher.java | 1 -
.../org/apache/beam/sdk/testing/NeedsRunner.java | 1 -
.../org/apache/beam/sdk/testing/TestStream.java | 1 -
.../beam/sdk/testing/UsesAttemptedMetrics.java | 1 -
.../beam/sdk/testing/UsesCommittedMetrics.java | 1 -
.../beam/sdk/testing/UsesCounterMetrics.java | 1 -
.../beam/sdk/testing/UsesDistributionMetrics.java | 1 -
.../apache/beam/sdk/testing/UsesGaugeMetrics.java | 1 -
.../beam/sdk/testing/UsesParDoLifecycle.java | 1 -
.../org/apache/beam/sdk/transforms/Impulse.java | 1 -
.../beam/sdk/transforms/Materialization.java | 1 -
.../beam/sdk/transforms/Materializations.java | 1 -
.../java/org/apache/beam/sdk/transforms/Reify.java | 1 -
.../beam/sdk/transforms/ReifyTimestamps.java | 1 -
.../beam/sdk/transforms/SerializableFunctions.java | 1 -
.../org/apache/beam/sdk/transforms/ToString.java | 1 -
.../sdk/transforms/windowing/WindowMappingFn.java | 1 -
.../org/apache/beam/sdk/util/BackOffUtils.java | 1 -
.../apache/beam/sdk/util/BucketingFunction.java | 1 -
.../apache/beam/sdk/util/ExplicitShardedFile.java | 1 -
.../sdk/util/FilePatternMatchingShardedFile.java | 1 -
.../org/apache/beam/sdk/util/MovingFunction.java | 1 -
.../java/org/apache/beam/sdk/util/NameUtils.java | 1 -
.../apache/beam/sdk/util/NumberedShardedFile.java | 1 -
.../java/org/apache/beam/sdk/util/ShardedFile.java | 1 -
.../org/apache/beam/sdk/values/RowWithGetters.java | 1 -
.../org/apache/beam/sdk/values/RowWithStorage.java | 1 -
.../org/apache/beam/sdk/values/ShardedKey.java | 1 -
.../org/apache/beam/sdk/values/TaggedPValue.java | 2 --
.../sdk/coders/PCollectionCustomCoderTest.java | 1 -
.../org/apache/beam/sdk/coders/RowCoderTest.java | 1 -
.../sdk/io/SerializableAvroCodecFactoryTest.java | 1 -
.../beam/sdk/metrics/MetricResultsMatchers.java | 1 -
.../beam/sdk/metrics/MetricsEnvironmentTest.java | 1 -
.../org/apache/beam/sdk/metrics/MetricsTest.java | 1 -
.../sdk/options/PipelineOptionsReflectorTest.java | 1 -
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 1 -
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 1 -
.../beam/sdk/schemas/SchemaRegistryTest.java | 1 -
.../org/apache/beam/sdk/schemas/SchemaTest.java | 1 -
.../beam/sdk/schemas/transforms/ConvertTest.java | 1 -
.../beam/sdk/schemas/transforms/FilterTest.java | 1 -
.../beam/sdk/schemas/transforms/GroupTest.java | 1 -
.../beam/sdk/schemas/transforms/SelectTest.java | 1 -
.../beam/sdk/schemas/utils/JavaBeanUtilsTest.java | 1 -
.../beam/sdk/schemas/utils/POJOUtilsTest.java | 1 -
.../beam/sdk/schemas/utils/TestJavaBeans.java | 1 -
.../apache/beam/sdk/schemas/utils/TestPOJOs.java | 1 -
.../beam/sdk/testing/CombineFnTesterTest.java | 1 -
.../beam/sdk/testing/CrashingRunnerTest.java | 1 -
.../beam/sdk/testing/PCollectionViewTesting.java | 1 -
.../apache/beam/sdk/testing/TestPipelineTest.java | 1 -
.../apache/beam/sdk/testing/TestStreamTest.java | 1 -
.../apache/beam/sdk/testing/ThreadLeakTracker.java | 2 +-
.../beam/sdk/transforms/ParDoLifecycleTest.java | 1 -
.../beam/sdk/transforms/ReifyTimestampsTest.java | 1 -
.../apache/beam/sdk/transforms/ToStringTest.java | 1 -
.../beam/sdk/util/BucketingFunctionTest.java | 1 -
.../apache/beam/sdk/util/MovingFunctionTest.java | 1 -
.../org/apache/beam/sdk/util/NameUtilsTest.java | 1 -
.../java/org/apache/beam/sdk/values/RowTest.java | 1 -
.../beam/sdk/values/TimestampedValueTest.java | 27 ++++++++--------
.../core/client/operator/CompositeOperator.java | 13 ++++----
.../euphoria/core/client/type/TypeAware.java | 13 ++++----
.../euphoria/core/client/type/TypeUtils.java | 14 ++++-----
.../core/translate/BeamAccumulatorProvider.java | 1 -
.../euphoria/core/testkit/WindowingTest.java | 36 +++++++++++-----------
.../core/translate/BeamMetricsTranslationTest.java | 1 -
.../euphoria/core/translate/TestUtils.java | 14 ++++-----
.../gcp/options/GcpPipelineOptionsRegistrar.java | 1 -
.../extensions/sorter/BufferedExternalSorter.java | 1 -
.../beam/sdk/extensions/sorter/ExternalSorter.java | 1 -
.../beam/sdk/extensions/sorter/InMemorySorter.java | 1 -
.../beam/sdk/extensions/sorter/SortValues.java | 1 -
.../apache/beam/sdk/extensions/sorter/Sorter.java | 1 -
.../sorter/BufferedExternalSorterTest.java | 1 -
.../sdk/extensions/sorter/ExternalSorterTest.java | 1 -
.../sdk/extensions/sorter/InMemorySorterTest.java | 1 -
.../beam/sdk/extensions/sorter/SortValuesTest.java | 1 -
.../sdk/extensions/sorter/SorterTestUtils.java | 1 -
.../beam/sdk/extensions/sql/BeamSqlTable.java | 1 -
.../beam/sdk/extensions/sql/SqlTransform.java | 1 -
.../operator/BeamSqlCaseExpression.java | 1 -
.../operator/BeamSqlCastExpression.java | 1 -
.../impl/interpreter/operator/DateOperators.java | 1 -
.../impl/interpreter/operator/StringOperators.java | 1 -
.../arithmetic/BeamSqlArithmeticExpression.java | 1 -
.../arithmetic/BeamSqlDivideExpression.java | 1 -
.../arithmetic/BeamSqlMinusExpression.java | 1 -
.../operator/arithmetic/BeamSqlModExpression.java | 1 -
.../arithmetic/BeamSqlMultiplyExpression.java | 1 -
.../operator/arithmetic/BeamSqlPlusExpression.java | 1 -
.../operator/array/BeamSqlArrayExpression.java | 1 -
.../date/BeamSqlCurrentDateExpression.java | 1 -
.../date/BeamSqlCurrentTimeExpression.java | 1 -
.../date/BeamSqlCurrentTimestampExpression.java | 1 -
.../date/BeamSqlDatetimeMinusExpression.java | 1 -
.../BeamSqlDatetimeMinusIntervalExpression.java | 1 -
.../date/BeamSqlDatetimePlusExpression.java | 1 -
.../date/BeamSqlIntervalMultiplyExpression.java | 1 -
.../BeamSqlTimestampMinusIntervalExpression.java | 1 -
.../BeamSqlTimestampMinusTimestampExpression.java | 1 -
.../interpreter/operator/date/TimeUnitUtils.java | 1 -
.../operator/logical/BeamSqlLogicalExpression.java | 1 -
.../operator/logical/BeamSqlNotExpression.java | 1 -
.../operator/map/BeamSqlMapExpression.java | 1 -
.../operator/math/BeamSqlAbsExpression.java | 1 -
.../operator/math/BeamSqlAcosExpression.java | 1 -
.../operator/math/BeamSqlAsinExpression.java | 1 -
.../operator/math/BeamSqlAtan2Expression.java | 1 -
.../operator/math/BeamSqlAtanExpression.java | 1 -
.../operator/math/BeamSqlCeilExpression.java | 1 -
.../operator/math/BeamSqlCosExpression.java | 1 -
.../operator/math/BeamSqlCotExpression.java | 1 -
.../operator/math/BeamSqlDegreesExpression.java | 1 -
.../operator/math/BeamSqlExpExpression.java | 1 -
.../operator/math/BeamSqlFloorExpression.java | 1 -
.../operator/math/BeamSqlLnExpression.java | 1 -
.../operator/math/BeamSqlLogExpression.java | 1 -
.../operator/math/BeamSqlMathBinaryExpression.java | 1 -
.../operator/math/BeamSqlMathUnaryExpression.java | 1 -
.../operator/math/BeamSqlPiExpression.java | 1 -
.../operator/math/BeamSqlPowerExpression.java | 1 -
.../operator/math/BeamSqlRadiansExpression.java | 1 -
.../operator/math/BeamSqlRandExpression.java | 1 -
.../math/BeamSqlRandIntegerExpression.java | 1 -
.../operator/math/BeamSqlSignExpression.java | 1 -
.../operator/math/BeamSqlSinExpression.java | 1 -
.../operator/math/BeamSqlTanExpression.java | 1 -
.../operator/math/BeamSqlTruncateExpression.java | 1 -
.../reinterpret/BeamSqlReinterpretExpression.java | 1 -
.../DatetimeReinterpretConversions.java | 1 -
.../reinterpret/IntegerReinterpretConversions.java | 1 -
.../reinterpret/ReinterpretConversion.java | 1 -
.../operator/reinterpret/Reinterpreter.java | 1 -
.../operator/row/BeamSqlFieldAccessExpression.java | 1 -
.../sql/impl/parser/SqlCheckConstraint.java | 15 ++++-----
.../sql/impl/parser/SqlColumnDeclaration.java | 15 ++++-----
.../sql/impl/parser/SqlCreateExternalTable.java | 15 ++++-----
.../extensions/sql/impl/parser/SqlDdlNodes.java | 15 ++++-----
.../extensions/sql/impl/parser/SqlDropObject.java | 15 ++++-----
.../extensions/sql/impl/parser/SqlDropTable.java | 15 ++++-----
.../sql/impl/parser/SqlSetOptionBeam.java | 15 ++++-----
.../extensions/sql/impl/rel/BeamIntersectRel.java | 1 -
.../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 1 -
.../sql/impl/rel/BeamLogicalConvention.java | 6 ++--
.../sdk/extensions/sql/impl/rel/BeamMinusRel.java | 1 -
.../sql/impl/rel/BeamSetOperatorRelBase.java | 1 -
.../sdk/extensions/sql/impl/rel/BeamSortRel.java | 1 -
.../sdk/extensions/sql/impl/rel/BeamUnionRel.java | 1 -
.../sdk/extensions/sql/impl/rel/BeamValuesRel.java | 1 -
.../sql/impl/rule/BeamIntersectRule.java | 1 -
.../sdk/extensions/sql/impl/rule/BeamJoinRule.java | 1 -
.../extensions/sql/impl/rule/BeamMinusRule.java | 1 -
.../sdk/extensions/sql/impl/rule/BeamSortRule.java | 1 -
.../sql/impl/rule/BeamUncollectRule.java | 1 -
.../extensions/sql/impl/rule/BeamUnionRule.java | 1 -
.../extensions/sql/impl/rule/BeamUnnestRule.java | 1 -
.../extensions/sql/impl/rule/BeamValuesRule.java | 1 -
.../extensions/sql/impl/schema/BeamTableUtils.java | 1 -
.../sql/impl/transform/BeamJoinTransforms.java | 1 -
.../impl/transform/BeamSetOperatorsTransforms.java | 1 -
.../impl/transform/agg/CovarianceAccumulator.java | 1 -
.../sql/impl/transform/agg/CovarianceFn.java | 1 -
.../impl/transform/agg/VarianceAccumulator.java | 1 -
.../sql/impl/transform/agg/VarianceFn.java | 1 -
.../sql/impl/utils/BigDecimalConverter.java | 1 -
.../extensions/sql/impl/utils/CalciteUtils.java | 1 -
.../apache/beam/sdk/extensions/sql/meta/Table.java | 1 -
.../meta/provider/InMemoryMetaTableProvider.java | 1 -
.../sql/meta/provider/ReadOnlyTableProvider.java | 1 -
.../sql/meta/provider/TableProvider.java | 1 -
.../provider/bigquery/BigQueryTableProvider.java | 1 -
.../meta/provider/kafka/KafkaTableProvider.java | 1 -
.../sql/meta/provider/test/TestTable.java | 1 -
.../sql/meta/provider/test/TestUnboundedTable.java | 1 -
.../sql/meta/provider/text/TextTable.java | 1 -
.../sql/meta/provider/text/TextTableProvider.java | 1 -
.../sql/meta/store/InMemoryMetaStore.java | 1 -
.../sdk/extensions/sql/meta/store/MetaStore.java | 1 -
.../sdk/extensions/sql/BeamSqlDslExistsTest.java | 1 -
.../sdk/extensions/sql/BeamSqlDslJoinTest.java | 1 -
.../apache/beam/sdk/extensions/sql/TestUtils.java | 1 -
.../operator/BeamSqlCaseExpressionTest.java | 1 -
.../operator/BeamSqlCastExpressionTest.java | 1 -
.../operator/BeamSqlReinterpretExpressionTest.java | 1 -
.../BeamSqlArithmeticExpressionTest.java | 1 -
.../date/BeamSqlCurrentDateExpressionTest.java | 1 -
.../date/BeamSqlCurrentTimeExpressionTest.java | 1 -
.../BeamSqlCurrentTimestampExpressionTest.java | 1 -
.../date/BeamSqlDateExpressionTestBase.java | 1 -
.../date/BeamSqlDatetimeMinusExpressionTest.java | 1 -
...BeamSqlDatetimeMinusIntervalExpressionTest.java | 1 -
.../date/BeamSqlDatetimePlusExpressionTest.java | 1 -
.../BeamSqlIntervalMultiplyExpressionTest.java | 1 -
...eamSqlTimestampMinusIntervalExpressionTest.java | 1 -
...amSqlTimestampMinusTimestampExpressionTest.java | 1 -
.../operator/logical/BeamSqlNotExpressionTest.java | 1 -
.../math/BeamSqlMathBinaryExpressionTest.java | 1 -
.../math/BeamSqlMathUnaryExpressionTest.java | 1 -
.../DatetimeReinterpretConversionsTest.java | 1 -
.../IntegerReinterpretConversionsTest.java | 1 -
.../reinterpret/ReinterpretConversionTest.java | 1 -
.../operator/reinterpret/ReinterpreterTest.java | 17 ++++++++++
.../sdk/extensions/sql/impl/rel/BaseRelTest.java | 1 -
.../sql/impl/rel/BeamEnumerableConverterTest.java | 1 -
.../sql/impl/rel/BeamIntersectRelTest.java | 1 -
.../impl/rel/BeamJoinRelBoundedVsBoundedTest.java | 1 -
.../rel/BeamJoinRelUnboundedVsBoundedTest.java | 1 -
.../rel/BeamJoinRelUnboundedVsUnboundedTest.java | 1 -
.../extensions/sql/impl/rel/BeamMinusRelTest.java | 1 -
.../sql/impl/rel/BeamSetOperatorRelBaseTest.java | 1 -
.../extensions/sql/impl/rel/BeamSortRelTest.java | 1 -
.../extensions/sql/impl/rel/BeamUnionRelTest.java | 1 -
.../extensions/sql/impl/rel/BeamValuesRelTest.java | 1 -
.../sdk/extensions/sql/impl/rel/CheckSize.java | 1 -
.../sql/impl/schema/BeamSqlRowCoderTest.java | 1 -
.../schema/transform/BeamTransformBaseTest.java | 15 ++++-----
.../transform/agg/VarianceAccumulatorTest.java | 1 -
.../sql/impl/transform/agg/VarianceFnTest.java | 1 -
.../sql/impl/utils/BigDecimalConverterTest.java | 1 -
.../sql/impl/utils/SqlTypeUtilsTest.java | 1 -
...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 1 -
.../BeamSqlComparisonOperatorsIntegrationTest.java | 1 -
.../BeamSqlDateFunctionsIntegrationTest.java | 1 -
.../meta/provider/kafka/BeamKafkaCSVTableTest.java | 1 -
.../beam/sdk/extensions/sql/utils/RowAsserts.java | 1 -
.../java/org/apache/beam/sdk/fn/IdGenerators.java | 30 ++++++++----------
.../beam/sdk/fn/channel/ManagedChannelFactory.java | 1 -
.../beam/sdk/fn/channel/SocketAddressFactory.java | 1 -
.../beam/sdk/fn/data/CloseableFnDataReceiver.java | 1 -
.../data/CompletableFutureInboundDataClient.java | 1 -
.../apache/beam/sdk/fn/data/InboundDataClient.java | 1 -
.../apache/beam/sdk/fn/data/LogicalEndpoint.java | 1 -
.../beam/sdk/fn/data/RemoteGrpcPortRead.java | 1 -
.../beam/sdk/fn/data/RemoteGrpcPortWrite.java | 1 -
.../beam/sdk/fn/function/ThrowingBiConsumer.java | 1 -
.../beam/sdk/fn/function/ThrowingBiFunction.java | 1 -
.../beam/sdk/fn/function/ThrowingFunction.java | 1 -
.../beam/sdk/fn/function/ThrowingRunnable.java | 1 -
.../apache/beam/sdk/fn/stream/AdvancingPhaser.java | 1 -
.../sdk/fn/stream/BufferingStreamObserver.java | 1 -
.../beam/sdk/fn/stream/DirectStreamObserver.java | 1 -
.../stream/ForwardingClientResponseObserver.java | 1 -
.../sdk/fn/stream/OutboundObserverFactory.java | 1 -
.../sdk/fn/stream/SynchronizedStreamObserver.java | 1 -
.../org/apache/beam/sdk/fn/test/TestExecutors.java | 1 -
.../org/apache/beam/sdk/fn/test/TestStreams.java | 1 -
.../sdk/fn/windowing/EncodedBoundedWindow.java | 1 -
.../sdk/fn/channel/ManagedChannelFactoryTest.java | 1 -
.../sdk/fn/channel/SocketAddressFactoryTest.java | 1 -
.../CompletableFutureInboundDataClientTest.java | 1 -
.../beam/sdk/fn/data/RemoteGrpcPortReadTest.java | 1 -
.../beam/sdk/fn/data/RemoteGrpcPortWriteTest.java | 1 -
.../beam/sdk/fn/stream/AdvancingPhaserTest.java | 1 -
.../sdk/fn/stream/BufferingStreamObserverTest.java | 1 -
.../sdk/fn/stream/DirectStreamObserverTest.java | 1 -
.../ForwardingClientResponseObserverTest.java | 1 -
.../sdk/fn/stream/OutboundObserverFactoryTest.java | 1 -
.../apache/beam/sdk/fn/test/TestExecutorsTest.java | 1 -
.../apache/beam/sdk/fn/test/TestStreamsTest.java | 1 -
.../sdk/fn/windowing/EncodedBoundedWindowTest.java | 1 -
.../beam/fn/harness/AssignWindowsRunner.java | 1 -
.../beam/fn/harness/BeamFnDataReadRunner.java | 1 -
.../beam/fn/harness/BeamFnDataWriteRunner.java | 1 -
.../beam/fn/harness/BoundedSourceRunner.java | 1 -
.../java/org/apache/beam/fn/harness/FnHarness.java | 1 -
.../org/apache/beam/fn/harness/GroupingTable.java | 1 -
.../org/apache/beam/fn/harness/MapFnRunners.java | 1 -
.../beam/fn/harness/PrecombineGroupingTable.java | 1 -
.../harness/control/AddHarnessIdInterceptor.java | 3 +-
.../fn/harness/control/BeamFnControlClient.java | 1 -
.../fn/harness/control/BundleSplitListener.java | 1 -
.../fn/harness/control/ProcessBundleHandler.java | 1 -
.../beam/fn/harness/control/RegisterHandler.java | 1 -
.../beam/fn/harness/data/BeamFnDataClient.java | 1 -
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 1 -
.../harness/data/MultiplexingFnDataReceiver.java | 1 -
.../fn/harness/logging/BeamFnLoggingClient.java | 1 -
.../beam/fn/harness/state/FnApiStateAccessor.java | 1 -
.../beam/fn/harness/state/SideInputSpec.java | 1 -
.../stream/HarnessStreamObserverFactories.java | 1 -
.../beam/fn/harness/BeamFnDataReadRunnerTest.java | 1 -
.../beam/fn/harness/BeamFnDataWriteRunnerTest.java | 1 -
.../beam/fn/harness/BoundedSourceRunnerTest.java | 1 -
.../apache/beam/fn/harness/FlattenRunnerTest.java | 1 -
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 1 -
.../org/apache/beam/fn/harness/FnHarnessTest.java | 1 -
.../harness/control/BeamFnControlClientTest.java | 1 -
.../harness/control/ProcessBundleHandlerTest.java | 1 -
.../fn/harness/control/RegisterHandlerTest.java | 1 -
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 1 -
.../data/MultiplexingFnDataReceiverTest.java | 1 -
.../harness/logging/BeamFnLoggingClientTest.java | 1 -
.../stream/HarnessStreamObserverFactoriesTest.java | 1 -
.../apache/beam/sdk/io/aws/options/AwsOptions.java | 1 -
.../apache/beam/sdk/io/aws/s3/S3ResourceId.java | 1 -
.../sdk/io/aws/sns/SnsCoderProviderRegistrar.java | 1 -
.../beam/sdk/io/aws/options/AwsModuleTest.java | 1 -
.../beam/sdk/io/aws/s3/MatchResultMatcher.java | 1 -
.../beam/sdk/io/aws/s3/S3ResourceIdTest.java | 1 -
.../apache/beam/sdk/io/aws/sns/AmazonSNSMock.java | 1 -
.../beam/sdk/io/aws/sns/AmazonSNSMockErrors.java | 1 -
.../beam/sdk/io/aws/sns/AmazonSNSMockSuccess.java | 1 -
.../org/apache/beam/sdk/io/aws/sns/SnsIOTest.java | 1 -
.../beam/sdk/io/cassandra/SplitGeneratorTest.java | 10 ++++--
.../org/apache/beam/sdk/io/common/HashingFn.java | 23 ++++++++------
.../io/elasticsearch/ElasticSearchIOTestUtils.java | 1 -
.../java/org/apache/beam/sdk/io/text/TextIOIT.java | 1 -
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 1 -
.../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 1 -
.../sdk/io/gcp/bigquery/BigQueryQuerySource.java | 1 -
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 1 -
.../sdk/io/gcp/bigquery/BigQueryTableSource.java | 1 -
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 1 -
.../sdk/io/gcp/bigquery/DynamicDestinations.java | 1 -
.../gcp/bigquery/DynamicDestinationsHelpers.java | 1 -
.../org/apache/beam/sdk/io/gcp/bigquery/Mode.java | 16 +++++-----
.../io/gcp/bigquery/PassThroughThenCleanup.java | 1 -
.../beam/sdk/io/gcp/bigquery/ReifyAsIterable.java | 1 -
.../sdk/io/gcp/bigquery/StandardSQLTypeName.java | 16 +++++-----
.../beam/sdk/io/gcp/bigquery/StreamingInserts.java | 1 -
.../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java | 1 -
.../beam/sdk/io/gcp/bigquery/TableDestination.java | 1 -
.../sdk/io/gcp/bigquery/TableDestinationCoder.java | 1 -
.../io/gcp/bigquery/TableDestinationCoderV2.java | 1 -
.../beam/sdk/io/gcp/bigquery/TableRowInfo.java | 1 -
.../sdk/io/gcp/bigquery/TableRowInfoCoder.java | 1 -
.../beam/sdk/io/gcp/bigquery/TableRowWriter.java | 1 -
.../beam/sdk/io/gcp/bigquery/TagWithUniqueIds.java | 1 -
.../sdk/io/gcp/bigquery/WriteBundlesToFiles.java | 1 -
.../gcp/bigquery/WriteGroupedRecordsToFiles.java | 1 -
.../beam/sdk/io/gcp/bigquery/WritePartition.java | 1 -
.../beam/sdk/io/gcp/bigquery/WriteRename.java | 1 -
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 1 -
.../beam/sdk/io/gcp/bigtable/BigtableConfig.java | 1 -
.../sdk/io/gcp/datastore/AdaptiveThrottler.java | 1 -
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 1 -
.../beam/sdk/io/gcp/datastore/MovingAverage.java | 1 -
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 1 -
.../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java | 1 -
.../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 1 -
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 1 -
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 1 -
.../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 1 -
.../beam/sdk/io/gcp/bigquery/BigQueryIOReadIT.java | 1 -
.../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 1 -
.../sdk/io/gcp/bigquery/FakeDatasetService.java | 1 -
.../beam/sdk/io/gcp/bigquery/FakeJobService.java | 1 -
.../sdk/io/gcp/bigquery/InsertRetryPolicyTest.java | 1 -
.../beam/sdk/io/gcp/datastore/SplitQueryFnIT.java | 1 -
.../apache/beam/sdk/io/gcp/datastore/V1ReadIT.java | 1 -
.../beam/sdk/io/gcp/datastore/V1TestOptions.java | 1 -
.../beam/sdk/io/gcp/datastore/V1TestUtil.java | 1 -
.../beam/sdk/io/gcp/datastore/V1WriteIT.java | 1 -
.../beam/sdk/io/gcp/pubsub/PubsubClientTest.java | 1 -
.../sdk/io/gcp/pubsub/PubsubGrpcClientTest.java | 1 -
.../sdk/io/gcp/pubsub/PubsubJsonClientTest.java | 1 -
.../sdk/io/gcp/pubsub/PubsubTestClientTest.java | 1 -
.../sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java | 1 -
.../io/gcp/pubsub/PubsubUnboundedSourceTest.java | 1 -
.../io/hadoop/inputformat/HadoopInputFormatIO.java | 23 ++++++++------
.../ConfigurableEmployeeInputFormat.java | 23 ++++++++------
.../beam/sdk/io/hadoop/inputformat/Employee.java | 23 ++++++++------
.../io/hadoop/inputformat/EmployeeInputFormat.java | 23 ++++++++------
.../sdk/io/hadoop/inputformat/HIFIOElasticIT.java | 23 ++++++++------
.../inputformat/HadoopInputFormatIOTest.java | 23 ++++++++------
.../ReuseObjectsEmployeeInputFormat.java | 23 ++++++++------
.../io/hadoop/inputformat/TestEmployeeDataSet.java | 23 ++++++++------
.../apache/beam/sdk/io/hcatalog/HCatalogIOIT.java | 23 ++++++++------
.../sdk/io/hcatalog/HiveDatabaseTestHelper.java | 23 ++++++++------
.../org/apache/beam/sdk/io/kafka/ConsumerSpEL.java | 2 +-
.../beam/sdk/io/kafka/KafkaTimestampType.java | 3 +-
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 3 +-
.../beam/sdk/io/kafka/TimestampPolicyFactory.java | 3 +-
.../kafka/serialization/InstantDeserializer.java | 1 -
.../io/kafka/serialization/InstantSerializer.java | 1 -
.../beam/sdk/io/synthetic/SyntheticBoundedIO.java | 1 -
.../beam/sdk/io/synthetic/SyntheticOptions.java | 1 -
.../beam/sdk/io/synthetic/SyntheticStep.java | 1 -
.../beam/sdk/io/synthetic/SyntheticUtils.java | 1 -
.../sdk/io/synthetic/SyntheticBoundedIOTest.java | 1 -
.../sdk/io/synthetic/SyntheticOptionsTest.java | 1 -
.../beam/sdk/io/synthetic/SyntheticStepTest.java | 1 -
.../beam/sdk/io/synthetic/SyntheticTestUtils.java | 1 -
.../beam/sdk/loadtests/GroupByKeyLoadTest.java | 4 +--
.../org/apache/beam/sdk/nexmark/PubsubHelper.java | 1 -
.../apache/beam/sdk/nexmark/model/sql/RowSize.java | 1 -
.../beam/sdk/nexmark/model/sql/SelectEvent.java | 1 -
.../sdk/nexmark/queries/AbstractSimulator.java | 1 -
.../sdk/nexmark/queries/sql/NexmarkSqlQuery.java | 1 -
.../beam/sdk/nexmark/queries/sql/SqlQuery0.java | 1 -
.../sources/generator/GeneratorCheckpoint.java | 1 -
.../sources/generator/model/AuctionGenerator.java | 1 -
.../sources/generator/model/BidGenerator.java | 1 -
.../sources/generator/model/LongGenerator.java | 1 -
.../sources/generator/model/PriceGenerator.java | 1 -
.../sources/generator/model/StringsGenerator.java | 1 -
.../beam/sdk/nexmark/model/sql/RowSizeTest.java | 1 -
.../sdk/nexmark/queries/sql/SqlQuery0Test.java | 1 -
.../sdk/nexmark/queries/sql/SqlQuery1Test.java | 1 -
.../sdk/nexmark/queries/sql/SqlQuery2Test.java | 1 -
.../sdk/nexmark/queries/sql/SqlQuery3Test.java | 1 -
.../sdk/nexmark/queries/sql/SqlQuery5Test.java | 1 -
.../sdk/nexmark/queries/sql/SqlQuery7Test.java | 1 -
1303 files changed, 565 insertions(+), 1694 deletions(-)