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