This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 2438286 (commit)
to aca9099 (commit)
from 2438286 Merge pull request #13130 from robinyqiu/release-doc
add df9d8c6 Add a well-known ShardedKey coder in Java/Python SDK
add 64d247c Merge pull request #13069 from nehsyc/coder
add 5675108 Suppress nullness warnings in files with nullness errors
add 68d6c8e Merge pull request #13191: [BEAM-10402] Suppress nullness
errors in classes that need it
add 91104aa Move @Nullable annotations adjacent to the type they annotate
add aca9099 Merge pull request #13192: [BEAM-10402] Move @Nullable
annotations adjacent to the type they annotate
No new revisions were added by this update.
Summary of changes:
.../apache/beam/examples/common/ExampleUtils.java | 1 +
.../beam/examples/complete/AutoComplete.java | 1 +
.../beam/examples/complete/TrafficMaxLaneFlow.java | 1 +
.../beam/examples/complete/TrafficRoutes.java | 1 +
.../examples/complete/game/StatefulTeamScore.java | 1 +
.../beam/examples/complete/game/UserScore.java | 1 +
.../examples/complete/game/injector/Injector.java | 1 +
.../complete/game/utils/WriteToBigQuery.java | 1 +
.../examples/complete/game/utils/WriteToText.java | 1 +
.../beam/examples/cookbook/TriggerExample.java | 1 +
.../apache/beam/examples/snippets/Snippets.java | 1 +
.../transforms/io/gcp/bigquery/BigQueryMyData.java | 1 +
.../configuration/SubProcessConfiguration.java | 2 +-
.../kernel/SubProcessCommandLineArgs.java | 1 +
.../subprocess/kernel/SubProcessKernel.java | 1 +
.../examples/subprocess/utils/ExecutableFile.java | 1 +
.../beam/examples/subprocess/utils/FileUtils.java | 1 +
.../apache/beam/examples/WindowedWordCountIT.java | 1 +
.../examples/complete/TrafficMaxLaneFlowIT.java | 1 +
.../beam/examples/complete/TrafficRoutesIT.java | 1 +
.../beam/model/fnexecution/v1/standard_coders.yaml | 23 ++++
.../pipeline/src/main/proto/beam_runner_api.proto | 22 +++
.../core/construction/CoderTranslation.java | 1 +
.../core/construction/CoderTranslators.java | 15 +++
.../core/construction/DefaultArtifactResolver.java | 1 +
.../core/construction/DisplayDataTranslation.java | 1 +
.../runners/core/construction/Environments.java | 1 +
.../beam/runners/core/construction/External.java | 1 +
.../core/construction/ExternalTranslation.java | 3 +-
.../core/construction/ForwardingPTransform.java | 1 +
.../core/construction/ModelCoderRegistrar.java | 4 +
.../runners/core/construction/ModelCoders.java | 5 +-
.../core/construction/PTransformReplacements.java | 1 +
.../core/construction/PTransformTranslation.java | 1 +
.../core/construction/RehydratedComponents.java | 1 +
.../core/construction/ReplacementOutputs.java | 1 +
.../core/construction/RunnerPCollectionView.java | 1 +
.../runners/core/construction/SdkComponents.java | 1 +
.../construction/SplittableParDoNaiveBounded.java | 1 +
.../beam/runners/core/construction/Timer.java | 1 +
.../core/construction/TriggerTranslation.java | 1 +
.../UnboundedReadFromBoundedSource.java | 1 +
.../runners/core/construction/UnconsumedReads.java | 1 +
.../core/construction/WriteFilesTranslation.java | 1 +
.../graph/GreedyPCollectionFusers.java | 1 +
.../construction/graph/GreedyPipelineFuser.java | 1 +
.../core/construction/graph/GreedyStageFuser.java | 1 +
.../runners/core/construction/graph/Networks.java | 1 +
.../construction/graph/OutputDeduplicator.java | 1 +
.../core/construction/graph/QueryablePipeline.java | 1 +
.../graph/SplittableParDoExpander.java | 1 +
.../graph/TrivialNativeTransformExpander.java | 1 +
.../construction/renderer/PipelineDotRenderer.java | 1 +
.../renderer/PortablePipelineDotRenderer.java | 1 +
.../core/construction/CoderTranslationTest.java | 3 +
.../runners/core/construction/CommonCoderTest.java | 11 ++
.../construction/DefaultArtifactResolverTest.java | 1 +
.../construction/ForwardingPTransformTest.java | 1 +
.../core/construction/MorePipelineTest.java | 1 +
.../construction/PCollectionTranslationTest.java | 1 +
.../core/construction/PTransformMatchersTest.java | 4 +-
.../construction/PTransformReplacementsTest.java | 1 +
.../construction/PTransformTranslationTest.java | 1 +
.../PipelineOptionsTranslationTest.java | 1 +
.../core/construction/PipelineTranslationTest.java | 1 +
.../core/construction/ReplacementOutputsTest.java | 1 +
.../core/construction/SchemaTranslationTest.java | 1 +
.../core/construction/SdkComponentsTest.java | 1 +
.../beam/runners/core/construction/TimerTest.java | 1 +
.../core/construction/TriggerTranslationTest.java | 1 +
.../UnboundedReadFromBoundedSourceTest.java | 1 +
.../UnsupportedOverrideFactoryTest.java | 1 +
.../core/construction/ValidateRunnerXlangTest.java | 1 +
.../WindowingStrategyTranslationTest.java | 1 +
.../graph/GreedyPipelineFuserTest.java | 1 +
.../construction/graph/GreedyStageFuserTest.java | 1 +
.../construction/graph/OutputDeduplicatorTest.java | 1 +
.../ClasspathScanningResourcesDetectorTest.java | 1 +
.../resources/PipelineResourcesTest.java | 1 +
.../org/apache/beam/runners/core/DoFnRunners.java | 1 +
.../beam/runners/core/GlobalCombineFnRunners.java | 1 +
.../core/InMemoryMultimapSideInputView.java | 1 +
.../beam/runners/core/InMemoryStateInternals.java | 1 +
.../beam/runners/core/InMemoryTimerInternals.java | 1 +
.../runners/core/LateDataDroppingDoFnRunner.java | 1 +
.../apache/beam/runners/core/LateDataUtils.java | 1 +
.../beam/runners/core/MergingActiveWindowSet.java | 1 +
...TimeBoundedSplittableProcessElementInvoker.java | 1 +
.../apache/beam/runners/core/PaneInfoTracker.java | 1 +
.../beam/runners/core/PeekingReiterator.java | 1 +
.../apache/beam/runners/core/ProcessFnRunner.java | 1 +
.../beam/runners/core/ReduceFnContextFactory.java | 1 +
.../apache/beam/runners/core/ReduceFnRunner.java | 1 +
.../apache/beam/runners/core/SideInputHandler.java | 4 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 1 +
.../core/SimplePushbackSideInputDoFnRunner.java | 1 +
.../org/apache/beam/runners/core/StateMerging.java | 1 +
.../org/apache/beam/runners/core/StateTable.java | 1 +
.../beam/runners/core/StatefulDoFnRunner.java | 1 +
.../apache/beam/runners/core/SystemReduceFn.java | 1 +
.../runners/core/TestInMemoryStateInternals.java | 1 +
.../apache/beam/runners/core/WatermarkHold.java | 1 +
.../runners/core/metrics/DefaultMetricResults.java | 1 +
.../core/metrics/ExecutionStateTracker.java | 3 +-
.../runners/core/metrics/MetricsContainerImpl.java | 1 +
.../beam/runners/core/metrics/MetricsMap.java | 1 +
.../beam/runners/core/metrics/MetricsPusher.java | 1 +
.../core/metrics/MonitoringInfoMetricName.java | 1 +
.../runners/core/metrics/SimpleExecutionState.java | 1 +
.../runners/core/metrics/SimpleStateRegistry.java | 1 +
.../core/triggers/AfterAllStateMachine.java | 1 +
.../AfterDelayFromFirstElementStateMachine.java | 1 +
.../core/triggers/AfterEachStateMachine.java | 1 +
.../core/triggers/AfterFirstStateMachine.java | 1 +
.../core/triggers/AfterWatermarkStateMachine.java | 1 +
.../core/triggers/DefaultTriggerStateMachine.java | 1 +
.../triggers/ExecutableTriggerStateMachine.java | 1 +
.../core/triggers/OrFinallyStateMachine.java | 1 +
.../core/triggers/RepeatedlyStateMachine.java | 1 +
.../runners/core/triggers/TriggerStateMachine.java | 1 +
.../TriggerStateMachineContextFactory.java | 1 +
.../runners/core/InMemoryTimerInternalsTest.java | 1 +
.../core/LateDataDroppingDoFnRunnerTest.java | 1 +
...BoundedSplittableProcessElementInvokerTest.java | 1 +
.../apache/beam/runners/core/ReduceFnTester.java | 1 +
.../beam/runners/core/SideInputHandlerTest.java | 1 +
.../beam/runners/core/SimpleDoFnRunnerTest.java | 1 +
.../SimplePushbackSideInputDoFnRunnerTest.java | 1 +
.../runners/core/SplittableParDoProcessFnTest.java | 1 +
.../beam/runners/core/StateInternalsTest.java | 1 +
.../beam/runners/core/StatefulDoFnRunnerTest.java | 1 +
.../apache/beam/runners/core/WindowMatchers.java | 1 +
.../core/metrics/ExecutionStateSamplerTest.java | 1 +
.../core/metrics/ExecutionStateTrackerTest.java | 1 +
.../runners/core/metrics/LabeledMetricsTest.java | 1 +
.../runners/core/metrics/MetricUpdateMatchers.java | 1 +
.../core/metrics/MetricsContainerImplTest.java | 1 +
.../core/metrics/MetricsContainerStepMapTest.java | 1 +
.../runners/core/metrics/MetricsPusherTest.java | 1 +
.../core/metrics/MonitoringInfoMetricNameTest.java | 1 +
.../core/metrics/MonitoringInfoTestUtil.java | 1 +
.../core/metrics/SimpleExecutionStateTest.java | 1 +
.../metrics/SimpleMonitoringInfoBuilderTest.java | 1 +
.../core/metrics/SimpleStateRegistryTest.java | 1 +
.../beam/runners/core/metrics/TestMetricsSink.java | 1 +
.../core/triggers/AfterAllStateMachineTest.java | 1 +
.../core/triggers/AfterEachStateMachineTest.java | 1 +
.../core/triggers/AfterFirstStateMachineTest.java | 1 +
.../core/triggers/AfterPaneStateMachineTest.java | 1 +
.../triggers/AfterWatermarkStateMachineTest.java | 1 +
.../triggers/DefaultTriggerStateMachineTest.java | 1 +
.../core/triggers/NeverStateMachineTest.java | 1 +
.../core/triggers/OrFinallyStateMachineTest.java | 1 +
.../core/triggers/RepeatedlyStateMachineTest.java | 1 +
.../core/triggers/TriggerStateMachineTest.java | 1 +
.../core/triggers/TriggerStateMachineTester.java | 1 +
.../direct/BoundedReadEvaluatorFactory.java | 1 +
.../beam/runners/direct/CloningBundleFactory.java | 1 +
.../beam/runners/direct/CommittedResult.java | 1 +
.../direct/CopyOnAccessInMemoryStateInternals.java | 1 +
.../runners/direct/DirectExecutionContext.java | 1 +
.../apache/beam/runners/direct/DirectGraph.java | 1 +
.../beam/runners/direct/DirectGraphVisitor.java | 1 +
.../apache/beam/runners/direct/DirectMetrics.java | 1 +
.../apache/beam/runners/direct/DirectRunner.java | 1 +
.../runners/direct/DirectWriteViewVisitor.java | 1 +
.../beam/runners/direct/DisplayDataValidator.java | 1 +
.../beam/runners/direct/EvaluationContext.java | 1 +
.../direct/ExecutorServiceParallelExecutor.java | 1 +
.../direct/GroupAlsoByWindowEvaluatorFactory.java | 1 +
.../direct/GroupByKeyOnlyEvaluatorFactory.java | 1 +
.../direct/ImmutabilityCheckingBundleFactory.java | 1 +
.../direct/ImmutabilityEnforcementFactory.java | 1 +
.../runners/direct/ImmutableListBundleFactory.java | 1 +
.../runners/direct/KeyedPValueTrackingVisitor.java | 1 +
.../beam/runners/direct/MultiStepCombine.java | 1 +
.../apache/beam/runners/direct/ParDoEvaluator.java | 1 +
.../beam/runners/direct/ParDoEvaluatorFactory.java | 1 +
.../beam/runners/direct/QuiescenceDriver.java | 1 +
.../beam/runners/direct/ReadEvaluatorFactory.java | 3 +-
.../beam/runners/direct/RootProviderRegistry.java | 1 +
.../beam/runners/direct/SideInputContainer.java | 1 +
.../SplittableProcessElementsEvaluatorFactory.java | 1 +
.../direct/StatefulParDoEvaluatorFactory.java | 1 +
.../beam/runners/direct/StepTransformResult.java | 1 +
.../runners/direct/TestStreamEvaluatorFactory.java | 4 +-
.../runners/direct/TransformEvaluatorRegistry.java | 1 +
.../runners/direct/TransformExecutorServices.java | 1 +
.../direct/UnboundedReadEvaluatorFactory.java | 1 +
.../runners/direct/WatermarkCallbackExecutor.java | 1 +
.../beam/runners/direct/WatermarkManager.java | 1 +
.../runners/direct/WindowEvaluatorFactory.java | 1 +
.../direct/BoundedReadEvaluatorFactoryTest.java | 1 +
.../runners/direct/CloningBundleFactoryTest.java | 1 +
.../CopyOnAccessInMemoryStateInternalsTest.java | 1 +
.../beam/runners/direct/DirectMetricsTest.java | 1 +
.../runners/direct/DirectRunnerApiSurfaceTest.java | 1 +
.../beam/runners/direct/DirectRunnerTest.java | 1 +
.../runners/direct/DirectTimerInternalsTest.java | 1 +
.../direct/DirectTransformExecutorTest.java | 1 +
...cycleManagerRemovingTransformEvaluatorTest.java | 1 +
.../runners/direct/DoFnLifecycleManagersTest.java | 1 +
.../beam/runners/direct/EvaluationContextTest.java | 1 +
.../direct/FlattenEvaluatorFactoryTest.java | 1 +
.../direct/GroupByKeyEvaluatorFactoryTest.java | 1 +
.../direct/GroupByKeyOnlyEvaluatorFactoryTest.java | 1 +
.../ImmutabilityCheckingBundleFactoryTest.java | 1 +
.../direct/ImmutabilityEnforcementFactoryTest.java | 1 +
.../direct/ImmutableListBundleFactoryTest.java | 1 +
.../direct/KeyedPValueTrackingVisitorTest.java | 1 +
.../beam/runners/direct/ParDoEvaluatorTest.java | 1 +
.../runners/direct/SideInputContainerTest.java | 1 +
.../direct/StatefulParDoEvaluatorFactoryTest.java | 1 +
.../runners/direct/StepTransformResultTest.java | 1 +
.../direct/TestStreamEvaluatorFactoryTest.java | 1 +
.../direct/TransformExecutorServicesTest.java | 1 +
.../direct/UnboundedReadEvaluatorFactoryTest.java | 1 +
.../runners/direct/ViewEvaluatorFactoryTest.java | 1 +
.../direct/WatermarkCallbackExecutorTest.java | 1 +
.../beam/runners/direct/WatermarkManagerTest.java | 1 +
.../runners/direct/WindowEvaluatorFactoryTest.java | 1 +
.../direct/WriteWithShardingFactoryTest.java | 3 +-
.../extensions/metrics/MetricsGraphiteSink.java | 1 +
.../extensions/metrics/MetricsHttpSink.java | 1 +
.../metrics/MetricsGraphiteSinkTest.java | 1 +
.../extensions/metrics/MetricsHttpSinkTest.java | 1 +
.../extensions/metrics/NetworkMockServer.java | 1 +
.../beam/runners/flink/FlinkRunnerTestCompat.java | 1 +
.../translation/types/CoderTypeSerializer.java | 1 +
.../translation/types/CoderTypeSerializerTest.java | 1 +
.../flink/FlinkBatchPipelineTranslator.java | 1 +
.../FlinkBatchPortablePipelineTranslator.java | 1 +
.../flink/FlinkBatchTransformTranslators.java | 1 +
.../flink/FlinkBatchTranslationContext.java | 1 +
.../runners/flink/FlinkExecutionEnvironments.java | 1 +
.../apache/beam/runners/flink/FlinkJobInvoker.java | 1 +
.../beam/runners/flink/FlinkJobServerDriver.java | 1 +
.../flink/FlinkPipelineExecutionEnvironment.java | 1 +
.../beam/runners/flink/FlinkPipelineRunner.java | 1 +
.../flink/FlinkPortableClientEntryPoint.java | 1 +
.../org/apache/beam/runners/flink/FlinkRunner.java | 1 +
.../beam/runners/flink/FlinkRunnerResult.java | 1 +
.../flink/FlinkStreamingPipelineTranslator.java | 1 +
.../FlinkStreamingPortablePipelineTranslator.java | 1 +
.../flink/FlinkStreamingTransformTranslators.java | 1 +
.../flink/FlinkStreamingTranslationContext.java | 1 +
.../flink/PipelineTranslationModeOptimizer.java | 1 +
.../apache/beam/runners/flink/TestFlinkRunner.java | 1 +
.../beam/runners/flink/metrics/FileReporter.java | 1 +
.../translation/functions/FlinkAssignContext.java | 1 +
.../translation/functions/FlinkDoFnFunction.java | 1 +
.../functions/FlinkExecutableStageFunction.java | 1 +
.../FlinkExecutableStagePruningFunction.java | 1 +
.../functions/FlinkNonMergingReduceFunction.java | 1 +
.../functions/FlinkSideInputReader.java | 3 +-
.../functions/FlinkStatefulDoFnFunction.java | 1 +
.../FlinkStreamingSideInputHandlerFactory.java | 1 +
.../functions/ImpulseSourceFunction.java | 1 +
.../functions/SingleWindowFlinkCombineRunner.java | 1 +
.../functions/SortingFlinkCombineRunner.java | 1 +
.../translation/types/EncodedValueComparator.java | 1 +
.../translation/utils/CountingPipelineVisitor.java | 1 +
.../translation/wrappers/SourceInputFormat.java | 1 +
.../translation/wrappers/SourceInputSplit.java | 1 +
.../wrappers/streaming/DoFnOperator.java | 7 +-
.../streaming/ExecutableStageDoFnOperator.java | 1 +
.../wrappers/streaming/SplittableDoFnOperator.java | 1 +
.../wrappers/streaming/WindowDoFnOperator.java | 1 +
.../wrappers/streaming/io/DedupingOperator.java | 1 +
.../streaming/io/UnboundedSourceWrapper.java | 1 +
.../streaming/stableinput/BufferingDoFnRunner.java | 1 +
.../state/FlinkBroadcastStateInternals.java | 1 +
.../streaming/state/FlinkStateInternals.java | 1 +
.../flink/FlinkExecutionEnvironmentsTest.java | 1 +
.../FlinkPipelineExecutionEnvironmentTest.java | 1 +
.../runners/flink/FlinkPipelineOptionsTest.java | 1 +
.../flink/FlinkRequiresStableInputTest.java | 1 +
.../apache/beam/runners/flink/FlinkRunnerTest.java | 1 +
.../beam/runners/flink/FlinkSavepointTest.java | 1 +
.../FlinkStreamingTransformTranslatorsTest.java | 1 +
.../beam/runners/flink/FlinkSubmissionTest.java | 1 +
.../runners/flink/FlinkTransformOverridesTest.java | 4 +-
.../beam/runners/flink/PortableExecutionTest.java | 1 +
.../runners/flink/PortableStateExecutionTest.java | 1 +
.../runners/flink/PortableTimersExecutionTest.java | 1 +
.../beam/runners/flink/ReadSourcePortableTest.java | 1 +
.../runners/flink/ReadSourceStreamingTest.java | 1 +
.../apache/beam/runners/flink/ReadSourceTest.java | 1 +
.../flink/batch/NonMergingGroupByKeyTest.java | 1 +
.../beam/runners/flink/batch/ReshuffleTest.java | 1 +
.../flink/metrics/FlinkMetricContainerTest.java | 1 +
.../FlinkBroadcastStateInternalsTest.java | 1 +
.../flink/streaming/FlinkStateInternalsTest.java | 1 +
.../flink/streaming/GroupByNullKeyTest.java | 1 +
.../flink/streaming/GroupByWithNullValuesTest.java | 1 +
.../flink/streaming/TopWikipediaSessionsTest.java | 1 +
.../functions/FlinkDoFnFunctionTest.java | 1 +
.../FlinkExecutableStageFunctionTest.java | 1 +
.../functions/FlinkStatefulDoFnFunctionTest.java | 1 +
.../wrappers/streaming/DoFnOperatorTest.java | 4 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 1 +
.../wrappers/streaming/StreamRecordStripper.java | 4 +-
.../wrappers/streaming/WindowDoFnOperatorTest.java | 1 +
.../wrappers/streaming/io/TestCountingSource.java | 1 +
.../streaming/io/UnboundedSourceWrapperTest.java | 1 +
.../beam/runners/dataflow/BatchViewOverrides.java | 1 +
.../beam/runners/dataflow/CreateDataflowView.java | 1 +
.../beam/runners/dataflow/DataflowClient.java | 1 +
.../beam/runners/dataflow/DataflowMetrics.java | 1 +
.../dataflow/DataflowPTransformMatchers.java | 1 +
.../beam/runners/dataflow/DataflowPipelineJob.java | 9 +-
.../dataflow/DataflowPipelineTranslator.java | 6 +-
.../beam/runners/dataflow/DataflowRunner.java | 1 +
.../beam/runners/dataflow/DataflowRunnerInfo.java | 1 +
.../dataflow/PrimitiveParDoSingleFactory.java | 1 +
.../beam/runners/dataflow/TestDataflowRunner.java | 3 +-
.../beam/runners/dataflow/internal/IsmFormat.java | 1 +
.../dataflow/options/DataflowPipelineOptions.java | 1 +
.../dataflow/options/DefaultGcpRegionFactory.java | 1 +
.../beam/runners/dataflow/util/CloudKnownType.java | 5 +-
.../beam/runners/dataflow/util/CloudObject.java | 1 +
.../dataflow/util/CloudObjectTranslators.java | 1 +
.../beam/runners/dataflow/util/CloudObjects.java | 1 +
.../runners/dataflow/util/DataflowTemplateJob.java | 3 +-
.../beam/runners/dataflow/util/PackageUtil.java | 1 +
.../runners/dataflow/util/RandomAccessData.java | 1 +
.../apache/beam/runners/dataflow/util/Structs.java | 1 +
.../beam/runners/dataflow/util/TimeUtil.java | 1 +
.../dataflow/BatchStatefulParDoOverridesTest.java | 1 +
.../beam/runners/dataflow/DataflowMetricsTest.java | 1 +
.../dataflow/DataflowPTransformMatchersTest.java | 1 +
.../runners/dataflow/DataflowPipelineJobTest.java | 1 +
.../dataflow/DataflowPipelineTranslatorTest.java | 1 +
.../runners/dataflow/DataflowRunnerInfoTest.java | 1 +
.../beam/runners/dataflow/DataflowRunnerTest.java | 4 +-
.../runners/dataflow/RecordingPipelineVisitor.java | 1 +
.../runners/dataflow/TestDataflowRunnerTest.java | 1 +
.../options/DataflowPipelineOptionsTest.java | 1 +
.../options/DataflowWorkerLoggingOptionsTest.java | 1 +
.../transforms/DataflowGroupByKeyTest.java | 1 +
.../dataflow/transforms/DataflowViewTest.java | 1 +
.../runners/dataflow/util/CloudObjectsTest.java | 1 +
.../runners/dataflow/util/MonitoringUtilTest.java | 1 +
.../runners/dataflow/util/PackageUtilTest.java | 1 +
.../beam/runners/dataflow/util/StructsTest.java | 1 +
.../beam/runners/dataflow/util/TimeUtilTest.java | 1 +
.../dataflow/worker/ApplianceShuffleReader.java | 1 +
.../dataflow/worker/ApplianceShuffleWriter.java | 1 +
.../runners/dataflow/worker/AvroByteReader.java | 1 +
.../dataflow/worker/AvroByteReaderFactory.java | 1 +
.../dataflow/worker/BatchDataflowWorker.java | 1 +
.../dataflow/worker/BatchModeExecutionContext.java | 7 +-
.../worker/BatchModeUngroupingParDoFn.java | 1 +
.../worker/BeamFnMapTaskExecutorFactory.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 +
.../worker/DataflowElementExecutionTracker.java | 1 +
.../dataflow/worker/DataflowExecutionContext.java | 1 +
.../worker/DataflowExecutionStateRegistry.java | 1 +
.../dataflow/worker/DataflowMetricsContainer.java | 1 +
.../dataflow/worker/DataflowOperationContext.java | 1 +
.../dataflow/worker/DataflowOutputCounter.java | 1 +
.../worker/DataflowPortabilityPCollectionView.java | 3 +-
.../dataflow/worker/DataflowProcessFnRunner.java | 1 +
.../dataflow/worker/DataflowRunnerHarness.java | 1 +
.../worker/DataflowSideInputReadCounter.java | 1 +
.../worker/DataflowWorkProgressUpdater.java | 1 +
.../dataflow/worker/DataflowWorkUnitClient.java | 1 +
.../worker/DataflowWorkerHarnessHelper.java | 1 +
.../dataflow/worker/DoFnInstanceManagers.java | 1 +
.../runners/dataflow/worker/ExperimentContext.java | 1 +
...FetchAndFilterStreamingSideInputsOperation.java | 4 +-
.../beam/runners/dataflow/worker/Filepatterns.java | 1 +
.../dataflow/worker/FnApiWindowMappingFn.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 | 4 +-
.../dataflow/worker/InMemoryReaderFactory.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 +
.../dataflow/worker/KeyTokenInvalidException.java | 1 +
.../worker/LazilyInitializedSideInputReader.java | 3 +-
.../worker/MetricTrackingWindmillServerStub.java | 1 +
.../worker/MetricsToCounterUpdateConverter.java | 1 +
.../worker/NoOpSourceOperationExecutor.java | 1 +
.../worker/PairWithConstantKeyDoFnFactory.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/ReaderRegistry.java | 1 +
.../ReifyTimestampAndWindowsParDoFnFactory.java | 1 +
...HarnessCoderCloudObjectTranslatorRegistrar.java | 1 +
.../dataflow/worker/SdkHarnessRegistries.java | 19 +--
.../runners/dataflow/worker/ShuffleLibrary.java | 1 +
.../beam/runners/dataflow/worker/ShuffleSink.java | 1 +
.../dataflow/worker/ShuffleSinkFactory.java | 1 +
.../runners/dataflow/worker/SimpleParDoFn.java | 3 +-
.../beam/runners/dataflow/worker/SinkRegistry.java | 1 +
.../dataflow/worker/SourceTranslationUtils.java | 1 +
.../beam/runners/dataflow/worker/StateFetcher.java | 1 +
.../dataflow/worker/StreamingDataflowWorker.java | 1 +
.../StreamingKeyedWorkItemSideInputDoFnRunner.java | 1 +
.../worker/StreamingModeExecutionContext.java | 4 +-
.../StreamingPCollectionViewWriterParDoFn.java | 1 +
.../dataflow/worker/StreamingSideInputFetcher.java | 1 +
.../worker/StreamingStepMetricsContainer.java | 1 +
.../worker/ToIsmRecordForMultimapDoFnFactory.java | 1 +
.../dataflow/worker/UngroupedShuffleReader.java | 1 +
.../worker/UngroupedShuffleReaderFactory.java | 1 +
.../dataflow/worker/UngroupedWindmillReader.java | 1 +
.../dataflow/worker/UserParDoFnFactory.java | 1 +
.../runners/dataflow/worker/ValuesDoFnFactory.java | 1 +
.../dataflow/worker/WindmillKeyedWorkItem.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/WindmillStateReader.java | 1 +
.../dataflow/worker/WindmillTimerInternals.java | 1 +
.../dataflow/worker/WindowingWindmillReader.java | 1 +
.../dataflow/worker/WorkItemStatusClient.java | 3 +-
.../WorkerCustomSourceOperationExecutor.java | 1 +
.../dataflow/worker/WorkerCustomSources.java | 4 +-
.../worker/WorkerPipelineOptionsFactory.java | 1 +
.../dataflow/worker/counters/CounterFactory.java | 1 +
.../dataflow/worker/counters/CounterName.java | 1 +
.../dataflow/worker/counters/CounterSet.java | 1 +
.../counters/DataflowCounterUpdateExtractor.java | 1 +
.../DistributionCounterUpdateAggregator.java | 1 +
.../counters/MeanCounterUpdateAggregator.java | 1 +
.../counters/SumCounterUpdateAggregator.java | 1 +
.../worker/fn/control/BeamFnMapTaskExecutor.java | 28 ++--
.../control/DataflowSideInputHandlerFactory.java | 1 +
...ntMonitoringInfoToCounterUpdateTransformer.java | 1 +
...meMonitoringInfoToCounterUpdateTransformer.java | 1 +
...ntMonitoringInfoToCounterUpdateTransformer.java | 1 +
.../fn/control/ProcessRemoteBundleOperation.java | 1 +
.../control/RegisterAndProcessBundleOperation.java | 1 +
...onMonitoringInfoToCounterUpdateTransformer.java | 1 +
...erMonitoringInfoToCounterUpdateTransformer.java | 1 +
.../fn/data/RemoteGrpcPortReadOperation.java | 1 +
.../fn/data/RemoteGrpcPortWriteOperation.java | 1 +
.../worker/fn/logging/BeamFnLoggingService.java | 1 +
.../fn/stream/ServerStreamObserverFactory.java | 1 +
.../graph/CreateExecutableStageNodeFunction.java | 1 +
.../graph/DeduceFlattenLocationsFunction.java | 1 +
.../beam/runners/dataflow/worker/graph/Edges.java | 1 +
...nsertFetchAndFilterStreamingSideInputNodes.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 +
.../graph/ReplacePgbkWithPrecombineFunction.java | 1 +
.../logging/DataflowWorkerLoggingHandler.java | 1 +
.../logging/DataflowWorkerLoggingInitializer.java | 1 +
.../worker/logging/DataflowWorkerLoggingMDC.java | 1 +
.../JulHandlerPrintStreamAdapterFactory.java | 1 +
.../options/StreamingDataflowWorkerOptions.java | 1 +
.../dataflow/worker/profiler/ScopedProfiler.java | 1 +
.../dataflow/worker/status/DebugCapture.java | 1 +
.../dataflow/worker/status/WorkerStatusPages.java | 1 +
.../dataflow/worker/util/BoundedQueueExecutor.java | 1 +
.../dataflow/worker/util/CloudSourceUtils.java | 1 +
.../dataflow/worker/util/MemoryMonitor.java | 1 +
.../dataflow/worker/util/TimerOrElement.java | 1 +
.../worker/util/common/TaggedReiteratorList.java | 1 +
.../common/worker/BatchingShuffleEntryReader.java | 1 +
.../common/worker/ByteArrayShufflePosition.java | 1 +
.../common/worker/CachingShuffleBatchReader.java | 1 +
.../worker/GroupingShuffleEntryIterator.java | 1 +
.../common/worker/GroupingShuffleRangeTracker.java | 1 +
.../worker/util/common/worker/GroupingTables.java | 1 +
.../worker/util/common/worker/MapTaskExecutor.java | 1 +
.../common/worker/OutputObjectAndByteCounter.java | 1 +
.../worker/util/common/worker/ReadOperation.java | 1 +
.../worker/util/common/worker/ShuffleEntry.java | 1 +
.../util/common/worker/ShuffleReadCounter.java | 1 +
.../worker/util/common/worker/WorkExecutor.java | 1 +
.../util/common/worker/WorkProgressUpdater.java | 1 +
.../worker/util/common/worker/WriteOperation.java | 1 +
.../worker/windmill/GrpcWindmillServer.java | 1 +
.../dataflow/worker/windmill/WindmillServer.java | 1 +
.../worker/windmill/WindmillServerBase.java | 1 +
.../worker/windmill/WindmillServerStub.java | 1 +
.../dataflow/harness/test/TestExecutors.java | 1 +
.../dataflow/harness/test/TestExecutorsTest.java | 5 +-
.../dataflow/harness/test/TestStreamsTest.java | 1 +
.../worker/ApplianceShuffleCountersTest.java | 1 +
.../dataflow/worker/AvroByteReaderFactoryTest.java | 5 +-
.../dataflow/worker/AvroByteReaderTest.java | 1 +
.../dataflow/worker/BatchDataflowWorkerTest.java | 1 +
.../worker/BatchModeExecutionContextTest.java | 1 +
.../dataflow/worker/ConcatReaderFactoryTest.java | 1 +
.../runners/dataflow/worker/ConcatReaderTest.java | 1 +
...CreateIsmShardKeyAndSortKeyDoFnFactoryTest.java | 1 +
.../worker/DataflowBatchWorkerHarnessTest.java | 1 +
.../DataflowElementExecutionTrackerTest.java | 1 +
.../worker/DataflowExecutionStateTrackerTest.java | 1 +
.../worker/DataflowOperationContextTest.java | 4 +-
.../worker/DataflowWorkProgressUpdaterTest.java | 1 +
.../worker/DataflowWorkUnitClientTest.java | 1 +
.../worker/DataflowWorkerHarnessHelperTest.java | 1 +
.../dataflow/worker/DefaultParDoFnFactoryTest.java | 1 +
.../dataflow/worker/DeltaCounterCellTest.java | 1 +
.../dataflow/worker/DoFnInstanceManagersTest.java | 1 +
.../dataflow/worker/FakeWindmillServer.java | 1 +
.../dataflow/worker/FnApiWindowMappingFnTest.java | 1 +
.../dataflow/worker/GroupingShuffleReaderTest.java | 1 +
.../runners/dataflow/worker/HotKeyLoggerTest.java | 1 +
.../dataflow/worker/InMemoryReaderFactoryTest.java | 1 +
.../IntrinsicMapTaskExecutorFactoryTest.java | 1 +
.../worker/IntrinsicMapTaskExecutorTest.java | 1 +
.../dataflow/worker/IsmReaderFactoryTest.java | 1 +
.../runners/dataflow/worker/IsmReaderTest.java | 1 +
.../dataflow/worker/IsmSideInputReaderTest.java | 1 +
.../LazilyInitializedSideInputReaderTest.java | 1 +
.../runners/dataflow/worker/LogRecordMatcher.java | 1 +
.../dataflow/worker/LogRecordMatcherTest.java | 5 +-
.../worker/NoOpSourceOperationExecutorTest.java | 1 +
.../worker/PairWithConstantKeyDoFnFactoryTest.java | 1 +
.../worker/PartialGroupByKeyParDoFnsTest.java | 6 +-
.../worker/PartitioningShuffleReaderTest.java | 1 +
.../runners/dataflow/worker/PubsubReaderTest.java | 1 +
.../runners/dataflow/worker/PubsubSinkTest.java | 1 +
.../runners/dataflow/worker/ReaderCacheTest.java | 1 +
.../runners/dataflow/worker/ReaderFactoryTest.java | 1 +
.../runners/dataflow/worker/ReaderTestUtils.java | 1 +
...ReifyTimestampAndWindowsParDoFnFactoryTest.java | 1 +
.../dataflow/worker/SdkHarnessRegistryTest.java | 1 +
.../dataflow/worker/ShuffleReaderFactoryTest.java | 6 +-
.../runners/dataflow/worker/ShuffleSinkTest.java | 1 +
.../runners/dataflow/worker/SimpleParDoFnTest.java | 1 +
.../worker/SourceOperationExecutorFactoryTest.java | 1 +
.../runners/dataflow/worker/StateFetcherTest.java | 1 +
.../worker/StreamingDataflowWorkerTest.java | 1 +
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 1 +
...reamingGroupAlsoByWindowsReshuffleDoFnTest.java | 1 +
...eamingKeyedWorkItemSideInputDoFnRunnerTest.java | 1 +
.../worker/StreamingModeExecutionContextTest.java | 1 +
...eamingPCollectionViewWriterDoFnFactoryTest.java | 1 +
.../worker/StreamingSideInputDoFnRunnerTest.java | 1 +
.../worker/StreamingSideInputFetcherTest.java | 1 +
.../dataflow/worker/TestOperationContext.java | 4 +-
.../worker/TestShuffleReadCounterFactory.java | 1 +
.../dataflow/worker/TestShuffleReaderTest.java | 1 +
.../ToIsmRecordForMultimapDoFnFactoryTest.java | 1 +
.../worker/UngroupedShuffleReaderTest.java | 1 +
.../dataflow/worker/UserParDoFnFactoryTest.java | 1 +
.../dataflow/worker/ValuesDoFnFactoryTest.java | 1 +
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 1 +
.../dataflow/worker/WindmillStateCacheTest.java | 1 +
.../worker/WindmillStateInternalsTest.java | 1 +
.../dataflow/worker/WindmillStateReaderTest.java | 5 +-
.../dataflow/worker/WindmillStateTestUtils.java | 1 +
.../dataflow/worker/WindmillTimeUtilsTest.java | 1 +
.../dataflow/worker/WorkItemStatusClientTest.java | 1 +
.../dataflow/worker/WorkerCustomSourcesTest.java | 1 +
.../runners/dataflow/worker/apiary/ApiaryTest.java | 1 +
.../DistributionCounterUpdateAggregatorTest.java | 1 +
.../counters/MeanCounterUpdateAggregatorTest.java | 1 +
.../counters/SumCounterUpdateAggregatorTest.java | 1 +
.../worker/fn/BeamFnControlServiceTest.java | 1 +
.../fn/control/BeamFnMapTaskExecutorTest.java | 17 +--
.../DataflowSideInputHandlerFactoryTest.java | 4 +-
...nitoringInfoToCounterUpdateTransformerTest.java | 1 +
...nitoringInfoToCounterUpdateTransformerTest.java | 1 +
...nitoringInfoToCounterUpdateTransformerTest.java | 1 +
...nitoringInfoToCounterUpdateTransformerTest.java | 1 +
.../RegisterAndProcessBundleOperationTest.java | 8 +-
.../SingularProcessBundleProgressTrackerTest.java | 1 +
...nitoringInfoToCounterUpdateTransformerTest.java | 1 +
...nitoringInfoToCounterUpdateTransformerTest.java | 1 +
.../worker/fn/data/BeamFnDataGrpcServiceTest.java | 5 +-
.../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/LengthPrefixUnknownCodersTest.java | 1 +
.../dataflow/worker/graph/NetworksTest.java | 1 +
.../runners/dataflow/worker/graph/NodesTest.java | 1 +
.../ReplacePgbkWithPrecombineFunctionTest.java | 1 +
.../logging/DataflowWorkerLoggingHandlerTest.java | 1 +
.../DataflowWorkerLoggingInitializerTest.java | 1 +
.../JulHandlerPrintStreamAdapterFactoryTest.java | 1 +
.../worker/profiler/ScopedProfilerTest.java | 1 +
.../dataflow/worker/status/DebugCaptureTest.java | 1 +
.../worker/status/WorkerStatusPagesTest.java | 1 +
.../worker/testing/GenericJsonMatcherTest.java | 1 +
.../worker/testing/RestoreDataflowLoggingMDC.java | 1 +
.../worker/testing/TestCountingSource.java | 1 +
.../worker/util/CounterHamcrestMatchers.java | 1 +
.../worker/util/GroupAlsoByWindowProperties.java | 1 +
.../dataflow/worker/util/MemoryMonitorTest.java | 1 +
.../util/common/TaggedReiteratorListTest.java | 1 +
.../worker/BatchingShuffleEntryReaderTest.java | 1 +
.../util/common/worker/ExecutorTestUtils.java | 6 +-
.../worker/GroupingShuffleEntryIteratorTest.java | 1 +
.../util/common/worker/GroupingTablesTest.java | 1 +
.../util/common/worker/MapTaskExecutorTest.java | 1 +
.../worker/OutputObjectAndByteCounterTest.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 +
.../worker/windmill/GrpcWindmillServerTest.java | 1 +
.../GrpcContextHeaderAccessorProvider.java | 1 +
.../beam/runners/fnexecution/GrpcFnServer.java | 1 +
.../artifact/ArtifactRetrievalService.java | 1 +
.../artifact/ArtifactStagingService.java | 1 +
.../control/DefaultJobBundleFactory.java | 1 +
.../fnexecution/control/FnApiControlClient.java | 1 +
.../control/ProcessBundleDescriptors.java | 1 +
...renceCountingExecutableStageContextFactory.java | 1 +
.../fnexecution/control/SdkHarnessClient.java | 1 +
.../fnexecution/control/StageBundleFactory.java | 1 +
.../fnexecution/control/TimerReceiverFactory.java | 1 +
.../runners/fnexecution/data/GrpcDataService.java | 1 +
.../fnexecution/environment/DockerCommand.java | 1 +
.../environment/EmbeddedEnvironmentFactory.java | 1 +
.../fnexecution/environment/ProcessManager.java | 1 +
.../fnexecution/logging/GrpcLoggingService.java | 1 +
.../provisioning/StaticGrpcProvisionService.java | 1 +
.../state/InMemoryBagUserStateFactory.java | 1 +
.../fnexecution/state/StateRequestHandlers.java | 1 +
.../translation/BatchSideInputHandlerFactory.java | 1 +
.../translation/PipelineTranslatorUtils.java | 1 +
.../runners/fnexecution/EmbeddedSdkHarness.java | 1 +
.../artifact/ArtifactRetrievalServiceTest.java | 1 +
.../artifact/ArtifactStagingServiceTest.java | 1 +
.../control/DefaultJobBundleFactoryTest.java | 1 +
.../control/FnApiControlClientPoolServiceTest.java | 1 +
.../control/FnApiControlClientTest.java | 1 +
.../control/ProcessBundleDescriptorsTest.java | 1 +
.../fnexecution/control/RemoteExecutionTest.java | 1 +
.../fnexecution/control/SdkHarnessClientTest.java | 1 +
...gleEnvironmentInstanceJobBundleFactoryTest.java | 1 +
.../environment/DockerEnvironmentFactoryTest.java | 1 +
.../environment/ProcessEnvironmentFactoryTest.java | 1 +
.../environment/ProcessManagerTest.java | 1 +
.../fnexecution/state/GrpcStateServiceTest.java | 1 +
.../status/BeamWorkerStatusGrpcServiceTest.java | 1 +
.../fnexecution/status/WorkerStatusClientTest.java | 1 +
.../BatchSideInputHandlerFactoryTest.java | 1 +
.../wire/LengthPrefixUnknownCodersTest.java | 1 +
.../runners/jobsubmission/InMemoryJobService.java | 1 +
.../beam/runners/jobsubmission/JobInvocation.java | 1 +
.../beam/runners/jobsubmission/JobInvoker.java | 1 +
.../runners/jobsubmission/JobServerDriver.java | 1 +
.../jobsubmission/PortablePipelineJarCreator.java | 1 +
.../jobsubmission/PortablePipelineJarUtils.java | 1 +
.../jobsubmission/InMemoryJobServiceTest.java | 1 +
.../runners/jobsubmission/JobInvocationTest.java | 1 +
.../PortablePipelineJarCreatorTest.java | 1 +
.../org/apache/beam/runners/jet/DAGBuilder.java | 1 +
.../apache/beam/runners/jet/JetGraphVisitor.java | 1 +
.../apache/beam/runners/jet/JetPipelineResult.java | 1 +
.../beam/runners/jet/JetTransformTranslators.java | 5 +-
.../java/org/apache/beam/runners/jet/Utils.java | 1 +
.../beam/runners/jet/metrics/JetMetricResults.java | 1 +
.../runners/jet/processors/AbstractParDoP.java | 1 +
.../beam/runners/jet/processors/AssignWindowP.java | 1 +
.../runners/jet/processors/BoundedSourceP.java | 1 +
.../beam/runners/jet/processors/FlattenP.java | 1 +
.../beam/runners/jet/processors/ImpulseP.java | 1 +
.../runners/jet/processors/StatefulParDoP.java | 1 +
.../runners/jet/processors/UnboundedSourceP.java | 1 +
.../apache/beam/runners/jet/processors/ViewP.java | 1 +
.../beam/runners/jet/processors/WindowGroupP.java | 1 +
.../org/apache/beam/runners/jet/TestJetRunner.java | 1 +
.../org/apache/beam/runners/jet/TestStreamP.java | 1 +
.../runners/portability/CloseableResource.java | 1 +
.../portability/JobServicePipelineResult.java | 1 +
.../beam/runners/portability/PortableMetrics.java | 1 +
.../beam/runners/portability/PortableRunner.java | 1 +
.../beam/runners/samza/SamzaExecutionContext.java | 1 +
.../beam/runners/samza/SamzaJobServerDriver.java | 1 +
.../beam/runners/samza/SamzaPipelineResult.java | 1 +
.../org/apache/beam/runners/samza/SamzaRunner.java | 1 +
.../runners/samza/SamzaRunnerOverrideConfigs.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/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 | 7 +-
.../beam/runners/samza/runtime/KeyedTimerData.java | 1 +
.../beam/runners/samza/runtime/OpAdapter.java | 1 +
.../beam/runners/samza/runtime/OpMessage.java | 1 +
.../runners/samza/runtime/SamzaAssignContext.java | 1 +
.../runners/samza/runtime/SamzaDoFnRunners.java | 1 +
.../samza/runtime/SamzaStoreStateInternals.java | 1 +
.../samza/runtime/SamzaTimerInternalsFactory.java | 1 +
.../SplittableParDoProcessKeyedElementsOp.java | 1 +
.../runners/samza/translation/ConfigBuilder.java | 1 +
.../runners/samza/translation/ConfigContext.java | 1 +
.../samza/translation/GroupByKeyTranslator.java | 1 +
.../runners/samza/translation/PViewToIdMapper.java | 1 +
.../translation/ParDoBoundMultiTranslator.java | 1 +
.../translation/PortableTranslationContext.java | 1 +
.../translation/SamzaImpulseSystemFactory.java | 1 +
.../samza/translation/SamzaPipelineTranslator.java | 1 +
.../SamzaPortablePipelineTranslator.java | 1 +
.../translation/SplittableParDoTranslators.java | 1 +
.../samza/translation/TranslationContext.java | 1 +
.../beam/runners/samza/util/SamzaCoders.java | 1 +
.../samza/adapter/BoundedSourceSystemTest.java | 1 +
.../runners/samza/adapter/TestSourceHelpers.java | 1 +
.../runners/samza/adapter/TestUnboundedSource.java | 1 +
.../samza/adapter/UnboundedSourceSystemTest.java | 1 +
.../runtime/SamzaStoreStateInternalsTest.java | 1 +
.../runtime/SamzaTimerInternalsFactoryTest.java | 1 +
.../samza/translation/ConfigGeneratorTest.java | 1 +
.../samza/translation/SamzaImpulseSystemTest.java | 1 +
.../runners/samza/util/TestHashIdGenerator.java | 1 +
.../apache/beam/runners/spark/SparkJobInvoker.java | 1 +
.../runners/spark/SparkNativePipelineVisitor.java | 1 +
.../beam/runners/spark/SparkPipelineResult.java | 1 +
.../beam/runners/spark/SparkPipelineRunner.java | 1 +
.../org/apache/beam/runners/spark/SparkRunner.java | 1 +
.../beam/runners/spark/SparkRunnerDebugger.java | 1 +
.../apache/beam/runners/spark/TestSparkRunner.java | 1 +
.../spark/aggregators/AggregatorsAccumulator.java | 1 +
.../spark/aggregators/NamedAggregators.java | 1 +
.../beam/runners/spark/coders/CoderHelpers.java | 1 +
.../spark/coders/StatelessJavaSerializer.java | 1 +
.../apache/beam/runners/spark/io/CreateStream.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/MetricsAccumulator.java | 1 +
.../runners/spark/metrics/WithMetricsSupport.java | 1 +
.../SparkGroupAlsoByWindowViaWindowSet.java | 1 +
.../spark/stateful/SparkStateInternals.java | 1 +
.../spark/stateful/SparkTimerInternals.java | 7 +-
.../runners/spark/stateful/StateSpecFunctions.java | 1 +
.../SparkStructuredStreamingPipelineResult.java | 1 +
.../SparkStructuredStreamingRunner.java | 1 +
.../aggregators/AggregatorsAccumulator.java | 1 +
.../aggregators/NamedAggregators.java | 1 +
.../metrics/MetricsAccumulator.java | 1 +
.../metrics/WithMetricsSupport.java | 1 +
.../translation/PipelineTranslator.java | 1 +
.../translation/TranslationContext.java | 1 +
.../translation/batch/DoFnFunction.java | 1 +
.../translation/batch/FlattenTranslatorBatch.java | 1 +
.../translation/batch/ParDoTranslatorBatch.java | 1 +
.../translation/batch/PipelineTranslatorBatch.java | 1 +
.../batch/WindowAssignTranslatorBatch.java | 1 +
.../batch/functions/SparkSideInputReader.java | 4 +-
.../translation/helpers/EncoderHelpers.java | 1 +
.../translation/helpers/MultiOuputCoder.java | 1 +
.../translation/helpers/SideInputBroadcast.java | 1 +
.../streaming/PipelineTranslatorStreaming.java | 1 +
.../translation/utils/CachedSideInputReader.java | 4 +-
.../translation/utils/SideInputStorage.java | 1 +
.../runners/spark/translation/BoundedDataset.java | 1 +
.../spark/translation/EvaluationContext.java | 1 +
.../GroupNonMergingWindowsFunctions.java | 1 +
.../spark/translation/MultiDoFnFunction.java | 1 +
.../SparkBatchPortablePipelineTranslator.java | 1 +
.../spark/translation/SparkContextFactory.java | 1 +
.../SparkExecutableStageExtractionFunction.java | 1 +
.../translation/SparkExecutableStageFunction.java | 1 +
.../spark/translation/SparkPCollectionView.java | 1 +
.../SparkStreamingPortablePipelineTranslator.java | 1 +
.../spark/translation/SparkTranslationContext.java | 1 +
.../spark/translation/TransformTranslator.java | 1 +
.../spark/translation/TranslationUtils.java | 1 +
.../translation/ValueAndCoderLazySerializable.java | 1 +
.../spark/translation/streaming/Checkpoint.java | 1 +
.../streaming/StreamingTransformTranslator.java | 1 +
.../streaming/WatermarkSyncedDStream.java | 1 +
.../runners/spark/util/CachedSideInputReader.java | 4 +-
.../runners/spark/util/GlobalWatermarkHolder.java | 1 +
.../runners/spark/util/SideInputBroadcast.java | 1 +
.../beam/runners/spark/util/SideInputStorage.java | 1 +
.../beam/runners/spark/util/SparkCompat.java | 1 +
.../runners/spark/util/SparkSideInputReader.java | 4 +-
.../org/apache/beam/runners/spark/CacheTest.java | 1 +
.../runners/spark/GlobalWatermarkHolderTest.java | 1 +
.../runners/spark/ProvidedSparkContextTest.java | 1 +
.../beam/runners/spark/SparkPipelineStateTest.java | 1 +
.../aggregators/metrics/sink/InMemoryMetrics.java | 1 +
.../beam/runners/spark/io/AvroPipelineTest.java | 1 +
.../beam/runners/spark/io/NumShardsTest.java | 1 +
.../spark/io/ReaderToIteratorAdapterTest.java | 1 +
.../StructuredStreamingPipelineStateTest.java | 1 +
.../aggregators/metrics/sink/InMemoryMetrics.java | 1 +
.../metrics/sink/SparkMetricsSinkTest.java | 1 +
.../translation/batch/CombineTest.java | 1 +
.../translation/batch/ComplexSourceTest.java | 1 +
.../translation/batch/FlattenTest.java | 1 +
.../translation/batch/GroupByKeyTest.java | 1 +
.../translation/batch/ParDoTest.java | 1 +
.../translation/batch/SimpleSourceTest.java | 1 +
.../translation/batch/WindowAssignTest.java | 1 +
.../translation/streaming/SimpleSourceTest.java | 1 +
.../utils/SerializationDebugger.java | 1 +
.../SparkExecutableStageFunctionTest.java | 1 +
.../ResumeFromCheckpointStreamingTest.java | 1 +
.../streaming/TrackStreamingSourcesTest.java | 1 +
.../streaming/utils/EmbeddedKafkaCluster.java | 1 +
.../runners/twister2/BeamBatchTSetEnvironment.java | 1 +
.../beam/runners/twister2/BeamBatchWorker.java | 1 +
.../Twister2PipelineExecutionEnvironment.java | 1 +
.../runners/twister2/Twister2PipelineResult.java | 1 +
.../beam/runners/twister2/Twister2Runner.java | 1 +
.../beam/runners/twister2/Twister2TestRunner.java | 1 +
.../twister2/Twister2TranslationContext.java | 1 +
.../wrappers/Twister2BoundedSource.java | 1 +
.../translation/wrappers/Twister2EmptySource.java | 1 +
.../Twister2BatchPipelineTranslator.java | 1 +
.../batch/ParDoMultiOutputTranslatorBatch.java | 1 +
.../functions/AssignWindowsFunction.java | 1 +
.../functions/ByteToWindowFunction.java | 1 +
.../functions/ByteToWindowFunctionPrimitive.java | 1 +
.../translators/functions/DoFnFunction.java | 1 +
.../functions/GroupByWindowFunction.java | 1 +
.../translators/functions/MapToTupleFunction.java | 1 +
.../translators/functions/OutputTagFilter.java | 1 +
.../functions/Twister2SinkFunction.java | 1 +
.../internal/SystemReduceFnBuffering.java | 1 +
.../runners/twister2/utils/TranslationUtils.java | 1 +
.../twister2/utils/Twister2AssignContext.java | 1 +
.../twister2/utils/Twister2SideInputReader.java | 4 +-
.../go/test/regression/coders/fromyaml/fromyaml.go | 1 +
.../main/java/org/apache/beam/sdk/Pipeline.java | 1 +
.../org/apache/beam/sdk/coders/AtomicCoder.java | 1 +
.../java/org/apache/beam/sdk/coders/AvroCoder.java | 1 +
.../org/apache/beam/sdk/coders/CoderProviders.java | 1 +
.../org/apache/beam/sdk/coders/CoderRegistry.java | 1 +
.../org/apache/beam/sdk/coders/DefaultCoder.java | 5 +-
.../org/apache/beam/sdk/coders/NullableCoder.java | 3 +-
.../apache/beam/sdk/coders/RowCoderGenerator.java | 1 +
.../beam/sdk/coders/StringDelegateCoder.java | 1 +
.../main/java/org/apache/beam/sdk/io/AvroIO.java | 4 +-
.../apache/beam/sdk/io/AvroSchemaIOProvider.java | 1 +
.../main/java/org/apache/beam/sdk/io/AvroSink.java | 1 +
.../java/org/apache/beam/sdk/io/AvroSource.java | 1 +
.../org/apache/beam/sdk/io/BlockBasedSource.java | 1 +
.../sdk/io/BoundedReadFromUnboundedSource.java | 1 +
.../apache/beam/sdk/io/ClassLoaderFileSystem.java | 4 +-
.../org/apache/beam/sdk/io/CompressedSource.java | 5 +-
.../beam/sdk/io/ConstantAvroDestination.java | 1 +
.../org/apache/beam/sdk/io/CountingSource.java | 1 +
.../apache/beam/sdk/io/DefaultFilenamePolicy.java | 1 +
.../beam/sdk/io/DynamicFileDestinations.java | 4 +-
.../java/org/apache/beam/sdk/io/FileBasedSink.java | 1 +
.../org/apache/beam/sdk/io/FileBasedSource.java | 1 +
.../main/java/org/apache/beam/sdk/io/FileIO.java | 7 +-
.../java/org/apache/beam/sdk/io/FileSystems.java | 1 +
.../org/apache/beam/sdk/io/GenerateSequence.java | 1 +
.../org/apache/beam/sdk/io/LocalFileSystem.java | 1 +
.../org/apache/beam/sdk/io/LocalResourceId.java | 2 +-
.../org/apache/beam/sdk/io/OffsetBasedSource.java | 1 +
.../src/main/java/org/apache/beam/sdk/io/Read.java | 1 +
.../beam/sdk/io/SerializableAvroCodecFactory.java | 1 +
.../java/org/apache/beam/sdk/io/TFRecordIO.java | 1 +
.../main/java/org/apache/beam/sdk/io/TextIO.java | 1 +
.../apache/beam/sdk/io/TextRowCountEstimator.java | 1 +
.../main/java/org/apache/beam/sdk/io/TextSink.java | 1 +
.../java/org/apache/beam/sdk/io/TextSource.java | 1 +
.../java/org/apache/beam/sdk/io/WriteFiles.java | 1 +
.../apache/beam/sdk/io/fs/ResourceIdTester.java | 1 +
.../beam/sdk/io/range/ByteKeyRangeTracker.java | 1 +
.../beam/sdk/io/range/OffsetRangeTracker.java | 1 +
.../org/apache/beam/sdk/metrics/MetricResult.java | 1 +
.../beam/sdk/options/ExperimentalOptions.java | 1 +
.../beam/sdk/options/PipelineOptionsFactory.java | 1 +
.../beam/sdk/options/PipelineOptionsValidator.java | 1 +
.../beam/sdk/options/ProxyInvocationHandler.java | 1 +
.../org/apache/beam/sdk/options/ValueProvider.java | 1 +
.../beam/sdk/runners/TransformHierarchy.java | 1 +
.../apache/beam/sdk/schemas/AutoValueSchema.java | 4 +-
.../apache/beam/sdk/schemas/CachingFactory.java | 1 +
.../beam/sdk/schemas/FieldAccessDescriptor.java | 2 +
.../beam/sdk/schemas/FieldTypeDescriptors.java | 1 +
.../sdk/schemas/FieldValueTypeInformation.java | 1 +
.../beam/sdk/schemas/FromRowUsingCreator.java | 1 +
.../sdk/schemas/GetterBasedSchemaProvider.java | 1 +
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 1 +
.../apache/beam/sdk/schemas/JavaFieldSchema.java | 1 +
.../java/org/apache/beam/sdk/schemas/Schema.java | 1 +
.../org/apache/beam/sdk/schemas/SchemaCoder.java | 1 +
.../beam/sdk/schemas/SchemaCoderHelpers.java | 1 +
.../apache/beam/sdk/schemas/SchemaRegistry.java | 12 +-
.../apache/beam/sdk/schemas/SchemaTranslation.java | 1 +
.../org/apache/beam/sdk/schemas/SchemaUtils.java | 1 +
.../sdk/schemas/annotations/DefaultSchema.java | 5 +-
.../apache/beam/sdk/schemas/logicaltypes/Date.java | 1 +
.../beam/sdk/schemas/logicaltypes/DateTime.java | 1 +
.../sdk/schemas/logicaltypes/EnumerationType.java | 1 +
.../sdk/schemas/logicaltypes/MicrosInstant.java | 1 +
.../sdk/schemas/logicaltypes/NanosDuration.java | 1 +
.../sdk/schemas/logicaltypes/NanosInstant.java | 1 +
.../beam/sdk/schemas/logicaltypes/OneOfType.java | 1 +
.../logicaltypes/PassThroughLogicalType.java | 1 +
.../apache/beam/sdk/schemas/logicaltypes/Time.java | 1 +
.../parser/FieldAccessDescriptorParser.java | 1 +
.../beam/sdk/schemas/transforms/AddFields.java | 1 +
.../apache/beam/sdk/schemas/transforms/Cast.java | 1 +
.../beam/sdk/schemas/transforms/CoGroup.java | 1 +
.../beam/sdk/schemas/transforms/Convert.java | 1 +
.../beam/sdk/schemas/transforms/DropFields.java | 1 +
.../apache/beam/sdk/schemas/transforms/Filter.java | 1 +
.../apache/beam/sdk/schemas/transforms/Group.java | 1 +
.../apache/beam/sdk/schemas/transforms/Join.java | 1 +
.../beam/sdk/schemas/transforms/RenameFields.java | 1 +
.../sdk/schemas/transforms/SchemaAggregateFn.java | 1 +
.../apache/beam/sdk/schemas/transforms/Select.java | 1 +
.../beam/sdk/schemas/utils/AutoValueUtils.java | 1 +
.../beam/sdk/schemas/utils/AvroByteBuddyUtils.java | 1 +
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 1 +
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 1 +
.../beam/sdk/schemas/utils/ConvertHelpers.java | 1 +
.../beam/sdk/schemas/utils/JavaBeanUtils.java | 1 +
.../apache/beam/sdk/schemas/utils/POJOUtils.java | 1 +
.../beam/sdk/schemas/utils/ReflectUtils.java | 1 +
.../beam/sdk/schemas/utils/SchemaZipFold.java | 1 +
.../sdk/schemas/utils/SelectByteBuddyHelpers.java | 1 +
.../beam/sdk/schemas/utils/SelectHelpers.java | 1 +
.../sdk/schemas/utils/StaticSchemaInference.java | 1 +
.../java/org/apache/beam/sdk/state/StateSpecs.java | 3 +-
.../org/apache/beam/sdk/testing/Annotations.java | 1 +
.../apache/beam/sdk/testing/CoderProperties.java | 1 +
.../apache/beam/sdk/testing/CombineFnTester.java | 1 +
.../beam/sdk/testing/FileChecksumMatcher.java | 1 +
.../org/apache/beam/sdk/testing/JsonMatcher.java | 1 +
.../java/org/apache/beam/sdk/testing/PAssert.java | 1 +
.../apache/beam/sdk/testing/PaneExtractors.java | 1 +
.../beam/sdk/testing/SerializableMatchers.java | 1 +
.../apache/beam/sdk/testing/SourceTestUtils.java | 1 +
.../apache/beam/sdk/testing/SuccessOrFailure.java | 1 +
.../org/apache/beam/sdk/testing/TestPipeline.java | 1 +
.../apache/beam/sdk/testing/WindowSupplier.java | 1 +
.../beam/sdk/transforms/ApproximateQuantiles.java | 1 +
.../org/apache/beam/sdk/transforms/Combine.java | 1 +
.../org/apache/beam/sdk/transforms/CombineFns.java | 4 +
.../org/apache/beam/sdk/transforms/Create.java | 5 +-
.../org/apache/beam/sdk/transforms/Distinct.java | 1 +
.../beam/sdk/transforms/DoFnOutputReceivers.java | 1 +
.../beam/sdk/transforms/DoFnSchemaInformation.java | 1 +
.../beam/sdk/transforms/FlatMapElements.java | 1 +
.../beam/sdk/transforms/GroupIntoBatches.java | 1 +
.../beam/sdk/transforms/InferableFunction.java | 1 +
.../org/apache/beam/sdk/transforms/Latest.java | 1 +
.../apache/beam/sdk/transforms/MapElements.java | 1 +
.../java/org/apache/beam/sdk/transforms/Max.java | 1 +
.../java/org/apache/beam/sdk/transforms/Min.java | 1 +
.../java/org/apache/beam/sdk/transforms/ParDo.java | 1 +
.../beam/sdk/transforms/PeriodicSequence.java | 1 +
.../java/org/apache/beam/sdk/transforms/Regex.java | 1 +
.../java/org/apache/beam/sdk/transforms/Reify.java | 1 +
.../org/apache/beam/sdk/transforms/Sample.java | 1 +
.../beam/sdk/transforms/SerializableFunctions.java | 1 +
.../apache/beam/sdk/transforms/SimpleFunction.java | 1 +
.../org/apache/beam/sdk/transforms/ToString.java | 1 +
.../java/org/apache/beam/sdk/transforms/Top.java | 1 +
.../java/org/apache/beam/sdk/transforms/View.java | 1 +
.../java/org/apache/beam/sdk/transforms/Wait.java | 1 +
.../java/org/apache/beam/sdk/transforms/Watch.java | 1 +
.../apache/beam/sdk/transforms/WithFailures.java | 1 +
.../org/apache/beam/sdk/transforms/WithKeys.java | 1 +
.../beam/sdk/transforms/display/DisplayData.java | 5 +-
.../beam/sdk/transforms/join/CoGbkResult.java | 1 +
.../beam/sdk/transforms/join/UnionCoder.java | 1 +
.../reflect/ByteBuddyDoFnInvokerFactory.java | 1 +
.../reflect/ByteBuddyOnTimerInvokerFactory.java | 1 +
.../beam/sdk/transforms/reflect/DoFnSignature.java | 34 ++---
.../sdk/transforms/reflect/DoFnSignatures.java | 1 +
.../splittabledofn/ByteKeyRangeTracker.java | 1 +
.../splittabledofn/GrowableOffsetRangeTracker.java | 1 +
.../splittabledofn/OffsetRangeTracker.java | 1 +
.../splittabledofn/WatermarkEstimators.java | 1 +
.../beam/sdk/transforms/windowing/AfterPane.java | 1 +
.../transforms/windowing/AfterProcessingTime.java | 1 +
.../windowing/AfterSynchronizedProcessingTime.java | 1 +
.../sdk/transforms/windowing/AfterWatermark.java | 1 +
.../sdk/transforms/windowing/GlobalWindows.java | 1 +
.../windowing/MergeOverlappingIntervalWindows.java | 1 +
.../beam/sdk/transforms/windowing/Never.java | 1 +
.../transforms/windowing/TimestampCombiner.java | 1 +
.../beam/sdk/transforms/windowing/Trigger.java | 1 +
.../beam/sdk/transforms/windowing/Window.java | 1 +
.../java/org/apache/beam/sdk/util/ApiSurface.java | 5 +-
.../org/apache/beam/sdk/util/AppliedCombineFn.java | 1 +
.../java/org/apache/beam/sdk/util/CoderUtils.java | 1 +
.../util/EmptyOnDeserializationThreadLocal.java | 1 +
.../sdk/util/ExposedByteArrayOutputStream.java | 1 +
.../sdk/util/FilePatternMatchingShardedFile.java | 1 +
.../org/apache/beam/sdk/util/FluentBackoff.java | 1 +
.../org/apache/beam/sdk/util/InstanceBuilder.java | 1 +
.../apache/beam/sdk/util/MutationDetectors.java | 1 +
.../java/org/apache/beam/sdk/util/NameUtils.java | 1 +
.../java/org/apache/beam/sdk/util/NoopLock.java | 1 +
.../apache/beam/sdk/util/NumberedShardedFile.java | 1 +
.../org/apache/beam/sdk/util/Preconditions.java | 1 +
.../java/org/apache/beam/sdk/util/ReleaseInfo.java | 1 +
.../java/org/apache/beam/sdk/util/RowJson.java | 1 +
.../beam/sdk/util/SerializableThrowable.java | 1 +
.../apache/beam/sdk/util/SerializableUtils.java | 1 +
.../java/org/apache/beam/sdk/util/ShardedKey.java | 150 +++++++++++++++++++++
.../java/org/apache/beam/sdk/util/StreamUtils.java | 1 +
.../apache/beam/sdk/util/UserCodeException.java | 1 +
.../java/org/apache/beam/sdk/util/ZipFiles.java | 1 +
.../sdk/util/common/ElementByteSizeObserver.java | 1 +
.../beam/sdk/util/common/ReflectHelpers.java | 1 +
.../sdk/values/FailsafeValueInSingleWindow.java | 1 +
.../org/apache/beam/sdk/values/PCollection.java | 1 +
.../apache/beam/sdk/values/PCollectionView.java | 3 +-
.../apache/beam/sdk/values/PCollectionViews.java | 1 +
.../java/org/apache/beam/sdk/values/PValue.java | 1 +
.../org/apache/beam/sdk/values/PValueBase.java | 1 +
.../java/org/apache/beam/sdk/values/PValues.java | 1 +
.../main/java/org/apache/beam/sdk/values/Row.java | 7 +-
.../java/org/apache/beam/sdk/values/RowUtils.java | 1 +
.../org/apache/beam/sdk/values/RowWithGetters.java | 4 +-
.../org/apache/beam/sdk/values/RowWithStorage.java | 3 +-
.../org/apache/beam/sdk/values/TaggedPValue.java | 1 +
.../apache/beam/sdk/values/TimestampedValue.java | 1 +
.../org/apache/beam/sdk/values/TypeDescriptor.java | 1 +
.../apache/beam/sdk/values/TypeDescriptors.java | 1 +
.../org/apache/beam/sdk/values/TypeParameter.java | 1 +
.../beam/sdk/values/ValueInSingleWindow.java | 1 +
.../java/org/apache/beam/sdk/PipelineTest.java | 1 +
.../test/java/org/apache/beam/sdk/TestUtils.java | 1 +
.../org/apache/beam/sdk/coders/AvroCoderTest.java | 1 +
.../apache/beam/sdk/coders/AvroCoderTestPojo.java | 1 +
.../beam/sdk/coders/BigDecimalCoderTest.java | 1 +
.../beam/sdk/coders/BigEndianIntegerCoderTest.java | 1 +
.../beam/sdk/coders/BigEndianLongCoderTest.java | 1 +
.../beam/sdk/coders/BigIntegerCoderTest.java | 1 +
.../apache/beam/sdk/coders/BitSetCoderTest.java | 1 +
.../apache/beam/sdk/coders/ByteArrayCoderTest.java | 1 +
.../org/apache/beam/sdk/coders/ByteCoderTest.java | 1 +
.../apache/beam/sdk/coders/CoderRegistryTest.java | 1 +
.../java/org/apache/beam/sdk/coders/CoderTest.java | 1 +
.../beam/sdk/coders/CollectionCoderTest.java | 1 +
.../apache/beam/sdk/coders/DoubleCoderTest.java | 1 +
.../apache/beam/sdk/coders/DurationCoderTest.java | 1 +
.../org/apache/beam/sdk/coders/FloatCoderTest.java | 1 +
.../apache/beam/sdk/coders/InstantCoderTest.java | 1 +
.../apache/beam/sdk/coders/IterableCoderTest.java | 1 +
.../org/apache/beam/sdk/coders/KvCoderTest.java | 1 +
.../org/apache/beam/sdk/coders/ListCoderTest.java | 1 +
.../org/apache/beam/sdk/coders/MapCoderTest.java | 1 +
.../apache/beam/sdk/coders/NullableCoderTest.java | 1 +
.../sdk/coders/PCollectionCustomCoderTest.java | 1 +
.../beam/sdk/coders/PrintBase64Encodings.java | 1 +
.../beam/sdk/coders/SerializableCoderTest.java | 1 +
.../org/apache/beam/sdk/coders/SetCoderTest.java | 1 +
.../beam/sdk/coders/StringUtf8CoderTest.java | 1 +
.../beam/sdk/coders/StructuredCoderTest.java | 1 +
.../beam/sdk/coders/TextualIntegerCoderTest.java | 1 +
.../apache/beam/sdk/coders/VarIntCoderTest.java | 1 +
.../apache/beam/sdk/coders/VarLongCoderTest.java | 1 +
.../java/org/apache/beam/sdk/io/AvroIOTest.java | 1 +
.../org/apache/beam/sdk/io/AvroSourceTest.java | 1 +
.../sdk/io/BoundedReadFromUnboundedSourceTest.java | 1 +
.../beam/sdk/io/ClassLoaderFileSystemTest.java | 1 +
.../apache/beam/sdk/io/CompressedSourceTest.java | 1 +
.../org/apache/beam/sdk/io/CountingSourceTest.java | 1 +
.../beam/sdk/io/DefaultFilenamePolicyTest.java | 1 +
.../org/apache/beam/sdk/io/FileBasedSinkTest.java | 1 +
.../apache/beam/sdk/io/FileBasedSourceTest.java | 1 +
.../java/org/apache/beam/sdk/io/FileIOTest.java | 1 +
.../org/apache/beam/sdk/io/FileSystemsTest.java | 1 +
.../apache/beam/sdk/io/LocalFileSystemTest.java | 1 +
.../apache/beam/sdk/io/LocalResourceIdTest.java | 1 +
.../apache/beam/sdk/io/OffsetBasedSourceTest.java | 1 +
.../test/java/org/apache/beam/sdk/io/ReadTest.java | 1 +
.../java/org/apache/beam/sdk/io/SimpleSink.java | 1 +
.../org/apache/beam/sdk/io/TFRecordIOTest.java | 1 +
.../org/apache/beam/sdk/io/TextIOReadTest.java | 1 +
.../org/apache/beam/sdk/io/TextIOWriteTest.java | 7 +-
.../org/apache/beam/sdk/io/TextSourceTest.java | 1 +
.../org/apache/beam/sdk/io/WriteFilesTest.java | 1 +
.../io/range/ByteKeyRangeInterpolateKeyTest.java | 1 +
.../apache/beam/sdk/io/range/ByteKeyRangeTest.java | 1 +
.../beam/sdk/metrics/MetricResultsMatchers.java | 1 +
.../beam/sdk/metrics/MetricsEnvironmentTest.java | 1 +
.../org/apache/beam/sdk/metrics/MetricsTest.java | 1 +
.../sdk/options/PipelineOptionsFactoryTest.java | 1 +
.../sdk/options/PipelineOptionsValidatorTest.java | 1 +
.../sdk/options/ProxyInvocationHandlerTest.java | 1 +
.../sdk/options/RemoteEnvironmentOptionsTest.java | 1 +
.../beam/sdk/options/SdkHarnessOptionsTest.java | 1 +
.../beam/sdk/runners/TransformHierarchyTest.java | 1 +
.../apache/beam/sdk/runners/TransformTreeTest.java | 1 +
.../beam/sdk/schemas/AutoValueSchemaTest.java | 1 +
.../apache/beam/sdk/schemas/AvroSchemaTest.java | 1 +
.../sdk/schemas/FieldAccessDescriptorTest.java | 1 +
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 1 +
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 1 +
.../apache/beam/sdk/schemas/SchemaCoderTest.java | 1 +
.../apache/beam/sdk/schemas/SchemaOptionsTest.java | 1 +
.../beam/sdk/schemas/SchemaRegistryTest.java | 1 +
.../org/apache/beam/sdk/schemas/SchemaTest.java | 1 +
.../sdk/schemas/logicaltypes/LogicalTypesTest.java | 1 +
.../beam/sdk/schemas/transforms/AddFieldsTest.java | 1 +
.../sdk/schemas/transforms/CastValidatorTest.java | 1 +
.../beam/sdk/schemas/transforms/CoGroupTest.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/JoinTest.java | 1 +
.../beam/sdk/schemas/transforms/SelectTest.java | 1 +
.../beam/sdk/schemas/utils/AvroGenerators.java | 1 +
.../beam/sdk/schemas/utils/AvroUtilsTest.java | 1 +
.../beam/sdk/schemas/utils/JavaBeanUtilsTest.java | 1 +
.../beam/sdk/schemas/utils/POJOUtilsTest.java | 1 +
.../beam/sdk/schemas/utils/SchemaTestUtils.java | 1 +
.../beam/sdk/schemas/utils/SelectHelpersTest.java | 1 +
.../beam/sdk/schemas/utils/TestJavaBeans.java | 1 +
.../apache/beam/sdk/schemas/utils/TestPOJOs.java | 3 +-
.../apache/beam/sdk/state/StateContextsTest.java | 1 +
.../beam/sdk/testing/CoderPropertiesTest.java | 1 +
.../org/apache/beam/sdk/testing/ExpectedLogs.java | 1 +
.../apache/beam/sdk/testing/ExpectedLogsTest.java | 1 +
.../beam/sdk/testing/FileChecksumMatcherTest.java | 1 +
.../sdk/testing/InterceptingUrlClassLoader.java | 1 +
.../org/apache/beam/sdk/testing/PAssertTest.java | 1 +
.../beam/sdk/testing/RestoreSystemProperties.java | 1 +
.../sdk/testing/RestoreSystemPropertiesTest.java | 1 +
.../beam/sdk/testing/SerializableMatchersTest.java | 1 +
.../beam/sdk/testing/SourceTestUtilsTest.java | 1 +
.../apache/beam/sdk/testing/TestStreamTest.java | 1 +
.../apache/beam/sdk/testing/ThreadLeakTracker.java | 1 +
.../beam/sdk/transforms/ApproximateUniqueTest.java | 1 +
.../apache/beam/sdk/transforms/CombineFnsTest.java | 1 +
.../apache/beam/sdk/transforms/CombineTest.java | 1 +
.../org/apache/beam/sdk/transforms/CreateTest.java | 5 +-
.../apache/beam/sdk/transforms/DistinctTest.java | 1 +
.../org/apache/beam/sdk/transforms/FilterTest.java | 1 +
.../beam/sdk/transforms/FlatMapElementsTest.java | 1 +
.../apache/beam/sdk/transforms/FlattenTest.java | 1 +
.../apache/beam/sdk/transforms/JsonToRowTest.java | 1 +
.../org/apache/beam/sdk/transforms/KvSwapTest.java | 6 +-
.../apache/beam/sdk/transforms/LatestFnTest.java | 1 +
.../org/apache/beam/sdk/transforms/LatestTest.java | 1 +
.../beam/sdk/transforms/MapElementsTest.java | 1 +
.../apache/beam/sdk/transforms/PTransformTest.java | 1 +
.../beam/sdk/transforms/ParDoLifecycleTest.java | 1 +
.../beam/sdk/transforms/ParDoSchemaTest.java | 1 +
.../org/apache/beam/sdk/transforms/ParDoTest.java | 1 +
.../apache/beam/sdk/transforms/PartitionTest.java | 1 +
.../org/apache/beam/sdk/transforms/SampleTest.java | 1 +
.../org/apache/beam/sdk/transforms/SetsTest.java | 1 +
.../beam/sdk/transforms/SimpleStatsFnsTest.java | 1 +
.../beam/sdk/transforms/SplittableDoFnTest.java | 1 +
.../org/apache/beam/sdk/transforms/ViewTest.java | 1 +
.../org/apache/beam/sdk/transforms/WaitTest.java | 1 +
.../org/apache/beam/sdk/transforms/WatchTest.java | 7 +-
.../beam/sdk/transforms/WithFailuresTest.java | 1 +
.../beam/sdk/transforms/WithTimestampsTest.java | 1 +
.../transforms/display/DisplayDataEvaluator.java | 1 +
.../transforms/display/DisplayDataMatchers.java | 1 +
.../sdk/transforms/display/DisplayDataTest.java | 1 +
.../beam/sdk/transforms/join/CoGroupByKeyTest.java | 1 +
.../sdk/transforms/reflect/DoFnInvokersTest.java | 1 +
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 2 +-
.../sdk/transforms/reflect/DoFnSignaturesTest.java | 1 +
.../transforms/reflect/OnTimerInvokersTest.java | 1 +
.../reflect/testhelper/DoFnInvokersTestHelper.java | 1 +
.../splittabledofn/ByteKeyRangeTrackerTest.java | 1 +
.../GrowableOffsetRangeTrackerTest.java | 1 +
.../splittabledofn/OffsetRangeTrackerTest.java | 1 +
.../transforms/splittabledofn/SplitResultTest.java | 1 +
.../sdk/transforms/windowing/RepeatedlyTest.java | 1 +
.../beam/sdk/transforms/windowing/StubTrigger.java | 1 +
.../beam/sdk/transforms/windowing/TriggerTest.java | 1 +
.../beam/sdk/transforms/windowing/WindowTest.java | 1 +
.../apache/beam/sdk/util/CombineFnUtilTest.java | 1 +
.../util/FilePatternMatchingShardedFileTest.java | 1 +
.../org/apache/beam/sdk/util/NameUtilsTest.java | 1 +
.../beam/sdk/util/NumberedShardedFileTest.java | 1 +
.../java/org/apache/beam/sdk/util/RowJsonTest.java | 1 +
.../beam/sdk/util/SerializableUtilsTest.java | 1 +
.../org/apache/beam/sdk/util/ShardedKeyTest.java | 74 ++++++++++
.../org/apache/beam/sdk/util/StreamUtilsTest.java | 1 +
.../beam/sdk/util/UnownedInputStreamTest.java | 1 +
.../beam/sdk/util/UnownedOutputStreamTest.java | 1 +
.../beam/sdk/util/UserCodeExceptionTest.java | 1 +
.../org/apache/beam/sdk/util/ZipFilesTest.java | 1 +
.../beam/sdk/util/common/ReflectHelpersTest.java | 1 +
.../java/org/apache/beam/sdk/values/KVTest.java | 1 +
.../java/org/apache/beam/sdk/values/RowTest.java | 1 +
.../beam/sdk/values/TimestampedValueTest.java | 1 +
.../apache/beam/sdk/values/TypeDescriptorTest.java | 1 +
.../core/client/operator/AssignEventTime.java | 1 +
.../euphoria/core/client/operator/CountByKey.java | 1 +
.../euphoria/core/client/operator/Distinct.java | 1 +
.../euphoria/core/client/operator/Filter.java | 1 +
.../euphoria/core/client/operator/FlatMap.java | 1 +
.../euphoria/core/client/operator/FullJoin.java | 1 +
.../euphoria/core/client/operator/Join.java | 1 +
.../euphoria/core/client/operator/LeftJoin.java | 1 +
.../euphoria/core/client/operator/MapElements.java | 1 +
.../euphoria/core/client/operator/ReduceByKey.java | 1 +
.../core/client/operator/ReduceWindow.java | 1 +
.../euphoria/core/client/operator/RightJoin.java | 1 +
.../euphoria/core/client/operator/SumByKey.java | 1 +
.../euphoria/core/client/operator/TopPerKey.java | 1 +
.../euphoria/core/client/operator/Union.java | 1 +
.../core/client/operator/WindowBuilder.java | 1 +
.../core/client/operator/base/Builders.java | 1 +
.../euphoria/core/client/type/TypeUtils.java | 1 +
.../translate/BroadcastHashJoinTranslator.java | 1 +
.../euphoria/core/translate/ExtractKey.java | 1 +
.../euphoria/core/translate/JoinTranslator.java | 1 +
.../core/translate/LazyAccumulatorProvider.java | 1 +
.../euphoria/core/translate/OperatorTransform.java | 1 +
.../core/translate/ReduceByKeyTranslator.java | 1 +
.../core/translate/SingleValueContext.java | 1 +
.../core/translate/TimestampExtractTransform.java | 1 +
.../euphoria/core/translate/UnionTranslator.java | 1 +
.../translate/collector/AdaptableCollector.java | 1 +
.../translate/collector/SingleValueCollector.java | 1 +
.../euphoria/core/util/InstanceUtils.java | 1 +
.../euphoria/core/client/operator/FlatMapTest.java | 1 +
.../euphoria/core/client/operator/JoinTest.java | 1 +
.../core/client/operator/ReduceByKeyTest.java | 1 +
.../core/client/operator/SumByKeyTest.java | 1 +
.../euphoria/core/client/operator/TestUtils.java | 1 +
.../core/client/type/TypePropagationAssert.java | 1 +
.../euphoria/core/client/util/IOUtilsTest.java | 1 +
.../euphoria/core/testkit/FlatMapTest.java | 1 +
.../extensions/euphoria/core/testkit/JoinTest.java | 1 +
.../euphoria/core/testkit/MapElementsTest.java | 1 +
.../euphoria/core/testkit/ReduceByKeyTest.java | 1 +
.../euphoria/core/testkit/SumByKeyTest.java | 1 +
.../SingleJvmAccumulatorProviderTest.java | 1 +
.../collector/SingleValueCollectorTest.java | 1 +
.../beam/sdk/transforms/windowing/WindowDesc.java | 1 +
.../extensions/gcp/auth/GcpCredentialFactory.java | 1 +
.../extensions/gcp/auth/NoopCredentialFactory.java | 1 +
.../sdk/extensions/gcp/options/GcpOptions.java | 1 +
.../gcp/options/GoogleApiDebugOptions.java | 1 +
.../sdk/extensions/gcp/storage/GcsFileSystem.java | 1 +
.../sdk/extensions/gcp/util/CustomHttpErrors.java | 1 +
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 1 +
.../gcp/util/RetryHttpRequestInitializer.java | 1 +
.../gcp/util/UploadIdResponseInterceptor.java | 1 +
.../sdk/extensions/gcp/util/gcsfs/GcsPath.java | 1 +
.../sdk/extensions/gcp/GcpCoreApiSurfaceTest.java | 1 +
.../sdk/extensions/gcp/options/GcpOptionsTest.java | 1 +
.../extensions/gcp/storage/GcsFileSystemTest.java | 1 +
.../gcp/storage/GcsPathValidatorTest.java | 1 +
.../extensions/gcp/storage/GcsResourceIdTest.java | 1 +
.../beam/sdk/extensions/gcp/util/GcsUtilIT.java | 1 +
.../beam/sdk/extensions/gcp/util/GcsUtilTest.java | 1 +
...LatencyRecordingHttpRequestInitializerTest.java | 1 +
.../gcp/util/RetryHttpRequestInitializerTest.java | 1 +
.../gcp/util/UploadIdResponseInterceptorTest.java | 1 +
.../beam/sdk/extensions/jackson/AsJsons.java | 1 +
.../beam/sdk/extensions/jackson/ParseJsons.java | 1 +
.../extensions/jackson/JacksonTransformsTest.java | 1 +
.../beam/sdk/extensions/ml/AnnotateImages.java | 1 +
.../beam/sdk/extensions/ml/AnnotateText.java | 1 +
.../ml/AnnotateVideoBytesWithContextFn.java | 1 +
.../beam/sdk/extensions/ml/AnnotateVideoFn.java | 1 +
.../extensions/ml/AnnotateVideoFromBytesFn.java | 1 +
.../sdk/extensions/ml/AnnotateVideoFromURIFn.java | 1 +
.../ml/AnnotateVideoURIWithContextFn.java | 1 +
.../beam/sdk/extensions/ml/DLPDeidentifyText.java | 1 +
.../beam/sdk/extensions/ml/DLPInspectText.java | 1 +
.../beam/sdk/extensions/ml/DLPReidentifyText.java | 1 +
.../beam/sdk/extensions/ml/AnnotateImagesTest.java | 1 +
.../beam/sdk/extensions/ml/AnnotateVideoTest.java | 1 +
.../sdk/extensions/ml/BatchRequestForDlpTest.java | 1 +
.../beam/sdk/extensions/ml/CloudVisionIT.java | 1 +
.../beam/sdk/extensions/ml/CloudVisionTest.java | 1 +
.../sdk/extensions/ml/MapStringToDlpRowTest.java | 1 +
.../extensions/protobuf/ProtoByteBuddyUtils.java | 1 +
.../beam/sdk/extensions/protobuf/ProtoCoder.java | 1 +
.../beam/sdk/extensions/protobuf/ProtoDomain.java | 1 +
.../protobuf/ProtoDynamicMessageSchema.java | 1 +
.../extensions/protobuf/ProtoMessageSchema.java | 3 +-
.../protobuf/ProtoSchemaLogicalTypes.java | 1 +
.../beam/sdk/extensions/protobuf/ProtobufUtil.java | 1 +
.../extensions/protobuf/ByteStringCoderTest.java | 1 +
.../extensions/protobuf/DynamicProtoCoderTest.java | 1 +
.../sdk/extensions/protobuf/ProtoCoderTest.java | 1 +
.../protobuf/ProtoMessageSchemaTest.java | 1 +
.../protobuf/ProtoSchemaTranslatorTest.java | 1 +
.../meta/provider/hcatalog/DatabaseProvider.java | 3 +-
.../provider/hcatalog/HCatalogTableProvider.java | 1 +
.../provider/hcatalog/BeamSqlHiveSchemaTest.java | 1 +
.../apache/beam/sdk/extensions/sql/BeamSqlCli.java | 1 +
.../beam/sdk/extensions/sql/SqlTransform.java | 1 +
.../sdk/extensions/sql/example/model/Customer.java | 1 +
.../sdk/extensions/sql/impl/BeamCalciteSchema.java | 1 +
.../sql/impl/BeamCalciteSchemaFactory.java | 1 +
.../sdk/extensions/sql/impl/BeamCalciteTable.java | 1 +
.../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 1 +
.../extensions/sql/impl/CalciteQueryPlanner.java | 1 +
.../sdk/extensions/sql/impl/JdbcConnection.java | 1 +
.../beam/sdk/extensions/sql/impl/JdbcDriver.java | 1 +
.../extensions/sql/impl/ScalarFunctionImpl.java | 1 +
.../extensions/sql/impl/TVFSlidingWindowFn.java | 1 +
.../extensions/sql/impl/TableResolutionUtils.java | 1 +
.../beam/sdk/extensions/sql/impl/UdafImpl.java | 1 +
.../beam/sdk/extensions/sql/impl/UdfImpl.java | 1 +
.../sql/impl/UdfImplReflectiveFunctionBase.java | 1 +
.../sdk/extensions/sql/impl/cep/CEPLiteral.java | 1 +
.../sdk/extensions/sql/impl/cep/CEPPattern.java | 1 +
.../beam/sdk/extensions/sql/impl/cep/CEPUtils.java | 1 +
.../beam/sdk/extensions/sql/impl/nfa/NFA.java | 1 +
.../sql/impl/parser/SqlCreateExternalTable.java | 1 +
.../sql/impl/parser/SqlSetOptionBeam.java | 1 +
.../sql/impl/rel/AbstractBeamCalcRel.java | 1 +
.../sql/impl/rel/BeamAggregationRel.java | 1 +
.../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 1 +
.../sql/impl/rel/BeamEnumerableConverter.java | 3 +-
.../sdk/extensions/sql/impl/rel/BeamMatchRel.java | 1 +
.../sdk/extensions/sql/impl/rel/BeamRelNode.java | 1 +
.../sql/impl/rel/BeamSetOperatorRelBase.java | 1 +
.../sdk/extensions/sql/impl/rel/BeamSortRel.java | 1 +
.../sql/impl/rel/BeamTableFunctionScanRel.java | 1 +
.../extensions/sql/impl/rel/BeamUncollectRel.java | 1 +
.../sdk/extensions/sql/impl/rel/BeamUnnestRel.java | 1 +
.../sdk/extensions/sql/impl/rel/BeamWindowRel.java | 1 +
.../impl/rule/BeamAggregateProjectMergeRule.java | 1 +
.../sql/impl/rule/BeamAggregationRule.java | 1 +
.../sql/impl/rule/BeamBasicAggregationRule.java | 1 +
.../sql/impl/rule/BeamIOPushDownRule.java | 1 +
.../sql/impl/rule/BeamTableFunctionScanRule.java | 1 +
.../sql/impl/rule/JoinRelOptRuleCall.java | 1 +
.../extensions/sql/impl/schema/BeamTableUtils.java | 1 +
.../impl/transform/BeamBuiltinAggregations.java | 1 +
.../transform/BeamBuiltinAnalyticFunctions.java | 1 +
.../sql/impl/transform/BeamJoinTransforms.java | 1 +
.../impl/transform/BeamSetOperatorsTransforms.java | 1 +
.../transform/agg/AggregationCombineFnAdapter.java | 1 +
.../sql/impl/transform/agg/CovarianceFn.java | 1 +
.../sql/impl/udf/BeamBuiltinFunctionProvider.java | 1 +
.../impl/udf/BuiltinTrigonometricFunctions.java | 1 +
.../extensions/sql/impl/utils/CalciteUtils.java | 1 +
.../sql/meta/provider/FullNameTableProvider.java | 4 +-
.../sql/meta/provider/ReadOnlyTableProvider.java | 1 +
.../provider/SchemaIOTableProviderWrapper.java | 1 +
.../sql/meta/provider/TableProvider.java | 1 +
.../provider/bigquery/BeamBigQuerySqlDialect.java | 1 +
.../provider/bigquery/BeamSqlUnparseContext.java | 1 +
.../sql/meta/provider/bigquery/BigQueryFilter.java | 1 +
.../sql/meta/provider/bigquery/BigQueryTable.java | 1 +
.../sql/meta/provider/kafka/BeamKafkaTable.java | 1 +
.../sql/meta/provider/mongodb/MongoDbTable.java | 1 +
.../sql/meta/provider/test/TestTableFilter.java | 1 +
.../sql/meta/provider/test/TestTableProvider.java | 1 +
.../sql/meta/provider/test/TestTableUtils.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/BeamComplexTypeTest.java | 1 +
.../beam/sdk/extensions/sql/BeamSqlCliTest.java | 1 +
.../sql/BeamSqlDslAggregationCovarianceTest.java | 1 +
.../sql/BeamSqlDslAggregationNullableTest.java | 1 +
.../extensions/sql/BeamSqlDslAggregationTest.java | 1 +
.../sql/BeamSqlDslAggregationVarianceTest.java | 1 +
.../beam/sdk/extensions/sql/BeamSqlDslBase.java | 1 +
.../sdk/extensions/sql/BeamSqlDslJoinTest.java | 1 +
.../sdk/extensions/sql/BeamSqlDslProjectTest.java | 1 +
.../sql/BeamSqlDslSqlStdOperatorsTest.java | 1 +
.../sdk/extensions/sql/BeamSqlDslUdfUdafTest.java | 1 +
.../sdk/extensions/sql/BeamSqlExplainTest.java | 1 +
.../extensions/sql/InferredJavaBeanSqlTest.java | 1 +
.../apache/beam/sdk/extensions/sql/TestUtils.java | 1 +
.../sdk/extensions/sql/impl/JdbcDriverTest.java | 1 +
.../sql/impl/parser/BeamDDLNestedTypesTest.java | 1 +
.../extensions/sql/impl/parser/BeamDDLTest.java | 1 +
.../extensions/sql/impl/planner/NodeStatsTest.java | 1 +
.../sdk/extensions/sql/impl/rel/BaseRelTest.java | 1 +
.../rel/BeamCoGBKJoinRelBoundedVsBoundedTest.java | 1 +
.../BeamCoGBKJoinRelUnboundedVsUnboundedTest.java | 1 +
.../sql/impl/rel/BeamEnumerableConverterTest.java | 1 +
.../sql/impl/rel/BeamSideInputJoinRelTest.java | 1 +
.../impl/rel/BeamSideInputLookupJoinRelTest.java | 1 +
.../extensions/sql/impl/rel/BeamSortRelTest.java | 1 +
.../rule/BeamAggregateProjectMergeRuleTest.java | 1 +
.../sql/impl/rule/IOPushDownRuleTest.java | 1 +
.../sql/impl/rule/JoinReorderingTest.java | 2 +
.../schema/transform/BeamTransformBaseTest.java | 1 +
.../sql/impl/utils/CalciteUtilsTest.java | 1 +
...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 1 +
.../BeamSqlDateFunctionsIntegrationTest.java | 1 +
.../sql/meta/CustomTableResolverTest.java | 1 +
.../meta/provider/bigquery/BigQueryFilterTest.java | 1 +
.../meta/provider/bigquery/BigQueryTestTable.java | 1 +
.../bigquery/BigQueryTestTableProvider.java | 4 +-
.../kafka/BeamKafkaTableStatisticsTest.java | 1 +
.../provider/kafka/KafkaTableProviderCSVIT.java | 1 +
.../meta/provider/kafka/KafkaTableProviderIT.java | 1 +
.../sql/meta/provider/kafka/KafkaTestTable.java | 1 +
.../meta/provider/mongodb/MongoDbFilterTest.java | 1 +
.../meta/provider/mongodb/MongoDbReadWriteIT.java | 1 +
.../provider/parquet/ParquetTableReadTest.java | 1 +
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 1 +
.../meta/provider/test/TestTableProviderTest.java | 1 +
...tTableProviderWithFilterAndProjectPushDown.java | 1 +
.../test/TestTableProviderWithFilterPushDown.java | 1 +
.../test/TestTableProviderWithProjectPushDown.java | 1 +
.../sql/meta/store/InMemoryMetaStoreTest.java | 1 +
.../beam/sdk/extensions/sql/utils/RowAsserts.java | 1 +
.../extensions/sql/zetasql/BeamZetaSqlCalcRel.java | 1 +
.../sdk/extensions/sql/zetasql/QueryTrait.java | 1 +
.../sdk/extensions/sql/zetasql/SqlAnalyzer.java | 1 +
.../extensions/sql/zetasql/TableResolution.java | 1 +
.../extensions/sql/zetasql/ZetaSQLPlannerImpl.java | 1 +
.../sql/zetasql/ZetaSQLQueryPlanner.java | 1 +
.../sql/zetasql/ZetaSqlBeamTranslationUtils.java | 1 +
.../zetasql/ZetaSqlCalciteTranslationUtils.java | 1 +
.../translation/AggregateScanConverter.java | 1 +
.../translation/ArrayScanColumnRefToUncollect.java | 1 +
.../zetasql/translation/ExpressionConverter.java | 1 +
.../LimitOffsetScanToLimitConverter.java | 1 +
.../LimitOffsetScanToOrderByLimitConverter.java | 1 +
.../translation/SqlNullIfOperatorRewriter.java | 1 +
.../sql/zetasql/translation/SqlOperators.java | 1 +
.../translation/SqlWindowTableFunction.java | 1 +
.../sql/zetasql/translation/TVFScanConverter.java | 1 +
.../zetasql/translation/WithRefScanConverter.java | 1 +
.../sql/zetasql/TableResolutionTest.java | 1 +
.../beam/sdk/extensions/sql/zetasql/TestInput.java | 1 +
.../sql/zetasql/ZetaSQLPushDownTest.java | 1 +
.../sql/zetasql/ZetaSqlDialectSpecTest.java | 1 +
.../extensions/sql/zetasql/ZetaSqlTestBase.java | 1 +
.../sql/zetasql/ZetaSqlTimeFunctionsTest.java | 1 +
...amFnDataSizeBasedBufferingOutboundObserver.java | 1 +
...amFnDataTimeBasedBufferingOutboundObserver.java | 1 +
.../sdk/fn/splittabledofn/RestrictionTrackers.java | 1 +
.../sdk/fn/stream/BufferingStreamObserver.java | 1 +
.../org/apache/beam/sdk/fn/stream/DataStreams.java | 1 +
.../org/apache/beam/sdk/fn/test/TestExecutors.java | 1 +
.../apache/beam/sdk/fn/JvmInitializersTest.java | 1 +
.../sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 1 +
...DataSizeBasedBufferingOutboundObserverTest.java | 1 +
...DataTimeBasedBufferingOutboundObserverTest.java | 1 +
.../fn/splittabledofn/RestrictionTrackersTest.java | 1 +
.../apache/beam/sdk/fn/stream/DataStreamsTest.java | 1 +
.../sdk/fn/stream/OutboundObserverFactoryTest.java | 1 +
.../apache/beam/sdk/fn/test/TestExecutorsTest.java | 1 +
.../apache/beam/sdk/fn/test/TestStreamsTest.java | 1 +
.../beam/fn/harness/BeamFnDataReadRunner.java | 1 +
.../beam/fn/harness/BeamFnDataWriteRunner.java | 1 +
.../org/apache/beam/fn/harness/CombineRunners.java | 1 +
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 1 +
.../java/org/apache/beam/fn/harness/FnHarness.java | 1 +
.../beam/fn/harness/PrecombineGroupingTable.java | 1 +
.../fn/harness/control/FinalizeBundleHandler.java | 1 +
.../fn/harness/control/ProcessBundleHandler.java | 1 +
.../harness/data/PCollectionConsumerRegistry.java | 1 +
.../fn/harness/data/QueueingBeamFnDataClient.java | 1 +
.../fn/harness/logging/BeamFnLoggingClient.java | 1 +
.../apache/beam/fn/harness/state/BagUserState.java | 1 +
.../harness/state/BeamFnStateGrpcClientCache.java | 1 +
.../beam/fn/harness/state/FnApiStateAccessor.java | 4 +-
.../state/LazyCachingIteratorToIterable.java | 1 +
.../beam/fn/harness/state/MultimapSideInput.java | 1 +
.../fn/harness/state/StateFetchingIterators.java | 1 +
.../beam/fn/harness/BeamFnDataReadRunnerTest.java | 1 +
.../beam/fn/harness/BeamFnDataWriteRunnerTest.java | 1 +
.../apache/beam/fn/harness/CombineRunnersTest.java | 1 +
.../apache/beam/fn/harness/FlattenRunnerTest.java | 1 +
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 1 +
.../apache/beam/fn/harness/MapFnRunnersTest.java | 1 +
.../fn/harness/PrecombineGroupingTableTest.java | 1 +
.../harness/control/BeamFnControlClientTest.java | 1 +
.../harness/control/FinalizeBundleHandlerTest.java | 1 +
.../harness/control/ProcessBundleHandlerTest.java | 1 +
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 1 +
.../fn/harness/data/FakeBeamFnTimerClient.java | 1 +
.../data/PCollectionConsumerRegistryTest.java | 1 +
.../harness/logging/BeamFnLoggingClientTest.java | 1 +
.../beam/fn/harness/state/BagUserStateTest.java | 1 +
.../state/BeamFnStateGrpcClientCacheTest.java | 1 +
.../fn/harness/state/StateBackedIterableTest.java | 1 +
.../stream/HarnessStreamObserverFactoriesTest.java | 1 +
.../apache/beam/sdk/io/aws/coders/AwsCoders.java | 1 +
.../beam/sdk/io/aws/dynamodb/DynamoDBIO.java | 1 +
.../apache/beam/sdk/io/aws/options/AwsModule.java | 1 +
.../apache/beam/sdk/io/aws/s3/S3FileSystem.java | 1 +
.../io/aws/s3/S3ReadableSeekableByteChannel.java | 1 +
.../apache/beam/sdk/io/aws/s3/S3ResourceId.java | 4 +-
.../beam/sdk/io/aws/s3/S3WritableByteChannel.java | 1 +
.../beam/sdk/io/aws/sns/PublishResultCoders.java | 1 +
.../java/org/apache/beam/sdk/io/aws/sns/SnsIO.java | 1 +
.../beam/sdk/io/aws/sqs/SqsConfiguration.java | 1 +
.../java/org/apache/beam/sdk/io/aws/sqs/SqsIO.java | 1 +
.../beam/sdk/io/aws/sqs/SqsUnboundedReader.java | 1 +
.../beam/sdk/io/aws/sqs/SqsUnboundedSource.java | 1 +
.../beam/sdk/io/aws/coders/AwsCodersTest.java | 1 +
.../io/aws/dynamodb/AwsClientsProviderMock.java | 1 +
.../beam/sdk/io/aws/dynamodb/DynamoDBIOTest.java | 1 +
.../sdk/io/aws/dynamodb/DynamoDBIOTestHelper.java | 1 +
.../beam/sdk/io/aws/options/AwsModuleTest.java | 1 +
.../beam/sdk/io/aws/s3/MatchResultMatcher.java | 1 +
.../beam/sdk/io/aws/s3/S3FileSystemTest.java | 1 +
.../beam/sdk/io/aws/s3/S3ResourceIdTest.java | 1 +
.../sdk/io/aws/s3/S3WritableByteChannelTest.java | 1 +
.../sdk/io/aws/sns/PublishResultCodersTest.java | 1 +
.../org/apache/beam/sdk/io/aws/sns/SnsIOTest.java | 1 +
.../org/apache/beam/sdk/io/aws/sqs/SqsIOTest.java | 1 +
.../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java | 1 +
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 1 +
.../beam/sdk/io/aws2/kinesis/KinesisReader.java | 1 +
.../beam/sdk/io/aws2/kinesis/KinesisRecord.java | 1 +
.../beam/sdk/io/aws2/kinesis/KinesisSource.java | 1 +
.../beam/sdk/io/aws2/kinesis/ShardCheckpoint.java | 1 +
.../beam/sdk/io/aws2/kinesis/ShardReadersPool.java | 1 +
.../io/aws2/kinesis/SimplifiedKinesisClient.java | 1 +
.../beam/sdk/io/aws2/kinesis/StartingPoint.java | 1 +
.../io/aws2/kinesis/StartingPointShardsFinder.java | 1 +
.../apache/beam/sdk/io/aws2/kinesis/TimeUtil.java | 1 +
.../apache/beam/sdk/io/aws2/options/AwsModule.java | 1 +
.../org/apache/beam/sdk/io/aws2/sns/SnsIO.java | 1 +
.../beam/sdk/io/aws2/sns/SnsResponseCoder.java | 1 +
.../org/apache/beam/sdk/io/aws2/sqs/SqsIO.java | 1 +
.../beam/sdk/io/aws2/sqs/SqsUnboundedReader.java | 1 +
.../beam/sdk/io/aws2/sqs/SqsUnboundedSource.java | 1 +
.../beam/sdk/io/aws2/dynamodb/DynamoDBIOTest.java | 1 +
.../sdk/io/aws2/dynamodb/DynamoDBIOTestHelper.java | 1 +
.../aws2/dynamodb/DynamoDbClientProviderMock.java | 1 +
.../sdk/io/aws2/kinesis/AmazonKinesisMock.java | 1 +
.../kinesis/DynamicCheckpointGeneratorTest.java | 1 +
.../beam/sdk/io/aws2/kinesis/KinesisIOIT.java | 1 +
.../aws2/kinesis/KinesisReaderCheckpointTest.java | 1 +
.../sdk/io/aws2/kinesis/KinesisReaderTest.java | 1 +
.../sdk/io/aws2/kinesis/KinesisServiceMock.java | 1 +
.../beam/sdk/io/aws2/kinesis/RecordFilterTest.java | 1 +
.../sdk/io/aws2/kinesis/ShardCheckpointTest.java | 1 +
.../sdk/io/aws2/kinesis/ShardReadersPoolTest.java | 1 +
.../io/aws2/kinesis/ShardRecordsIteratorTest.java | 1 +
.../aws2/kinesis/SimplifiedKinesisClientTest.java | 1 +
.../kinesis/StartingPointShardsFinderTest.java | 1 +
.../beam/sdk/io/aws2/kinesis/TimeUtilTest.java | 1 +
.../sdk/io/aws2/sns/MockSnsAsyncBaseClient.java | 1 +
.../beam/sdk/io/aws2/sns/SnsClientMockErrors.java | 1 +
.../beam/sdk/io/aws2/sns/SnsClientMockSuccess.java | 1 +
.../org/apache/beam/sdk/io/aws2/sns/SnsIOTest.java | 1 +
.../beam/sdk/io/aws2/sns/SnsIOWriteTest.java | 1 +
.../beam/sdk/io/aws2/sqs/EmbeddedSqsServer.java | 1 +
.../sdk/io/aws2/sqs/SqsClientProviderMock.java | 1 +
.../java/org/apache/beam/sdk/io/amqp/AmqpIO.java | 1 +
.../sdk/io/azure/blobstore/AzfsResourceId.java | 4 +-
.../azure/blobstore/AzureBlobStoreFileSystem.java | 1 +
.../DefaultBlobstoreClientBuilderFactory.java | 1 +
.../sdk/io/azure/blobstore/AzfsResourceIdTest.java | 1 +
.../blobstore/AzureBlobStoreFileSystemTest.java | 5 +-
.../beam/sdk/bigqueryioperftests/BigQueryIOIT.java | 1 +
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 1 +
.../io/cassandra/DefaultObjectMapperFactory.java | 1 +
.../beam/sdk/io/cassandra/CassandraIOIT.java | 1 +
.../beam/sdk/io/cassandra/CassandraIOTest.java | 1 +
.../beam/sdk/io/clickhouse/ClickHouseIO.java | 1 +
.../beam/sdk/io/clickhouse/ClickHouseWriter.java | 1 +
.../apache/beam/sdk/io/clickhouse/TableSchema.java | 1 +
.../beam/sdk/io/clickhouse/BaseClickHouseTest.java | 5 +-
.../beam/sdk/io/clickhouse/ClickHouseIOTest.java | 1 +
.../org/apache/beam/sdk/io/common/HashingFn.java | 1 +
.../org/apache/beam/sdk/io/common/IOITHelper.java | 1 +
.../apache/beam/sdk/io/common/IOITHelperTest.java | 1 +
.../sdk/io/contextualtextio/ContextualTextIO.java | 1 +
.../contextualtextio/ContextualTextIOSource.java | 1 +
.../io/contextualtextio/RecordWithMetadata.java | 1 +
.../io/contextualtextio/ContextualTextIOTest.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 1 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 1 +
.../elasticsearch/ElasticsearchIOTestCommon.java | 1 +
.../io/elasticsearch/ElasticsearchIOTestUtils.java | 1 +
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 1 +
.../java/org/apache/beam/sdk/io/avro/AvroIOIT.java | 1 +
.../apache/beam/sdk/io/parquet/ParquetIOIT.java | 1 +
.../java/org/apache/beam/sdk/io/text/TextIOIT.java | 1 +
.../apache/beam/sdk/io/tfrecord/TFRecordIOIT.java | 1 +
.../java/org/apache/beam/sdk/io/xml/XmlIOIT.java | 1 +
.../beam/sdk/io/gcp/bigquery/AvroRowWriter.java | 1 +
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 10 +-
.../sdk/io/gcp/bigquery/BigQueryIOMetadata.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryQueryHelper.java | 1 +
.../io/gcp/bigquery/BigQueryResourceNaming.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 1 +
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 4 +-
.../gcp/bigquery/BigQueryStorageQuerySource.java | 1 +
.../io/gcp/bigquery/BigQueryStorageSourceBase.java | 1 +
.../gcp/bigquery/BigQueryStorageStreamSource.java | 1 +
.../gcp/bigquery/BigQueryStorageTableSource.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryTableSource.java | 1 +
.../io/gcp/bigquery/BigQueryTableSourceDef.java | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 1 +
.../beam/sdk/io/gcp/bigquery/CreateTables.java | 1 +
.../sdk/io/gcp/bigquery/DynamicDestinations.java | 1 +
.../gcp/bigquery/DynamicDestinationsHelpers.java | 1 +
.../beam/sdk/io/gcp/bigquery/ErrorContainer.java | 1 +
.../beam/sdk/io/gcp/bigquery/PrepareWrite.java | 1 +
.../beam/sdk/io/gcp/bigquery/ReifyAsIterable.java | 1 +
.../beam/sdk/io/gcp/bigquery/RowWriterFactory.java | 1 +
.../beam/sdk/io/gcp/bigquery/StreamingInserts.java | 1 +
.../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java | 1 +
.../sdk/io/gcp/bigquery/StreamingWriteTables.java | 1 +
.../beam/sdk/io/gcp/bigquery/TableDestination.java | 1 +
.../sdk/io/gcp/bigquery/TableDestinationCoder.java | 1 +
.../io/gcp/bigquery/TableDestinationCoderV2.java | 1 +
.../io/gcp/bigquery/TableDestinationCoderV3.java | 1 +
.../beam/sdk/io/gcp/bigquery/TagWithUniqueIds.java | 1 +
.../beam/sdk/io/gcp/bigquery/TestBigQuery.java | 1 +
.../sdk/io/gcp/bigquery/WriteBundlesToFiles.java | 1 +
.../beam/sdk/io/gcp/bigquery/WritePartition.java | 1 +
.../beam/sdk/io/gcp/bigquery/WriteRename.java | 1 +
.../beam/sdk/io/gcp/bigquery/WriteResult.java | 1 +
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 1 +
.../beam/sdk/io/gcp/bigtable/BigtableConfig.java | 1 +
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 1 +
.../sdk/io/gcp/bigtable/BigtableReadOptions.java | 1 +
.../sdk/io/gcp/bigtable/BigtableServiceImpl.java | 1 +
.../sdk/io/gcp/bigtable/BigtableWriteResult.java | 1 +
.../gcp/datastore/DataStoreV1SchemaIOProvider.java | 1 +
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 1 +
.../beam/sdk/io/gcp/datastore/EntityToRow.java | 1 +
.../beam/sdk/io/gcp/datastore/RowToEntity.java | 1 +
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 1 +
.../apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java | 1 +
.../beam/sdk/io/gcp/healthcare/HL7v2Message.java | 1 +
.../sdk/io/gcp/healthcare/HealthcareIOError.java | 1 +
.../io/gcp/healthcare/HealthcareIOErrorCoder.java | 1 +
.../healthcare/HealthcareIOErrorToTableRow.java | 1 +
.../io/gcp/healthcare/HttpHealthcareApiClient.java | 1 +
.../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 1 +
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 1 +
.../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java | 1 +
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 4 +-
.../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 1 +
.../beam/sdk/io/gcp/pubsub/PubsubMessage.java | 1 +
.../beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java | 1 +
...bsubMessageWithAttributesAndMessageIdCoder.java | 1 +
.../pubsub/PubsubMessageWithAttributesCoder.java | 1 +
.../pubsub/PubsubMessageWithMessageIdCoder.java | 1 +
.../sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java | 1 +
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 1 +
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 1 +
.../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 4 +-
.../beam/sdk/io/gcp/pubsub/RowToPubsubMessage.java | 1 +
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 1 +
.../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java | 1 +
.../sdk/io/gcp/pubsublite/PublisherOptions.java | 1 +
.../sdk/io/gcp/pubsublite/PublisherOrError.java | 1 +
.../beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java | 1 +
.../gcp/pubsublite/PubsubLiteUnboundedReader.java | 1 +
.../gcp/pubsublite/PubsubLiteUnboundedSource.java | 1 +
.../sdk/io/gcp/pubsublite/SubscriberOptions.java | 1 +
.../apache/beam/sdk/io/gcp/pubsublite/Uuid.java | 1 +
.../gcp/pubsublite/UuidDeduplicationOptions.java | 1 +
.../beam/sdk/io/gcp/spanner/BatchSpannerRead.java | 1 +
.../sdk/io/gcp/spanner/CreateTransactionFn.java | 1 +
.../beam/sdk/io/gcp/spanner/NaiveSpannerRead.java | 1 +
.../beam/sdk/io/gcp/spanner/ReadOperation.java | 1 +
.../beam/sdk/io/gcp/spanner/ReadSpannerSchema.java | 1 +
.../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 1 +
.../beam/sdk/io/gcp/spanner/SpannerConfig.java | 4 +-
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 1 +
.../beam/sdk/io/gcp/spanner/SpannerSchema.java | 1 +
.../beam/sdk/io/gcp/spanner/Transaction.java | 1 +
.../beam/sdk/io/gcp/testing/BigqueryClient.java | 1 +
.../beam/sdk/io/gcp/testing/BigqueryMatcher.java | 1 +
.../sdk/io/gcp/testing/FakeBigQueryServices.java | 1 +
.../sdk/io/gcp/testing/FakeDatasetService.java | 1 +
.../beam/sdk/io/gcp/testing/FakeJobService.java | 1 +
.../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryAvroUtilsTest.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryHelpersTest.java | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryIOReadIT.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryIOReadTest.java | 1 +
.../io/gcp/bigquery/BigQueryIOStorageQueryIT.java | 1 +
.../gcp/bigquery/BigQueryIOStorageQueryTest.java | 1 +
.../io/gcp/bigquery/BigQueryIOStorageReadIT.java | 1 +
.../bigquery/BigQueryIOStorageReadTableRowIT.java | 1 +
.../io/gcp/bigquery/BigQueryIOStorageReadTest.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryKmsKeyIT.java | 1 +
.../bigquery/BigQuerySchemaUpdateOptionsIT.java | 1 +
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 1 +
.../BigQueryTimePartitioningClusteringIT.java | 4 +-
.../sdk/io/gcp/bigquery/BigQueryToTableIT.java | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java | 1 +
.../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 1 +
.../sdk/io/gcp/bigtable/BigtableConfigTest.java | 1 +
.../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 1 +
.../io/gcp/bigtable/BigtableServiceImplTest.java | 1 +
.../beam/sdk/io/gcp/bigtable/BigtableWriteIT.java | 1 +
.../datastore/DataStoreV1SchemaIOProviderTest.java | 1 +
.../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 1 +
.../gcp/datastore/EntityToRowRowToEntityTest.java | 1 +
.../beam/sdk/io/gcp/datastore/SplitQueryFnIT.java | 1 +
.../apache/beam/sdk/io/gcp/datastore/V1ReadIT.java | 1 +
.../beam/sdk/io/gcp/datastore/V1TestUtil.java | 1 +
.../beam/sdk/io/gcp/datastore/V1WriteIT.java | 1 +
.../beam/sdk/io/gcp/healthcare/FhirIOLROIT.java | 1 +
.../beam/sdk/io/gcp/healthcare/FhirIOReadIT.java | 1 +
.../beam/sdk/io/gcp/healthcare/FhirIOTestUtil.java | 1 +
.../beam/sdk/io/gcp/healthcare/FhirIOWriteIT.java | 1 +
.../io/gcp/healthcare/HL7V2MessagePagesTest.java | 1 +
.../beam/sdk/io/gcp/healthcare/HL7v2IOReadIT.java | 1 +
.../sdk/io/gcp/healthcare/HL7v2IOReadWriteIT.java | 1 +
.../sdk/io/gcp/healthcare/HL7v2IOTestUtil.java | 1 +
.../beam/sdk/io/gcp/healthcare/HL7v2IOWriteIT.java | 1 +
.../sdk/io/gcp/pubsub/PubsubGrpcClientTest.java | 1 +
.../sdk/io/gcp/pubsub/PubsubIOExternalTest.java | 1 +
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 1 +
.../sdk/io/gcp/pubsub/PubsubJsonClientTest.java | 1 +
.../sdk/io/gcp/pubsub/PubsubMessageToRowTest.java | 1 +
.../sdk/io/gcp/pubsub/PubsubTestClientTest.java | 1 +
.../sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java | 1 +
.../io/gcp/pubsub/PubsubUnboundedSourceTest.java | 1 +
.../io/gcp/pubsublite/AddUuidsTransformTest.java | 1 +
.../sdk/io/gcp/pubsublite/FakeSerializable.java | 1 +
.../gcp/pubsublite/OffsetCheckpointMarkTest.java | 1 +
.../sdk/io/gcp/pubsublite/PubsubLiteSinkTest.java | 1 +
.../pubsublite/PubsubLiteUnboundedReaderTest.java | 1 +
.../sdk/io/gcp/spanner/FakeServiceFactory.java | 1 +
.../sdk/io/gcp/spanner/MutationKeyEncoderTest.java | 1 +
.../io/gcp/spanner/MutationSizeEstimatorTest.java | 1 +
.../beam/sdk/io/gcp/spanner/OrderedCodeTest.java | 1 +
.../sdk/io/gcp/spanner/ReadSpannerSchemaTest.java | 1 +
.../sdk/io/gcp/spanner/SpannerAccessorTest.java | 1 +
.../beam/sdk/io/gcp/spanner/SpannerIOReadTest.java | 1 +
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 1 +
.../beam/sdk/io/gcp/spanner/SpannerReadIT.java | 1 +
.../beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 1 +
.../beam/sdk/io/gcp/storage/GcsKmsKeyIT.java | 1 +
.../sdk/io/gcp/testing/BigqueryClientTest.java | 1 +
.../sdk/io/gcp/testing/BigqueryMatcherTest.java | 1 +
.../sdk/io/hadoop/SerializableConfiguration.java | 1 +
.../io/hadoop/SerializableConfigurationTest.java | 1 +
.../beam/sdk/io/hdfs/HadoopFileSystemModule.java | 1 +
.../beam/sdk/io/hdfs/HadoopFileSystemOptions.java | 5 +-
.../apache/beam/sdk/io/hdfs/HadoopResourceId.java | 1 +
.../sdk/io/hdfs/HadoopFileSystemRegistrarTest.java | 1 +
.../beam/sdk/io/hdfs/HadoopFileSystemTest.java | 1 +
.../beam/sdk/io/hdfs/HadoopResourceIdTest.java | 1 +
.../beam/sdk/io/hadoop/format/HadoopFormatIO.java | 1 +
.../beam/sdk/io/hadoop/format/HadoopFormats.java | 1 +
.../format/ConfigurableEmployeeInputFormat.java | 1 +
.../apache/beam/sdk/io/hadoop/format/Employee.java | 1 +
.../sdk/io/hadoop/format/EmployeeInputFormat.java | 1 +
.../sdk/io/hadoop/format/EmployeeOutputFormat.java | 1 +
.../io/hadoop/format/HDFSSynchronizationTest.java | 1 +
.../hadoop/format/HadoopFormatIOCassandraIT.java | 1 +
.../hadoop/format/HadoopFormatIOCassandraTest.java | 1 +
.../io/hadoop/format/HadoopFormatIOElasticIT.java | 1 +
.../sdk/io/hadoop/format/HadoopFormatIOIT.java | 1 +
.../io/hadoop/format/HadoopFormatIOReadTest.java | 1 +
.../format/HadoopFormatIOSequenceFileTest.java | 1 +
.../io/hadoop/format/HadoopFormatIOWriteTest.java | 1 +
.../sdk/io/hadoop/format/IterableCombinerTest.java | 1 +
.../format/ReuseObjectsEmployeeInputFormat.java | 1 +
.../sdk/io/hadoop/format/TestRowDBWritable.java | 1 +
.../java/org/apache/beam/sdk/io/hbase/HBaseIO.java | 1 +
.../org/apache/beam/sdk/io/hbase/HBaseIOIT.java | 1 +
.../org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 1 +
.../org/apache/beam/sdk/io/hcatalog/HCatToRow.java | 1 +
.../beam/sdk/io/hcatalog/HCatalogBeamSchema.java | 1 +
.../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 1 +
.../apache/beam/sdk/io/hcatalog/HCatalogUtils.java | 1 +
.../beam/sdk/io/hcatalog/PartitionPollerFn.java | 1 +
.../beam/sdk/io/hcatalog/PartitionReaderFn.java | 1 +
.../apache/beam/sdk/io/hcatalog/SchemaUtils.java | 1 +
.../sdk/io/hcatalog/HCatalogBeamSchemaTest.java | 1 +
.../apache/beam/sdk/io/hcatalog/HCatalogIOIT.java | 1 +
.../beam/sdk/io/hcatalog/HCatalogIOTest.java | 1 +
.../sdk/io/hcatalog/HiveDatabaseTestHelper.java | 1 +
.../beam/sdk/io/hcatalog/SchemaUtilsTest.java | 1 +
.../apache/beam/sdk/io/influxdb/InfluxDbIO.java | 1 +
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 1 +
.../beam/sdk/io/jdbc/JdbcSchemaIOProvider.java | 1 +
.../java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java | 1 +
.../org/apache/beam/sdk/io/jdbc/LogicalTypes.java | 1 +
.../org/apache/beam/sdk/io/jdbc/SchemaUtil.java | 1 +
.../java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java | 1 +
.../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 1 +
.../apache/beam/sdk/io/jdbc/JdbcTestHelper.java | 1 +
.../apache/beam/sdk/io/jdbc/SchemaUtilTest.java | 1 +
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 1 +
.../java/org/apache/beam/sdk/io/jms/JmsRecord.java | 1 +
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 1 +
...onfluentSchemaRegistryDeserializerProvider.java | 2 +
.../beam/sdk/io/kafka/KafkaCheckpointMark.java | 1 +
.../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 1 +
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 26 ++--
.../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 1 +
.../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 1 +
.../beam/sdk/io/kafka/KafkaSourceDescriptor.java | 1 +
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 1 +
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 1 +
.../org/apache/beam/sdk/io/kafka/KafkaWriter.java | 1 +
.../sdk/io/kafka/LocalDeserializerProvider.java | 1 +
.../beam/sdk/io/kafka/ProducerRecordCoder.java | 1 +
.../org/apache/beam/sdk/io/kafka/ProducerSpEL.java | 1 +
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 1 +
...uentSchemaRegistryDeserializerProviderTest.java | 1 +
.../CustomTimestampPolicyWithLimitedDelayTest.java | 1 +
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 1 +
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 1 +
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 1 +
.../apache/beam/sdk/io/kafka/KafkaIOUtilsTest.java | 1 +
.../beam/sdk/io/kafka/ProducerRecordCoderTest.java | 1 +
.../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 1 +
.../apache/beam/sdk/io/kinesis/KinesisReader.java | 1 +
.../apache/beam/sdk/io/kinesis/KinesisRecord.java | 1 +
.../apache/beam/sdk/io/kinesis/KinesisSource.java | 1 +
.../sdk/io/kinesis/KinesisTransformRegistrar.java | 21 +--
.../beam/sdk/io/kinesis/ShardCheckpoint.java | 1 +
.../beam/sdk/io/kinesis/ShardReadersPool.java | 1 +
.../sdk/io/kinesis/SimplifiedKinesisClient.java | 1 +
.../apache/beam/sdk/io/kinesis/StartingPoint.java | 1 +
.../sdk/io/kinesis/StartingPointShardsFinder.java | 1 +
.../beam/sdk/io/kinesis/AmazonKinesisMock.java | 1 +
.../io/kinesis/DynamicCheckpointGeneratorTest.java | 1 +
.../apache/beam/sdk/io/kinesis/KinesisIOIT.java | 1 +
.../beam/sdk/io/kinesis/KinesisMockWriteTest.java | 1 +
.../io/kinesis/KinesisReaderCheckpointTest.java | 1 +
.../beam/sdk/io/kinesis/KinesisReaderTest.java | 1 +
.../beam/sdk/io/kinesis/KinesisServiceMock.java | 1 +
.../beam/sdk/io/kinesis/RecordFilterTest.java | 1 +
.../beam/sdk/io/kinesis/ShardCheckpointTest.java | 1 +
.../beam/sdk/io/kinesis/ShardReadersPoolTest.java | 1 +
.../sdk/io/kinesis/ShardRecordsIteratorTest.java | 1 +
.../io/kinesis/SimplifiedKinesisClientTest.java | 1 +
.../io/kinesis/StartingPointShardsFinderTest.java | 1 +
.../java/org/apache/beam/sdk/io/kudu/KuduIO.java | 1 +
.../apache/beam/sdk/io/kudu/KuduServiceImpl.java | 1 +
.../java/org/apache/beam/sdk/io/kudu/KuduIOIT.java | 1 +
.../org/apache/beam/sdk/io/kudu/KuduIOTest.java | 1 +
.../org/apache/beam/sdk/io/mongodb/FindQuery.java | 1 +
.../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 1 +
.../org/apache/beam/sdk/io/mongodb/MongoDbIO.java | 1 +
.../org/apache/beam/sdk/io/mongodb/SSLUtils.java | 1 +
.../beam/sdk/io/mongodb/MongoDBGridFSIOTest.java | 1 +
.../apache/beam/sdk/io/mongodb/MongoDBIOIT.java | 1 +
.../apache/beam/sdk/io/mongodb/MongoDbIOTest.java | 1 +
.../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 1 +
.../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 1 +
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 1 +
.../sdk/io/parquet/ParquetSchemaIOProvider.java | 1 +
.../apache/beam/sdk/io/parquet/ParquetIOTest.java | 1 +
.../apache/beam/sdk/io/rabbitmq/RabbitMqIO.java | 1 +
.../beam/sdk/io/rabbitmq/RabbitMqMessage.java | 1 +
.../beam/sdk/io/rabbitmq/ExchangeTestPlan.java | 1 +
.../beam/sdk/io/rabbitmq/RabbitMqIOTest.java | 1 +
.../sdk/io/redis/RedisConnectionConfiguration.java | 1 +
.../java/org/apache/beam/sdk/io/redis/RedisIO.java | 1 +
.../org/apache/beam/sdk/io/redis/RedisIOTest.java | 1 +
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 1 +
.../crosslanguage/CrossLanguageConfiguration.java | 1 +
.../io/snowflake/crosslanguage/WriteBuilder.java | 1 +
.../sdk/io/snowflake/data/SnowflakeColumn.java | 1 +
.../io/snowflake/data/SnowflakeTableSchema.java | 1 +
.../io/snowflake/data/text/SnowflakeBinary.java | 1 +
.../io/snowflake/data/text/SnowflakeVarchar.java | 1 +
.../services/SnowflakeBatchServiceConfig.java | 1 +
.../services/SnowflakeBatchServiceImpl.java | 1 +
.../services/SnowflakeStreamingServiceImpl.java | 1 +
.../sdk/io/snowflake/test/BatchSnowflakeIOIT.java | 1 +
.../test/FakeSnowflakeBasicDataSource.java | 1 +
.../test/FakeSnowflakeBatchServiceImpl.java | 1 +
.../io/snowflake/test/FakeSnowflakeDatabase.java | 1 +
.../test/FakeSnowflakeStreamingServiceImpl.java | 1 +
.../io/snowflake/test/StreamingSnowflakeIOIT.java | 1 +
.../beam/sdk/io/snowflake/test/TestUtils.java | 1 +
.../test/unit/DataSourceConfigurationTest.java | 1 +
.../test/unit/read/SnowflakeIOReadTest.java | 1 +
.../test/unit/write/CreateDispositionTest.java | 1 +
.../unit/write/QueryDispositionLocationTest.java | 1 +
.../test/unit/write/SchemaDispositionTest.java | 1 +
.../test/unit/write/SnowflakeIOWriteTest.java | 1 +
.../test/unit/write/StreamingWriteTest.java | 1 +
.../beam/sdk/io/solr/AuthorizedSolrClient.java | 1 +
.../java/org/apache/beam/sdk/io/solr/SolrIO.java | 1 +
.../beam/sdk/io/solr/JavaBinCodecCoderTest.java | 1 +
.../org/apache/beam/sdk/io/solr/SolrIOTest.java | 1 +
.../beam/sdk/io/splunk/HttpEventPublisher.java | 1 +
.../org/apache/beam/sdk/io/splunk/SplunkEvent.java | 3 +-
.../beam/sdk/io/splunk/SplunkEventWriter.java | 1 +
.../org/apache/beam/sdk/io/splunk/SplunkIO.java | 1 +
.../beam/sdk/io/splunk/SplunkEventWriterTest.java | 1 +
.../apache/beam/sdk/io/splunk/SplunkIOTest.java | 1 +
.../sdk/io/synthetic/SyntheticBoundedSource.java | 1 +
.../beam/sdk/io/synthetic/SyntheticOptions.java | 1 +
.../sdk/io/synthetic/SyntheticSourceOptions.java | 1 +
.../sdk/io/synthetic/SyntheticUnboundedSource.java | 1 +
.../beam/sdk/io/synthetic/BundleSplitterTest.java | 1 +
.../io/synthetic/SyntheticBoundedSourceTest.java | 1 +
.../io/synthetic/SyntheticUnboundedSourceTest.java | 1 +
.../org/apache/beam/sdk/io/thrift/ThriftCoder.java | 1 +
.../org/apache/beam/sdk/io/thrift/ThriftIO.java | 1 +
.../beam/sdk/io/thrift/TestThriftStruct.java | 9 +-
.../apache/beam/sdk/io/thrift/ThriftIOTest.java | 1 +
.../org/apache/beam/sdk/io/tika/ParseResult.java | 1 +
.../java/org/apache/beam/sdk/io/tika/TikaIO.java | 1 +
.../org/apache/beam/sdk/io/tika/TikaIOTest.java | 1 +
.../java/org/apache/beam/sdk/io/xml/JAXBCoder.java | 1 +
.../java/org/apache/beam/sdk/io/xml/XmlIO.java | 1 +
.../java/org/apache/beam/sdk/io/xml/XmlSource.java | 1 +
.../org/apache/beam/sdk/io/xml/JAXBCoderTest.java | 1 +
.../java/org/apache/beam/sdk/io/xml/XmlIOTest.java | 1 +
.../org/apache/beam/sdk/io/xml/XmlSourceTest.java | 1 +
.../testing/expansion/TestExpansionService.java | 1 +
.../org/apache/beam/sdk/loadtests/LoadTest.java | 1 +
.../beam/sdk/loadtests/SyntheticDataPublisher.java | 1 +
.../java/org/apache/beam/sdk/nexmark/Main.java | 1 +
.../java/org/apache/beam/sdk/nexmark/Monitor.java | 1 +
.../beam/sdk/nexmark/NexmarkConfiguration.java | 1 +
.../apache/beam/sdk/nexmark/NexmarkLauncher.java | 1 +
.../apache/beam/sdk/nexmark/NexmarkOptions.java | 12 +-
.../apache/beam/sdk/nexmark/NexmarkQueryName.java | 5 +-
.../org/apache/beam/sdk/nexmark/NexmarkUtils.java | 1 +
.../org/apache/beam/sdk/nexmark/model/Auction.java | 1 +
.../apache/beam/sdk/nexmark/model/AuctionBid.java | 1 +
.../org/apache/beam/sdk/nexmark/model/Bid.java | 1 +
.../org/apache/beam/sdk/nexmark/model/Done.java | 1 +
.../org/apache/beam/sdk/nexmark/model/Event.java | 7 +-
.../beam/sdk/nexmark/model/IdNameReserve.java | 1 +
.../beam/sdk/nexmark/model/NameCityStateId.java | 1 +
.../org/apache/beam/sdk/nexmark/model/Person.java | 1 +
.../beam/sdk/nexmark/model/sql/SelectEvent.java | 1 +
.../sdk/nexmark/queries/BoundedSideInputJoin.java | 1 +
.../beam/sdk/nexmark/queries/NexmarkQuery.java | 1 +
.../sdk/nexmark/queries/NexmarkQueryModel.java | 1 +
.../sdk/nexmark/queries/NexmarkQueryTransform.java | 1 +
.../beam/sdk/nexmark/queries/NexmarkQueryUtil.java | 1 +
.../apache/beam/sdk/nexmark/queries/Query0.java | 1 +
.../apache/beam/sdk/nexmark/queries/Query10.java | 1 +
.../apache/beam/sdk/nexmark/queries/Query3.java | 1 +
.../beam/sdk/nexmark/queries/Query3Model.java | 1 +
.../beam/sdk/nexmark/queries/Query4Model.java | 1 +
.../beam/sdk/nexmark/queries/Query5Model.java | 1 +
.../beam/sdk/nexmark/queries/Query6Model.java | 1 +
.../beam/sdk/nexmark/queries/Query7Model.java | 1 +
.../beam/sdk/nexmark/queries/Query8Model.java | 1 +
.../apache/beam/sdk/nexmark/queries/Query9.java | 1 +
.../sdk/nexmark/queries/SessionSideInputJoin.java | 1 +
.../nexmark/queries/SessionSideInputJoinModel.java | 1 +
.../beam/sdk/nexmark/queries/WinningBids.java | 1 +
.../sdk/nexmark/queries/WinningBidsSimulator.java | 1 +
.../queries/sql/SqlBoundedSideInputJoin.java | 1 +
.../beam/sdk/nexmark/queries/sql/SqlQuery0.java | 1 +
.../sdk/nexmark/sources/UnboundedEventSource.java | 1 +
.../apache/beam/sdk/nexmark/NexmarkUtilsTest.java | 1 +
.../beam/sdk/nexmark/PerfsToBigQueryTest.java | 1 +
.../testutils/publishing/InfluxDBPublisher.java | 1 +
.../sdk/testutils/publishing/InfluxDBSettings.java | 1 +
.../sdk/testutils/fakes/FakeBigQueryClient.java | 1 +
.../fakes/FakeBigQueryResultsPublisher.java | 1 +
.../testutils/jvmverification/JvmVerification.java | 1 +
.../publishing/BigQueryResultsPublisherTest.java | 1 +
sdks/python/apache_beam/coders/coder_impl.py | 51 +++++--
sdks/python/apache_beam/coders/coders.py | 47 ++++++-
.../apache_beam/coders/coders_test_common.py | 36 +++++
.../apache_beam/coders/standard_coders_test.py | 4 +
.../avro_record.py => utils/sharded_key.py} | 42 ++++--
1989 files changed, 2658 insertions(+), 299 deletions(-)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ShardedKey.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/util/ShardedKeyTest.java
copy sdks/python/apache_beam/{coders/avro_record.py => utils/sharded_key.py}
(53%)
