You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/06/09 04:01:21 UTC
[beam] branch nightly-refs/heads/master updated (163bafdd217 -> 4ffeae4d2b8)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 163bafdd217 Fix typos in README (#17675)
add e02362d131d Fix for increased FAILED_PRECONDITION errors in BQ Read API.
add 414f299594d Merge branch 'master' into offsets-issue
add ea0015d34a4 Adding comments.
add 3778799a0fe Merge pull request #21739: Fix for increased FAILED_PRECONDITION errors in BQ Read API.
add a1c3d0cd60d Bump google.golang.org/api from 0.81.0 to 0.83.0 in /sdks (#21743)
add cd966ec35b6 Add ability to self-assign issues for non-committers (#21719)
add fd8af19798b Dont try to generate jiras as part of dependency report (#21753)
add 6ae198aae76 Allow users to comment `.take-issue` without taking (#21755)
add 8bcc3e035a3 Gather metrics on GH Issues
add f31d7926790 Fixes
add 1a769fc0c23 Fixes
add fd631ce45b4 Comment + naming fix
add e2cae4fb2da Conflicts fix
add c49bdc1016e Ordering
add 7c87b3c1c7f Different fallback for prs/issues
add c2ca2620495 Fix sync time
add 6c6b5f74f23 Merge pull request #21736 from damccorm/users/damccorm/metrics
add b0d964c4309 Merge pull request: [Beam-14528]: Add ISO time format support for Timestamp, Date, DateTime, Time field.
add 4ffeae4d2b8 Update all links to in progress jiras to issues (#21749)
No new revisions were added by this update.
Summary of changes:
.github/workflows/self-assign.yml | 45 ++++
.../dependency_check_report_generator.py | 17 +-
.../dependency_check_report_generator_test.py | 29 +-
.../jenkins/dependency_check/generate_report.sh | 5 +-
.../dependency_check/report_generator_config.py | 5 -
.test-infra/jenkins/jira_utils/__init__.py | 16 --
.test-infra/jenkins/jira_utils/jira_client.py | 132 ----------
.test-infra/jenkins/jira_utils/jira_manager.py | 293 ---------------------
.../jenkins/jira_utils/jira_manager_test.py | 254 ------------------
.test-infra/jenkins/job_Dependency_Check.groovy | 6 -
.test-infra/metrics/sync/github/queries.py | 58 ++++
.test-infra/metrics/sync/github/sync.py | 205 ++++++++++----
CHANGES.md | 16 +-
.../apache/beam/examples/common/ExampleUtils.java | 2 +-
.../beam/examples/complete/AutoComplete.java | 2 +-
.../beam/examples/complete/TrafficMaxLaneFlow.java | 2 +-
.../beam/examples/complete/TrafficRoutes.java | 2 +-
.../examples/complete/game/StatefulTeamScore.java | 2 +-
.../beam/examples/complete/game/UserScore.java | 2 +-
.../examples/complete/game/injector/Injector.java | 2 +-
.../complete/game/utils/WriteToBigQuery.java | 2 +-
.../examples/complete/game/utils/WriteToText.java | 2 +-
.../beam/examples/cookbook/TriggerExample.java | 2 +-
.../apache/beam/examples/snippets/Snippets.java | 4 +-
.../transforms/io/gcp/bigquery/BigQueryMyData.java | 2 +-
.../configuration/SubProcessConfiguration.java | 2 +-
.../kernel/SubProcessCommandLineArgs.java | 2 +-
.../subprocess/kernel/SubProcessKernel.java | 2 +-
.../examples/subprocess/utils/ExecutableFile.java | 2 +-
.../beam/examples/subprocess/utils/FileUtils.java | 2 +-
.../complete/game/HourlyTeamScoreTest.java | 2 +-
.../transforms/python/elementwise/pardo-py.ipynb | 2 +-
gradle.properties | 2 +-
.../construction/AvroGenericCoderRegistrar.java | 2 +-
.../core/construction/CoderTranslation.java | 4 +-
.../construction/CoderTranslatorRegistrar.java | 2 +-
.../core/construction/CombineTranslation.java | 2 +-
.../CreatePCollectionViewTranslation.java | 2 +-
.../core/construction/DefaultArtifactResolver.java | 2 +-
.../core/construction/DisplayDataTranslation.java | 2 +-
.../runners/core/construction/Environments.java | 2 +-
.../beam/runners/core/construction/External.java | 4 +-
.../core/construction/ExternalTranslation.java | 2 +-
.../core/construction/FlattenTranslator.java | 2 +-
.../core/construction/ForwardingPTransform.java | 4 +-
.../core/construction/GroupByKeyTranslation.java | 2 +-
.../construction/GroupIntoBatchesTranslation.java | 2 +-
.../core/construction/ImpulseTranslation.java | 2 +-
.../core/construction/ModelCoderRegistrar.java | 4 +-
.../core/construction/PTransformMatchers.java | 2 +-
.../core/construction/PTransformReplacements.java | 2 +-
.../core/construction/PTransformTranslation.java | 4 +-
.../core/construction/ParDoTranslation.java | 2 +-
.../runners/core/construction/ReadTranslation.java | 2 +-
.../core/construction/RehydratedComponents.java | 2 +-
.../core/construction/ReplacementOutputs.java | 2 +-
.../core/construction/ReshuffleTranslation.java | 2 +-
.../core/construction/RunnerPCollectionView.java | 2 +-
.../runners/core/construction/SdkComponents.java | 2 +-
.../construction/SerializablePipelineOptions.java | 2 +-
.../runners/core/construction/SplittableParDo.java | 2 +-
.../construction/SplittableParDoNaiveBounded.java | 2 +-
.../core/construction/TestStreamTranslation.java | 2 +-
.../beam/runners/core/construction/Timer.java | 4 +-
.../TransformPayloadTranslatorRegistrar.java | 2 +-
.../core/construction/TriggerTranslation.java | 4 +-
.../UnboundedReadFromBoundedSource.java | 4 +-
.../runners/core/construction/UnconsumedReads.java | 2 +-
.../core/construction/WindowIntoTranslation.java | 2 +-
.../core/construction/WriteFilesTranslation.java | 4 +-
.../graph/GreedyPCollectionFusers.java | 2 +-
.../construction/graph/GreedyPipelineFuser.java | 2 +-
.../core/construction/graph/GreedyStageFuser.java | 2 +-
.../runners/core/construction/graph/Networks.java | 2 +-
.../construction/graph/OutputDeduplicator.java | 2 +-
.../graph/ProjectionPushdownOptimizer.java | 2 +-
.../core/construction/graph/QueryablePipeline.java | 2 +-
.../graph/SplittableParDoExpander.java | 2 +-
.../graph/TrivialNativeTransformExpander.java | 2 +-
.../construction/renderer/PipelineDotRenderer.java | 2 +-
.../renderer/PortablePipelineDotRenderer.java | 2 +-
.../core/construction/CoderTranslationTest.java | 2 +-
.../core/construction/MorePipelineTest.java | 2 +-
.../core/construction/PTransformMatchersTest.java | 2 +-
.../core/construction/ParDoTranslationTest.java | 2 +-
.../core/construction/PipelineTranslationTest.java | 2 +-
.../construction/RehydratedComponentsTest.java | 2 +-
.../UnsupportedOverrideFactoryTest.java | 2 +-
.../WindowingStrategyTranslationTest.java | 2 +-
.../construction/graph/OutputDeduplicatorTest.java | 2 +-
.../org/apache/beam/runners/core/DoFnRunners.java | 2 +-
.../beam/runners/core/GlobalCombineFnRunners.java | 2 +-
.../runners/core/GroupByKeyViaGroupByKeyOnly.java | 2 +-
.../core/InMemoryMultimapSideInputView.java | 4 +-
.../beam/runners/core/InMemoryStateInternals.java | 4 +-
.../beam/runners/core/InMemoryTimerInternals.java | 2 +-
.../runners/core/LateDataDroppingDoFnRunner.java | 2 +-
.../apache/beam/runners/core/LateDataUtils.java | 4 +-
.../beam/runners/core/MergingActiveWindowSet.java | 2 +-
...TimeBoundedSplittableProcessElementInvoker.java | 4 +-
.../apache/beam/runners/core/PaneInfoTracker.java | 2 +-
.../beam/runners/core/PeekingReiterator.java | 2 +-
.../apache/beam/runners/core/ProcessFnRunner.java | 2 +-
.../beam/runners/core/ReduceFnContextFactory.java | 2 +-
.../apache/beam/runners/core/ReduceFnRunner.java | 4 +-
.../apache/beam/runners/core/SideInputHandler.java | 4 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 4 +-
.../core/SimplePushbackSideInputDoFnRunner.java | 2 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 2 +-
.../org/apache/beam/runners/core/StateMerging.java | 2 +-
.../org/apache/beam/runners/core/StateTable.java | 4 +-
.../org/apache/beam/runners/core/StateTags.java | 2 +-
.../beam/runners/core/StatefulDoFnRunner.java | 4 +-
.../apache/beam/runners/core/SystemReduceFn.java | 2 +-
.../runners/core/TestInMemoryStateInternals.java | 4 +-
.../apache/beam/runners/core/WatermarkHold.java | 2 +-
.../runners/core/metrics/DefaultMetricResults.java | 2 +-
.../core/metrics/ExecutionStateTracker.java | 2 +-
.../beam/runners/core/metrics/MetricUpdates.java | 2 +-
.../runners/core/metrics/MetricsContainerImpl.java | 2 +-
.../beam/runners/core/metrics/MetricsMap.java | 2 +-
.../beam/runners/core/metrics/MetricsPusher.java | 2 +-
.../runners/core/metrics/SimpleExecutionState.java | 2 +-
.../runners/core/metrics/SimpleStateRegistry.java | 2 +-
.../core/triggers/AfterAllStateMachine.java | 2 +-
.../AfterDelayFromFirstElementStateMachine.java | 4 +-
.../core/triggers/AfterEachStateMachine.java | 2 +-
.../core/triggers/AfterFirstStateMachine.java | 2 +-
.../core/triggers/AfterWatermarkStateMachine.java | 2 +-
.../core/triggers/DefaultTriggerStateMachine.java | 2 +-
.../triggers/ExecutableTriggerStateMachine.java | 2 +-
.../core/triggers/OrFinallyStateMachine.java | 2 +-
.../core/triggers/RepeatedlyStateMachine.java | 2 +-
.../runners/core/triggers/TriggerStateMachine.java | 2 +-
.../TriggerStateMachineContextFactory.java | 2 +-
...BoundedSplittableProcessElementInvokerTest.java | 2 +-
.../apache/beam/runners/core/ReduceFnTester.java | 2 +-
.../beam/runners/core/SimpleDoFnRunnerTest.java | 2 +-
.../SimplePushbackSideInputDoFnRunnerTest.java | 2 +-
.../beam/runners/core/StatefulDoFnRunnerTest.java | 2 +-
.../core/metrics/MonitoringInfoTestUtil.java | 2 +-
.../core/triggers/TriggerStateMachineTester.java | 6 +-
runners/direct-java/build.gradle | 10 +-
.../direct/BoundedReadEvaluatorFactory.java | 4 +-
.../beam/runners/direct/CloningBundleFactory.java | 2 +-
.../beam/runners/direct/CommittedResult.java | 2 +-
.../beam/runners/direct/CompletionCallback.java | 2 +-
.../direct/CopyOnAccessInMemoryStateInternals.java | 4 +-
.../direct/CreateViewNoopEvaluatorFactory.java | 6 +-
.../runners/direct/DirectExecutionContext.java | 4 +-
.../apache/beam/runners/direct/DirectGraph.java | 2 +-
.../beam/runners/direct/DirectGraphVisitor.java | 4 +-
.../apache/beam/runners/direct/DirectMetrics.java | 2 +-
.../apache/beam/runners/direct/DirectRunner.java | 2 +-
.../beam/runners/direct/DirectTimerInternals.java | 2 +-
.../runners/direct/DirectTransformExecutor.java | 2 +-
.../runners/direct/DirectWriteViewVisitor.java | 2 +-
.../beam/runners/direct/DisplayDataValidator.java | 2 +-
.../beam/runners/direct/EvaluationContext.java | 4 +-
.../direct/ExecutorServiceParallelExecutor.java | 2 +-
.../direct/GroupAlsoByWindowEvaluatorFactory.java | 4 +-
.../direct/GroupByKeyOnlyEvaluatorFactory.java | 4 +-
.../direct/ImmutabilityCheckingBundleFactory.java | 2 +-
.../direct/ImmutabilityEnforcementFactory.java | 4 +-
.../runners/direct/ImmutableListBundleFactory.java | 2 +-
.../runners/direct/KeyedPValueTrackingVisitor.java | 4 +-
.../beam/runners/direct/MultiStepCombine.java | 4 +-
.../apache/beam/runners/direct/ParDoEvaluator.java | 4 +-
.../beam/runners/direct/ParDoEvaluatorFactory.java | 2 +-
.../runners/direct/ParDoMultiOverrideFactory.java | 2 +-
.../beam/runners/direct/QuiescenceDriver.java | 4 +-
.../beam/runners/direct/RootProviderRegistry.java | 4 +-
.../beam/runners/direct/SideInputContainer.java | 4 +-
.../SplittableProcessElementsEvaluatorFactory.java | 2 +-
.../direct/StatefulParDoEvaluatorFactory.java | 4 +-
.../beam/runners/direct/StepTransformResult.java | 4 +-
.../runners/direct/TestStreamEvaluatorFactory.java | 4 +-
.../runners/direct/TransformEvaluatorRegistry.java | 4 +-
.../runners/direct/TransformExecutorServices.java | 2 +-
.../beam/runners/direct/TransformResult.java | 2 +-
.../direct/UnboundedReadEvaluatorFactory.java | 4 +-
.../beam/runners/direct/ViewEvaluatorFactory.java | 2 +-
.../runners/direct/WatermarkCallbackExecutor.java | 2 +-
.../beam/runners/direct/WatermarkManager.java | 2 +-
.../runners/direct/WindowEvaluatorFactory.java | 2 +-
.../direct/BoundedReadEvaluatorFactoryTest.java | 2 +-
.../beam/runners/direct/DirectRunnerTest.java | 2 +-
.../runners/direct/DirectTimerInternalsTest.java | 2 +-
.../direct/DirectTransformExecutorTest.java | 2 +-
.../beam/runners/direct/EvaluationContextTest.java | 2 +-
.../ExecutorServiceParallelExecutorTest.java | 4 +-
.../direct/StatefulParDoEvaluatorFactoryTest.java | 2 +-
.../direct/TestStreamEvaluatorFactoryTest.java | 2 +-
.../direct/UnboundedReadEvaluatorFactoryTest.java | 2 +-
.../beam/runners/direct/WatermarkManagerTest.java | 4 +-
.../extensions/metrics/MetricsGraphiteSink.java | 2 +-
.../extensions/metrics/MetricsHttpSink.java | 4 +-
runners/flink/flink_runner.gradle | 6 +-
.../runners/flink/CreateStreamingFlinkView.java | 2 +-
.../flink/FlinkBatchPipelineTranslator.java | 4 +-
.../FlinkBatchPortablePipelineTranslator.java | 4 +-
.../flink/FlinkBatchTransformTranslators.java | 4 +-
.../flink/FlinkBatchTranslationContext.java | 2 +-
.../runners/flink/FlinkExecutionEnvironments.java | 4 +-
.../apache/beam/runners/flink/FlinkJobInvoker.java | 2 +-
.../beam/runners/flink/FlinkJobServerDriver.java | 2 +-
.../flink/FlinkPipelineExecutionEnvironment.java | 2 +-
.../beam/runners/flink/FlinkPipelineRunner.java | 2 +-
.../flink/FlinkPortableClientEntryPoint.java | 2 +-
.../org/apache/beam/runners/flink/FlinkRunner.java | 2 +-
.../beam/runners/flink/FlinkRunnerResult.java | 2 +-
.../flink/FlinkStreamingPipelineTranslator.java | 4 +-
.../FlinkStreamingPortablePipelineTranslator.java | 4 +-
.../flink/FlinkStreamingTransformTranslators.java | 10 +-
.../flink/FlinkStreamingTranslationContext.java | 2 +-
.../runners/flink/FlinkTransformOverrides.java | 2 +-
.../flink/PipelineTranslationModeOptimizer.java | 4 +-
.../apache/beam/runners/flink/TestFlinkRunner.java | 2 +-
.../beam/runners/flink/metrics/FileReporter.java | 2 +-
.../translation/functions/FlinkAssignContext.java | 2 +-
.../translation/functions/FlinkDoFnFunction.java | 2 +-
.../functions/FlinkExecutableStageFunction.java | 6 +-
.../FlinkExecutableStagePruningFunction.java | 2 +-
.../functions/FlinkNonMergingReduceFunction.java | 2 +-
.../functions/FlinkSideInputReader.java | 2 +-
.../functions/FlinkStatefulDoFnFunction.java | 4 +-
.../functions/ImpulseSourceFunction.java | 2 +-
.../functions/SideInputInitializer.java | 2 +-
.../functions/SingleWindowFlinkCombineRunner.java | 2 +-
.../functions/SortingFlinkCombineRunner.java | 2 +-
.../translation/types/CoderTypeInformation.java | 2 +-
.../translation/types/CoderTypeSerializer.java | 4 +-
.../translation/types/EncodedValueComparator.java | 4 +-
.../translation/utils/CountingPipelineVisitor.java | 2 +-
.../translation/wrappers/SourceInputFormat.java | 4 +-
.../translation/wrappers/SourceInputSplit.java | 2 +-
.../wrappers/streaming/DoFnOperator.java | 4 +-
.../streaming/ExecutableStageDoFnOperator.java | 4 +-
.../wrappers/streaming/SplittableDoFnOperator.java | 2 +-
.../wrappers/streaming/WindowDoFnOperator.java | 2 +-
.../wrappers/streaming/io/DedupingOperator.java | 2 +-
.../streaming/io/UnboundedSourceWrapper.java | 4 +-
.../streaming/stableinput/BufferedElements.java | 2 +-
.../streaming/stableinput/BufferingDoFnRunner.java | 4 +-
.../stableinput/KeyedBufferingElementsHandler.java | 2 +-
.../state/FlinkBroadcastStateInternals.java | 2 +-
.../streaming/state/FlinkStateInternals.java | 4 +-
.../FlinkPipelineExecutionEnvironmentTest.java | 2 +-
.../beam/runners/flink/FlinkSavepointTest.java | 2 +-
.../FlinkStreamingTransformTranslatorsTest.java | 2 +-
.../beam/runners/flink/FlinkSubmissionTest.java | 2 +-
.../flink/streaming/FlinkStateInternalsTest.java | 2 +-
.../functions/FlinkDoFnFunctionTest.java | 2 +-
.../FlinkExecutableStageFunctionTest.java | 2 +-
.../functions/FlinkStatefulDoFnFunctionTest.java | 2 +-
.../functions/ImpulseSourceFunctionTest.java | 2 +-
.../translation/types/CoderTypeSerializerTest.java | 2 +-
.../wrappers/SourceInputFormatTest.java | 2 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
.../wrappers/streaming/WindowDoFnOperatorTest.java | 2 +-
.../streaming/io/UnboundedSourceWrapperTest.java | 2 +-
.../stableinput/BufferedElementsTest.java | 2 +-
.../stableinput/BufferingDoFnRunnerTest.java | 2 +-
.../beam/runners/dataflow/BatchViewOverrides.java | 8 +-
.../beam/runners/dataflow/CreateDataflowView.java | 2 +-
.../beam/runners/dataflow/DataflowClient.java | 2 +-
.../beam/runners/dataflow/DataflowMetrics.java | 2 +-
.../dataflow/DataflowPTransformMatchers.java | 2 +-
.../beam/runners/dataflow/DataflowPipelineJob.java | 2 +-
.../dataflow/DataflowPipelineTranslator.java | 4 +-
.../beam/runners/dataflow/DataflowRunner.java | 6 +-
.../beam/runners/dataflow/DataflowRunnerInfo.java | 2 +-
.../runners/dataflow/GroupIntoBatchesOverride.java | 2 +-
.../dataflow/PrimitiveParDoSingleFactory.java | 4 +-
.../beam/runners/dataflow/TestDataflowRunner.java | 2 +-
.../beam/runners/dataflow/TransformTranslator.java | 2 +-
.../beam/runners/dataflow/internal/IsmFormat.java | 2 +-
.../dataflow/options/DataflowPipelineOptions.java | 2 +-
.../dataflow/options/DefaultGcpRegionFactory.java | 2 +-
.../util/AvroCoderCloudObjectTranslator.java | 2 +-
.../beam/runners/dataflow/util/CloudKnownType.java | 2 +-
.../beam/runners/dataflow/util/CloudObject.java | 2 +-
.../dataflow/util/CloudObjectTranslators.java | 4 +-
.../beam/runners/dataflow/util/CloudObjects.java | 4 +-
.../util/CoderCloudObjectTranslatorRegistrar.java | 2 +-
.../runners/dataflow/util/DataflowTemplateJob.java | 2 +-
...DefaultCoderCloudObjectTranslatorRegistrar.java | 2 +-
.../beam/runners/dataflow/util/PackageUtil.java | 2 +-
.../runners/dataflow/util/RandomAccessData.java | 2 +-
.../util/SchemaCoderCloudObjectTranslator.java | 2 +-
.../SerializableCoderCloudObjectTranslator.java | 2 +-
.../apache/beam/runners/dataflow/util/Structs.java | 2 +-
.../beam/runners/dataflow/util/TimeUtil.java | 2 +-
.../beam/runners/dataflow/DataflowMetricsTest.java | 2 +-
.../dataflow/DataflowPipelineTranslatorTest.java | 2 +-
.../runners/dataflow/util/CloudObjectsTest.java | 2 +-
.../dataflow/worker/ApplianceShuffleReader.java | 2 +-
.../dataflow/worker/ApplianceShuffleWriter.java | 2 +-
.../runners/dataflow/worker/AvroByteReader.java | 2 +-
.../dataflow/worker/AvroByteReaderFactory.java | 4 +-
.../dataflow/worker/AvroByteSinkFactory.java | 2 +-
.../dataflow/worker/BatchDataflowWorker.java | 2 +-
.../dataflow/worker/BatchModeExecutionContext.java | 4 +-
.../worker/BatchModeUngroupingParDoFn.java | 2 +-
.../worker/BeamFnMapTaskExecutorFactory.java | 4 +-
.../dataflow/worker/CombineValuesFnFactory.java | 4 +-
.../beam/runners/dataflow/worker/ConcatReader.java | 4 +-
.../dataflow/worker/ConcatReaderFactory.java | 4 +-
.../dataflow/worker/CounterShortIdCache.java | 4 +-
.../CreateIsmShardKeyAndSortKeyDoFnFactory.java | 4 +-
.../worker/DataflowElementExecutionTracker.java | 2 +-
.../dataflow/worker/DataflowExecutionContext.java | 2 +-
.../worker/DataflowExecutionStateRegistry.java | 2 +-
.../dataflow/worker/DataflowMetricsContainer.java | 4 +-
.../dataflow/worker/DataflowOperationContext.java | 2 +-
.../dataflow/worker/DataflowOutputCounter.java | 2 +-
.../worker/DataflowPortabilityPCollectionView.java | 2 +-
.../dataflow/worker/DataflowProcessFnRunner.java | 2 +-
.../dataflow/worker/DataflowRunnerHarness.java | 2 +-
.../worker/DataflowSideInputReadCounter.java | 4 +-
.../worker/DataflowWorkProgressUpdater.java | 2 +-
.../dataflow/worker/DataflowWorkUnitClient.java | 2 +-
.../worker/DataflowWorkerHarnessHelper.java | 2 +-
.../dataflow/worker/DoFnInstanceManagers.java | 2 +-
.../runners/dataflow/worker/ExperimentContext.java | 2 +-
...FetchAndFilterStreamingSideInputsOperation.java | 4 +-
.../beam/runners/dataflow/worker/Filepatterns.java | 2 +-
.../dataflow/worker/FnApiWindowMappingFn.java | 2 +-
.../worker/GroupAlsoByWindowParDoFnFactory.java | 4 +-
.../dataflow/worker/GroupAlsoByWindowsParDoFn.java | 2 +-
.../dataflow/worker/GroupingShuffleReader.java | 2 +-
.../worker/GroupingShuffleReaderFactory.java | 6 +-
...ingShuffleReaderWithFaultyBytesReadCounter.java | 2 +-
.../runners/dataflow/worker/InMemoryReader.java | 2 +-
.../dataflow/worker/InMemoryReaderFactory.java | 4 +-
.../worker/IntrinsicMapTaskExecutorFactory.java | 2 +-
.../beam/runners/dataflow/worker/IsmReader.java | 2 +-
.../runners/dataflow/worker/IsmReaderFactory.java | 4 +-
.../runners/dataflow/worker/IsmReaderImpl.java | 2 +-
.../dataflow/worker/IsmSideInputReader.java | 8 +-
.../beam/runners/dataflow/worker/IsmSink.java | 2 +-
.../runners/dataflow/worker/IsmSinkFactory.java | 2 +-
.../dataflow/worker/KeyTokenInvalidException.java | 2 +-
.../worker/MetricTrackingWindmillServerStub.java | 2 +-
.../worker/MetricsToCounterUpdateConverter.java | 2 +-
.../worker/NoOpSourceOperationExecutor.java | 2 +-
.../worker/PairWithConstantKeyDoFnFactory.java | 4 +-
.../dataflow/worker/PartialGroupByKeyParDoFns.java | 2 +-
.../dataflow/worker/PartitioningShuffleReader.java | 2 +-
.../worker/PartitioningShuffleReaderFactory.java | 4 +-
.../beam/runners/dataflow/worker/PubsubReader.java | 4 +-
.../beam/runners/dataflow/worker/PubsubSink.java | 4 +-
.../beam/runners/dataflow/worker/ReaderCache.java | 2 +-
.../runners/dataflow/worker/ReaderFactory.java | 2 +-
.../runners/dataflow/worker/ReaderRegistry.java | 4 +-
.../ReifyTimestampAndWindowsParDoFnFactory.java | 2 +-
...HarnessCoderCloudObjectTranslatorRegistrar.java | 4 +-
.../dataflow/worker/SdkHarnessRegistries.java | 2 +-
.../runners/dataflow/worker/ShuffleLibrary.java | 2 +-
.../beam/runners/dataflow/worker/ShuffleSink.java | 4 +-
.../dataflow/worker/ShuffleSinkFactory.java | 4 +-
.../dataflow/worker/SimpleDoFnRunnerFactory.java | 2 +-
.../runners/dataflow/worker/SimpleParDoFn.java | 4 +-
.../beam/runners/dataflow/worker/SinkFactory.java | 2 +-
.../beam/runners/dataflow/worker/SinkRegistry.java | 4 +-
.../dataflow/worker/SourceTranslationUtils.java | 2 +-
.../worker/SplittableProcessFnFactory.java | 2 +-
.../beam/runners/dataflow/worker/StateFetcher.java | 4 +-
.../dataflow/worker/StreamingDataflowWorker.java | 4 +-
.../StreamingKeyedWorkItemSideInputDoFnRunner.java | 2 +-
.../worker/StreamingModeExecutionContext.java | 2 +-
.../StreamingPCollectionViewWriterParDoFn.java | 2 +-
.../dataflow/worker/StreamingSideInputFetcher.java | 2 +-
.../worker/StreamingStepMetricsContainer.java | 2 +-
.../worker/ToIsmRecordForMultimapDoFnFactory.java | 4 +-
.../dataflow/worker/UngroupedShuffleReader.java | 2 +-
.../worker/UngroupedShuffleReaderFactory.java | 4 +-
.../dataflow/worker/UngroupedWindmillReader.java | 4 +-
.../dataflow/worker/UserParDoFnFactory.java | 4 +-
.../runners/dataflow/worker/ValuesDoFnFactory.java | 2 +-
.../dataflow/worker/WindmillKeyedWorkItem.java | 4 +-
.../worker/WindmillReaderIteratorBase.java | 2 +-
.../beam/runners/dataflow/worker/WindmillSink.java | 4 +-
.../dataflow/worker/WindmillStateInternals.java | 4 +-
.../dataflow/worker/WindmillStateReader.java | 4 +-
.../dataflow/worker/WindmillTimerInternals.java | 2 +-
.../dataflow/worker/WindowingWindmillReader.java | 6 +-
.../dataflow/worker/WorkItemStatusClient.java | 4 +-
.../WorkerCustomSourceOperationExecutor.java | 4 +-
.../dataflow/worker/WorkerCustomSources.java | 4 +-
.../worker/WorkerPipelineOptionsFactory.java | 2 +-
.../dataflow/worker/counters/CounterFactory.java | 2 +-
.../dataflow/worker/counters/CounterName.java | 2 +-
.../dataflow/worker/counters/CounterSet.java | 2 +-
.../counters/DataflowCounterUpdateExtractor.java | 2 +-
.../DistributionCounterUpdateAggregator.java | 2 +-
.../counters/MeanCounterUpdateAggregator.java | 2 +-
.../counters/SumCounterUpdateAggregator.java | 2 +-
.../worker/fn/control/BeamFnMapTaskExecutor.java | 4 +-
.../control/DataflowSideInputHandlerFactory.java | 2 +-
...ntMonitoringInfoToCounterUpdateTransformer.java | 2 +-
...meMonitoringInfoToCounterUpdateTransformer.java | 2 +-
...ntMonitoringInfoToCounterUpdateTransformer.java | 2 +-
.../fn/control/ProcessRemoteBundleOperation.java | 2 +-
.../control/RegisterAndProcessBundleOperation.java | 4 +-
...onMonitoringInfoToCounterUpdateTransformer.java | 2 +-
...erMonitoringInfoToCounterUpdateTransformer.java | 2 +-
.../worker/fn/data/BeamFnDataGrpcService.java | 2 +-
.../fn/data/RemoteGrpcPortReadOperation.java | 2 +-
.../fn/data/RemoteGrpcPortWriteOperation.java | 2 +-
.../worker/fn/logging/BeamFnLoggingService.java | 2 +-
.../fn/stream/ServerStreamObserverFactory.java | 2 +-
.../graph/CreateExecutableStageNodeFunction.java | 2 +-
.../graph/DeduceFlattenLocationsFunction.java | 2 +-
.../beam/runners/dataflow/worker/graph/Edges.java | 2 +-
...nsertFetchAndFilterStreamingSideInputNodes.java | 4 +-
.../worker/graph/MapTaskToNetworkFunction.java | 2 +-
.../runners/dataflow/worker/graph/Networks.java | 2 +-
.../beam/runners/dataflow/worker/graph/Nodes.java | 2 +-
.../worker/graph/RegisterNodeFunction.java | 2 +-
.../graph/RemoveFlattenInstructionsFunction.java | 2 +-
.../graph/ReplacePgbkWithPrecombineFunction.java | 2 +-
.../logging/DataflowWorkerLoggingHandler.java | 2 +-
.../logging/DataflowWorkerLoggingInitializer.java | 2 +-
.../worker/logging/DataflowWorkerLoggingMDC.java | 2 +-
.../JulHandlerPrintStreamAdapterFactory.java | 2 +-
.../options/StreamingDataflowWorkerOptions.java | 2 +-
.../dataflow/worker/profiler/ScopedProfiler.java | 2 +-
.../dataflow/worker/status/DebugCapture.java | 2 +-
.../dataflow/worker/status/WorkerStatusPages.java | 2 +-
.../dataflow/worker/util/BoundedQueueExecutor.java | 2 +-
.../dataflow/worker/util/CloudSourceUtils.java | 2 +-
.../dataflow/worker/util/MemoryMonitor.java | 2 +-
.../dataflow/worker/util/TimerOrElement.java | 4 +-
.../worker/util/common/TaggedReiteratorList.java | 2 +-
.../common/worker/BatchingShuffleEntryReader.java | 2 +-
.../common/worker/ByteArrayShufflePosition.java | 2 +-
.../common/worker/CachingShuffleBatchReader.java | 2 +-
.../worker/GroupingShuffleEntryIterator.java | 2 +-
.../common/worker/GroupingShuffleRangeTracker.java | 4 +-
.../worker/util/common/worker/GroupingTables.java | 2 +-
.../worker/util/common/worker/MapTaskExecutor.java | 2 +-
.../common/worker/OutputObjectAndByteCounter.java | 2 +-
.../worker/util/common/worker/ReadOperation.java | 4 +-
.../worker/util/common/worker/ShuffleEntry.java | 2 +-
.../util/common/worker/ShuffleReadCounter.java | 2 +-
.../worker/util/common/worker/WorkExecutor.java | 2 +-
.../util/common/worker/WorkProgressUpdater.java | 4 +-
.../worker/util/common/worker/WriteOperation.java | 2 +-
.../worker/windmill/GrpcWindmillServer.java | 6 +-
.../dataflow/worker/windmill/WindmillServer.java | 2 +-
.../worker/windmill/WindmillServerBase.java | 2 +-
.../worker/windmill/WindmillServerStub.java | 2 +-
.../dataflow/worker/AvroByteReaderFactoryTest.java | 2 +-
.../dataflow/worker/AvroByteReaderTest.java | 2 +-
.../worker/CombineValuesFnFactoryTest.java | 2 +-
.../runners/dataflow/worker/ConcatReaderTest.java | 2 +-
.../worker/DataflowSideInputReadCounterTest.java | 2 +-
.../dataflow/worker/DefaultParDoFnFactoryTest.java | 2 +-
.../dataflow/worker/FnApiWindowMappingFnTest.java | 2 +-
.../GroupAlsoByWindowParDoFnFactoryTest.java | 2 +-
.../dataflow/worker/GroupingShuffleReaderTest.java | 4 +-
.../IntrinsicMapTaskExecutorFactoryTest.java | 4 +-
.../runners/dataflow/worker/IsmReaderTest.java | 2 +-
.../LazilyInitializedSideInputReaderTest.java | 2 +-
.../worker/PartialGroupByKeyParDoFnsTest.java | 2 +-
.../runners/dataflow/worker/ReaderFactoryTest.java | 2 +-
.../dataflow/worker/ShuffleReaderFactoryTest.java | 2 +-
.../dataflow/worker/ShuffleSinkFactoryTest.java | 2 +-
...eamingPCollectionViewWriterDoFnFactoryTest.java | 2 +-
.../worker/StreamingSideInputFetcherTest.java | 2 +-
.../worker/StreamingStepMetricsContainerTest.java | 2 +-
.../dataflow/worker/UserParDoFnFactoryTest.java | 2 +-
.../worker/WindmillStateInternalsTest.java | 2 +-
.../fn/control/BeamFnMapTaskExecutorTest.java | 2 +-
.../DataflowSideInputHandlerFactoryTest.java | 2 +-
.../RegisterAndProcessBundleOperationTest.java | 2 +-
.../SingularProcessBundleProgressTrackerTest.java | 2 +-
.../runners/dataflow/worker/graph/NodesTest.java | 2 +-
.../dataflow/worker/util/ListOutputManager.java | 6 +-
.../util/common/worker/ExecutorTestUtils.java | 2 +-
.../worker/GroupingShuffleEntryIteratorTest.java | 2 +-
.../util/common/worker/WriteOperationTest.java | 2 +-
.../worker/windmill/GrpcWindmillServerTest.java | 2 +-
.../artifact/ArtifactRetrievalService.java | 2 +-
.../artifact/ArtifactStagingService.java | 2 +-
.../control/BundleCheckpointHandlers.java | 4 +-
.../control/DefaultJobBundleFactory.java | 4 +-
.../fnexecution/control/FnApiControlClient.java | 2 +-
.../control/FnApiControlClientPoolService.java | 2 +-
.../control/ProcessBundleDescriptors.java | 4 +-
...renceCountingExecutableStageContextFactory.java | 2 +-
.../runners/fnexecution/control/RemoteBundle.java | 2 +-
.../fnexecution/control/RemoteOutputReceiver.java | 2 +-
.../fnexecution/control/SdkHarnessClient.java | 4 +-
.../SingleEnvironmentInstanceJobBundleFactory.java | 2 +-
.../fnexecution/control/StageBundleFactory.java | 2 +-
.../fnexecution/control/TimerReceiverFactory.java | 4 +-
.../runners/fnexecution/data/GrpcDataService.java | 2 +-
.../fnexecution/environment/DockerCommand.java | 2 +-
.../environment/DockerEnvironmentFactory.java | 2 +-
.../environment/EmbeddedEnvironmentFactory.java | 4 +-
.../fnexecution/environment/ProcessManager.java | 2 +-
.../fnexecution/logging/GrpcLoggingService.java | 2 +-
.../provisioning/StaticGrpcProvisionService.java | 2 +-
.../state/InMemoryBagUserStateFactory.java | 4 +-
.../fnexecution/state/StateRequestHandlers.java | 4 +-
.../translation/BatchSideInputHandlerFactory.java | 2 +-
.../translation/PipelineTranslatorUtils.java | 4 +-
.../StreamingSideInputHandlerFactory.java | 4 +-
.../fnexecution/control/RemoteExecutionTest.java | 2 +-
.../fnexecution/control/SdkHarnessClientTest.java | 2 +-
.../fnexecution/state/GrpcStateServiceTest.java | 2 +-
.../state/StateRequestHandlersTest.java | 2 +-
.../runners/fnexecution/wire/CommonCoderTest.java | 2 +-
.../runners/jobsubmission/InMemoryJobService.java | 2 +-
.../beam/runners/jobsubmission/JobInvocation.java | 2 +-
.../beam/runners/jobsubmission/JobInvoker.java | 2 +-
.../runners/jobsubmission/JobServerDriver.java | 2 +-
.../jobsubmission/PortablePipelineJarCreator.java | 4 +-
.../jobsubmission/PortablePipelineJarUtils.java | 2 +-
.../org/apache/beam/runners/jet/DAGBuilder.java | 4 +-
.../apache/beam/runners/jet/JetGraphVisitor.java | 2 +-
.../apache/beam/runners/jet/JetPipelineResult.java | 2 +-
.../beam/runners/jet/JetTransformTranslator.java | 2 +-
.../beam/runners/jet/JetTransformTranslators.java | 4 +-
.../java/org/apache/beam/runners/jet/Utils.java | 4 +-
.../beam/runners/jet/metrics/JetMetricResults.java | 2 +-
.../runners/jet/processors/AbstractParDoP.java | 4 +-
.../beam/runners/jet/processors/AssignWindowP.java | 4 +-
.../runners/jet/processors/BoundedSourceP.java | 4 +-
.../beam/runners/jet/processors/FlattenP.java | 4 +-
.../beam/runners/jet/processors/ImpulseP.java | 4 +-
.../runners/jet/processors/StatefulParDoP.java | 4 +-
.../runners/jet/processors/UnboundedSourceP.java | 4 +-
.../apache/beam/runners/jet/processors/ViewP.java | 4 +-
.../beam/runners/jet/processors/WindowGroupP.java | 4 +-
.../org/apache/beam/runners/jet/TestJetRunner.java | 2 +-
.../org/apache/beam/runners/jet/TestStreamP.java | 2 +-
runners/portability/java/build.gradle | 18 +-
.../runners/portability/CloseableResource.java | 2 +-
.../portability/JobServicePipelineResult.java | 2 +-
.../beam/runners/portability/PortableMetrics.java | 2 +-
.../beam/runners/portability/PortableRunner.java | 2 +-
.../beam/runners/samza/SamzaExecutionContext.java | 2 +-
.../apache/beam/runners/samza/SamzaJobInvoker.java | 2 +-
.../beam/runners/samza/SamzaPipelineResult.java | 2 +-
.../org/apache/beam/runners/samza/SamzaRunner.java | 2 +-
.../runners/samza/SamzaRunnerOverrideConfigs.java | 2 +-
.../runners/samza/adapter/BoundedSourceSystem.java | 2 +-
.../samza/adapter/UnboundedSourceSystem.java | 4 +-
.../samza/container/BeamContainerRunner.java | 4 +-
.../samza/container/ContainerCfgLoader.java | 2 +-
.../samza/metrics/SamzaMetricsContainer.java | 2 +-
.../beam/runners/samza/runtime/BundleManager.java | 2 +-
.../apache/beam/runners/samza/runtime/DoFnOp.java | 4 +-
.../runtime/DoFnRunnerWithKeyedInternals.java | 4 +-
.../beam/runners/samza/runtime/GroupByKeyOp.java | 2 +-
.../beam/runners/samza/runtime/KeyedInternals.java | 4 +-
.../beam/runners/samza/runtime/KeyedTimerData.java | 4 +-
.../beam/runners/samza/runtime/OpAdapter.java | 2 +-
.../beam/runners/samza/runtime/OpMessage.java | 2 +-
.../runners/samza/runtime/SamzaAssignContext.java | 2 +-
.../runners/samza/runtime/SamzaDoFnRunners.java | 4 +-
.../samza/runtime/SamzaStoreStateInternals.java | 4 +-
.../samza/runtime/SamzaTimerInternalsFactory.java | 4 +-
.../SplittableParDoProcessKeyedElementsOp.java | 2 +-
.../runners/samza/translation/ConfigBuilder.java | 2 +-
.../runners/samza/translation/ConfigContext.java | 2 +-
.../samza/translation/GroupByKeyTranslator.java | 2 +-
.../samza/translation/ImpulseTranslator.java | 2 +-
.../runners/samza/translation/PViewToIdMapper.java | 4 +-
.../translation/ParDoBoundMultiTranslator.java | 4 +-
.../translation/PortableTranslationContext.java | 4 +-
.../translation/SamzaImpulseSystemFactory.java | 2 +-
.../samza/translation/SamzaPipelineTranslator.java | 4 +-
.../SamzaPortablePipelineTranslator.java | 4 +-
.../translation/SamzaTestStreamSystemFactory.java | 2 +-
.../samza/translation/SamzaTransformOverrides.java | 2 +-
.../translation/SplittableParDoTranslators.java | 4 +-
.../samza/translation/TranslationContext.java | 4 +-
.../beam/runners/samza/util/SamzaCoders.java | 2 +-
.../samza/util/SamzaPipelineTranslatorUtils.java | 2 +-
.../samza/adapter/UnboundedSourceSystemTest.java | 2 +-
.../runtime/SamzaStoreStateInternalsTest.java | 2 +-
.../runtime/SamzaTimerInternalsFactoryTest.java | 4 +-
.../samza/translation/SamzaImpulseSystemTest.java | 2 +-
.../streaming/DatasetSourceStreaming.java | 2 +-
.../streaming/DatasetSourceStreaming.java | 2 +-
.../apache/beam/runners/spark/SparkJobInvoker.java | 2 +-
.../runners/spark/SparkNativePipelineVisitor.java | 4 +-
.../beam/runners/spark/SparkPipelineResult.java | 4 +-
.../beam/runners/spark/SparkPipelineRunner.java | 2 +-
.../org/apache/beam/runners/spark/SparkRunner.java | 2 +-
.../beam/runners/spark/SparkRunnerDebugger.java | 2 +-
.../runners/spark/SparkTransformOverrides.java | 2 +-
.../apache/beam/runners/spark/TestSparkRunner.java | 2 +-
.../spark/aggregators/AggregatorsAccumulator.java | 2 +-
.../spark/aggregators/NamedAggregators.java | 2 +-
.../beam/runners/spark/coders/CoderHelpers.java | 2 +-
.../spark/coders/SparkRunnerKryoRegistrator.java | 2 +-
.../spark/coders/StatelessJavaSerializer.java | 4 +-
.../apache/beam/runners/spark/io/CreateStream.java | 2 +-
.../beam/runners/spark/io/MicrobatchSource.java | 2 +-
.../beam/runners/spark/io/SourceDStream.java | 2 +-
.../apache/beam/runners/spark/io/SourceRDD.java | 4 +-
.../runners/spark/io/SparkUnboundedSource.java | 2 +-
.../runners/spark/metrics/MetricsAccumulator.java | 2 +-
.../runners/spark/metrics/WithMetricsSupport.java | 4 +-
.../SparkGroupAlsoByWindowViaWindowSet.java | 2 +-
.../spark/stateful/SparkStateInternals.java | 2 +-
.../spark/stateful/SparkTimerInternals.java | 2 +-
.../runners/spark/stateful/StateSpecFunctions.java | 4 +-
.../SparkStructuredStreamingPipelineResult.java | 4 +-
.../SparkStructuredStreamingRunner.java | 2 +-
.../aggregators/AggregatorsAccumulator.java | 2 +-
.../aggregators/NamedAggregators.java | 2 +-
.../metrics/MetricsAccumulator.java | 2 +-
.../metrics/WithMetricsSupport.java | 4 +-
.../translation/AbstractTranslationContext.java | 4 +-
.../translation/PipelineTranslator.java | 2 +-
.../translation/SparkTransformOverrides.java | 2 +-
.../translation/TransformTranslator.java | 2 +-
.../batch/CombinePerKeyTranslatorBatch.java | 2 +-
.../translation/batch/DoFnFunction.java | 2 +-
.../translation/batch/FlattenTranslatorBatch.java | 2 +-
.../translation/batch/ParDoTranslatorBatch.java | 4 +-
.../translation/batch/PipelineTranslatorBatch.java | 4 +-
.../batch/WindowAssignTranslatorBatch.java | 2 +-
.../batch/functions/SparkSideInputReader.java | 4 +-
.../translation/helpers/EncoderHelpers.java | 2 +-
.../translation/helpers/MultiOutputCoder.java | 4 +-
.../translation/helpers/SideInputBroadcast.java | 2 +-
.../streaming/PipelineTranslatorStreaming.java | 4 +-
.../translation/utils/CachedSideInputReader.java | 2 +-
.../translation/utils/SideInputStorage.java | 2 +-
.../runners/spark/translation/BoundedDataset.java | 2 +-
.../spark/translation/EvaluationContext.java | 4 +-
.../GroupNonMergingWindowsFunctions.java | 2 +-
.../spark/translation/MultiDoFnFunction.java | 2 +-
.../SparkBatchPortablePipelineTranslator.java | 4 +-
.../SparkExecutableStageExtractionFunction.java | 2 +-
.../translation/SparkExecutableStageFunction.java | 4 +-
.../spark/translation/SparkPCollectionView.java | 4 +-
.../SparkStreamingPortablePipelineTranslator.java | 4 +-
.../spark/translation/SparkTranslationContext.java | 4 +-
.../spark/translation/TransformTranslator.java | 4 +-
.../spark/translation/TranslationUtils.java | 4 +-
.../translation/ValueAndCoderLazySerializable.java | 2 +-
.../spark/translation/streaming/Checkpoint.java | 2 +-
.../streaming/StreamingTransformTranslator.java | 4 +-
.../streaming/WatermarkSyncedDStream.java | 4 +-
.../runners/spark/util/CachedSideInputReader.java | 2 +-
.../runners/spark/util/GlobalWatermarkHolder.java | 6 +-
.../runners/spark/util/SideInputBroadcast.java | 2 +-
.../beam/runners/spark/util/SideInputStorage.java | 2 +-
.../beam/runners/spark/util/SparkCompat.java | 4 +-
.../runners/spark/util/SparkSideInputReader.java | 4 +-
.../org/apache/beam/runners/spark/CacheTest.java | 2 +-
.../coders/SparkRunnerKryoRegistratorTest.java | 2 +-
.../SparkExecutableStageFunctionTest.java | 2 +-
.../spark/translation/TransformTranslatorTest.java | 2 +-
.../ValueAndCoderLazySerializableTest.java | 2 +-
.../ResumeFromCheckpointStreamingTest.java | 2 +-
.../streaming/TrackStreamingSourcesTest.java | 2 +-
.../runners/twister2/BeamBatchTSetEnvironment.java | 2 +-
.../beam/runners/twister2/BeamBatchWorker.java | 4 +-
.../Twister2PipelineExecutionEnvironment.java | 4 +-
.../runners/twister2/Twister2PipelineResult.java | 2 +-
.../beam/runners/twister2/Twister2Runner.java | 4 +-
.../beam/runners/twister2/Twister2TestRunner.java | 2 +-
.../twister2/Twister2TranslationContext.java | 4 +-
.../wrappers/Twister2BoundedSource.java | 2 +-
.../translation/wrappers/Twister2EmptySource.java | 2 +-
.../translators/BatchTransformTranslator.java | 2 +-
.../translators/StreamTransformTranslator.java | 2 +-
.../Twister2BatchPipelineTranslator.java | 4 +-
.../batch/AssignWindowTranslatorBatch.java | 2 +-
.../translators/batch/FlattenTranslatorBatch.java | 2 +-
.../batch/GroupByKeyTranslatorBatch.java | 2 +-
.../batch/PCollectionViewTranslatorBatch.java | 2 +-
.../batch/ParDoMultiOutputTranslatorBatch.java | 4 +-
.../functions/AssignWindowsFunction.java | 2 +-
.../translators/functions/ByteToElemFunction.java | 2 +-
.../functions/ByteToWindowFunction.java | 2 +-
.../functions/ByteToWindowFunctionPrimitive.java | 2 +-
.../translators/functions/DoFnFunction.java | 4 +-
.../translators/functions/ElemToBytesFunction.java | 2 +-
.../functions/GroupByWindowFunction.java | 2 +-
.../translators/functions/MapToTupleFunction.java | 2 +-
.../translators/functions/OutputTagFilter.java | 2 +-
.../functions/Twister2SinkFunction.java | 2 +-
.../internal/SystemReduceFnBuffering.java | 2 +-
.../runners/twister2/utils/TranslationUtils.java | 2 +-
.../twister2/utils/Twister2AssignContext.java | 2 +-
.../twister2/utils/Twister2SideInputReader.java | 4 +-
sdks/go.mod | 10 +-
sdks/go.sum | 19 +-
.../src/main/resources/beam/checkstyle.xml | 5 +-
.../main/java/org/apache/beam/sdk/Pipeline.java | 2 +-
.../org/apache/beam/sdk/coders/AtomicCoder.java | 2 +-
.../java/org/apache/beam/sdk/coders/AvroCoder.java | 2 +-
.../org/apache/beam/sdk/coders/CoderProviders.java | 2 +-
.../org/apache/beam/sdk/coders/CoderRegistry.java | 2 +-
.../org/apache/beam/sdk/coders/DefaultCoder.java | 4 +-
.../org/apache/beam/sdk/coders/NullableCoder.java | 2 +-
.../apache/beam/sdk/coders/RowCoderGenerator.java | 2 +-
.../beam/sdk/coders/StringDelegateCoder.java | 2 +-
.../sdk/expansion/ExternalTransformRegistrar.java | 2 +-
.../main/java/org/apache/beam/sdk/io/AvroIO.java | 2 +-
.../apache/beam/sdk/io/AvroSchemaIOProvider.java | 2 +-
.../main/java/org/apache/beam/sdk/io/AvroSink.java | 2 +-
.../java/org/apache/beam/sdk/io/AvroSource.java | 2 +-
.../org/apache/beam/sdk/io/BlockBasedSource.java | 2 +-
.../sdk/io/BoundedReadFromUnboundedSource.java | 2 +-
.../apache/beam/sdk/io/ClassLoaderFileSystem.java | 2 +-
.../org/apache/beam/sdk/io/CompressedSource.java | 2 +-
.../beam/sdk/io/ConstantAvroDestination.java | 2 +-
.../org/apache/beam/sdk/io/CountingSource.java | 2 +-
.../apache/beam/sdk/io/DefaultFilenamePolicy.java | 2 +-
.../beam/sdk/io/DynamicFileDestinations.java | 2 +-
.../java/org/apache/beam/sdk/io/FileBasedSink.java | 2 +-
.../org/apache/beam/sdk/io/FileBasedSource.java | 2 +-
.../main/java/org/apache/beam/sdk/io/FileIO.java | 2 +-
.../java/org/apache/beam/sdk/io/FileSystems.java | 2 +-
.../org/apache/beam/sdk/io/GenerateSequence.java | 2 +-
.../org/apache/beam/sdk/io/LocalFileSystem.java | 4 +-
.../org/apache/beam/sdk/io/OffsetBasedSource.java | 2 +-
.../src/main/java/org/apache/beam/sdk/io/Read.java | 2 +-
.../beam/sdk/io/SerializableAvroCodecFactory.java | 2 +-
.../java/org/apache/beam/sdk/io/TFRecordIO.java | 2 +-
.../main/java/org/apache/beam/sdk/io/TextIO.java | 2 +-
.../apache/beam/sdk/io/TextRowCountEstimator.java | 2 +-
.../main/java/org/apache/beam/sdk/io/TextSink.java | 2 +-
.../java/org/apache/beam/sdk/io/TextSource.java | 2 +-
.../java/org/apache/beam/sdk/io/WriteFiles.java | 4 +-
.../apache/beam/sdk/io/fs/ResourceIdTester.java | 2 +-
.../beam/sdk/io/range/ByteKeyRangeTracker.java | 2 +-
.../beam/sdk/io/range/OffsetRangeTracker.java | 2 +-
.../org/apache/beam/sdk/metrics/MetricResult.java | 2 +-
.../beam/sdk/options/ExperimentalOptions.java | 2 +-
.../beam/sdk/options/PipelineOptionsFactory.java | 4 +-
.../beam/sdk/options/PipelineOptionsValidator.java | 2 +-
.../beam/sdk/options/ProxyInvocationHandler.java | 2 +-
.../org/apache/beam/sdk/options/ValueProvider.java | 2 +-
.../beam/sdk/runners/PTransformOverride.java | 2 +-
.../sdk/runners/PTransformOverrideFactory.java | 2 +-
.../beam/sdk/runners/TransformHierarchy.java | 2 +-
.../apache/beam/sdk/schemas/AutoValueSchema.java | 2 +-
.../apache/beam/sdk/schemas/AvroRecordSchema.java | 2 +-
.../apache/beam/sdk/schemas/CachingFactory.java | 2 +-
.../beam/sdk/schemas/FieldAccessDescriptor.java | 2 +-
.../beam/sdk/schemas/FieldTypeDescriptors.java | 2 +-
.../sdk/schemas/FieldValueTypeInformation.java | 2 +-
.../beam/sdk/schemas/FromRowUsingCreator.java | 2 +-
.../sdk/schemas/GetterBasedSchemaProvider.java | 2 +-
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 2 +-
.../java/org/apache/beam/sdk/schemas/Schema.java | 2 +-
.../org/apache/beam/sdk/schemas/SchemaCoder.java | 2 +-
.../beam/sdk/schemas/SchemaCoderHelpers.java | 2 +-
.../apache/beam/sdk/schemas/SchemaRegistry.java | 2 +-
.../apache/beam/sdk/schemas/SchemaTranslation.java | 2 +-
.../org/apache/beam/sdk/schemas/SchemaUtils.java | 2 +-
.../sdk/schemas/SetterBasedCreatorFactory.java | 2 +-
.../sdk/schemas/annotations/DefaultSchema.java | 4 +-
.../beam/sdk/schemas/annotations/SchemaCreate.java | 2 +-
.../sdk/schemas/annotations/SchemaFieldName.java | 2 +-
.../sdk/schemas/annotations/SchemaFieldNumber.java | 2 +-
.../beam/sdk/schemas/annotations/SchemaIgnore.java | 2 +-
.../apache/beam/sdk/schemas/logicaltypes/Date.java | 2 +-
.../beam/sdk/schemas/logicaltypes/DateTime.java | 2 +-
.../sdk/schemas/logicaltypes/EnumerationType.java | 2 +-
.../sdk/schemas/logicaltypes/MicrosInstant.java | 2 +-
.../sdk/schemas/logicaltypes/NanosDuration.java | 2 +-
.../sdk/schemas/logicaltypes/NanosInstant.java | 2 +-
.../beam/sdk/schemas/logicaltypes/OneOfType.java | 2 +-
.../logicaltypes/PassThroughLogicalType.java | 2 +-
.../apache/beam/sdk/schemas/logicaltypes/Time.java | 2 +-
.../parser/FieldAccessDescriptorParser.java | 2 +-
.../beam/sdk/schemas/transforms/AddFields.java | 2 +-
.../apache/beam/sdk/schemas/transforms/Cast.java | 2 +-
.../beam/sdk/schemas/transforms/CoGroup.java | 2 +-
.../beam/sdk/schemas/transforms/Convert.java | 2 +-
.../beam/sdk/schemas/transforms/DropFields.java | 2 +-
.../apache/beam/sdk/schemas/transforms/Filter.java | 2 +-
.../apache/beam/sdk/schemas/transforms/Group.java | 2 +-
.../apache/beam/sdk/schemas/transforms/Join.java | 2 +-
.../beam/sdk/schemas/transforms/RenameFields.java | 2 +-
.../sdk/schemas/transforms/SchemaAggregateFn.java | 2 +-
.../apache/beam/sdk/schemas/transforms/Select.java | 2 +-
.../beam/sdk/schemas/utils/AutoValueUtils.java | 2 +-
.../beam/sdk/schemas/utils/AvroByteBuddyUtils.java | 2 +-
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 2 +-
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 2 +-
.../beam/sdk/schemas/utils/ConvertHelpers.java | 2 +-
.../beam/sdk/schemas/utils/JavaBeanUtils.java | 2 +-
.../apache/beam/sdk/schemas/utils/POJOUtils.java | 4 +-
.../beam/sdk/schemas/utils/ReflectUtils.java | 2 +-
.../beam/sdk/schemas/utils/SchemaZipFold.java | 2 +-
.../sdk/schemas/utils/SelectByteBuddyHelpers.java | 2 +-
.../beam/sdk/schemas/utils/SelectHelpers.java | 2 +-
.../sdk/schemas/utils/StaticSchemaInference.java | 2 +-
.../java/org/apache/beam/sdk/state/StateSpec.java | 2 +-
.../java/org/apache/beam/sdk/state/StateSpecs.java | 2 +-
.../org/apache/beam/sdk/testing/Annotations.java | 2 +-
.../apache/beam/sdk/testing/CoderProperties.java | 2 +-
.../apache/beam/sdk/testing/CombineFnTester.java | 2 +-
.../beam/sdk/testing/FileChecksumMatcher.java | 2 +-
.../org/apache/beam/sdk/testing/JsonMatcher.java | 2 +-
.../java/org/apache/beam/sdk/testing/PAssert.java | 6 +-
.../apache/beam/sdk/testing/PaneExtractors.java | 2 +-
.../beam/sdk/testing/SerializableMatchers.java | 14 +-
.../apache/beam/sdk/testing/SourceTestUtils.java | 2 +-
.../apache/beam/sdk/testing/SuccessOrFailure.java | 2 +-
.../org/apache/beam/sdk/testing/TestPipeline.java | 2 +-
.../org/apache/beam/sdk/testing/TestStream.java | 2 +-
.../apache/beam/sdk/testing/WindowSupplier.java | 2 +-
.../beam/sdk/transforms/ApproximateQuantiles.java | 2 +-
.../org/apache/beam/sdk/transforms/Combine.java | 2 +-
.../org/apache/beam/sdk/transforms/CombineFns.java | 4 +-
.../org/apache/beam/sdk/transforms/Create.java | 2 +-
.../org/apache/beam/sdk/transforms/Distinct.java | 2 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 2 +-
.../beam/sdk/transforms/DoFnOutputReceivers.java | 2 +-
.../beam/sdk/transforms/DoFnSchemaInformation.java | 2 +-
.../org/apache/beam/sdk/transforms/DoFnTester.java | 2 +-
.../beam/sdk/transforms/FlatMapElements.java | 2 +-
.../beam/sdk/transforms/GroupIntoBatches.java | 2 +-
.../beam/sdk/transforms/InferableFunction.java | 2 +-
.../org/apache/beam/sdk/transforms/Latest.java | 2 +-
.../apache/beam/sdk/transforms/MapElements.java | 2 +-
.../java/org/apache/beam/sdk/transforms/Max.java | 2 +-
.../java/org/apache/beam/sdk/transforms/Min.java | 2 +-
.../java/org/apache/beam/sdk/transforms/ParDo.java | 2 +-
.../org/apache/beam/sdk/transforms/Partition.java | 2 +-
.../beam/sdk/transforms/PeriodicSequence.java | 2 +-
.../java/org/apache/beam/sdk/transforms/Regex.java | 2 +-
.../java/org/apache/beam/sdk/transforms/Reify.java | 2 +-
.../apache/beam/sdk/transforms/Requirements.java | 2 +-
.../org/apache/beam/sdk/transforms/Sample.java | 2 +-
.../beam/sdk/transforms/SerializableFunctions.java | 2 +-
.../apache/beam/sdk/transforms/SimpleFunction.java | 2 +-
.../org/apache/beam/sdk/transforms/ToString.java | 2 +-
.../java/org/apache/beam/sdk/transforms/Top.java | 2 +-
.../java/org/apache/beam/sdk/transforms/View.java | 6 +-
.../java/org/apache/beam/sdk/transforms/Wait.java | 2 +-
.../java/org/apache/beam/sdk/transforms/Watch.java | 4 +-
.../apache/beam/sdk/transforms/WithFailures.java | 2 +-
.../org/apache/beam/sdk/transforms/WithKeys.java | 2 +-
.../apache/beam/sdk/transforms/WithTimestamps.java | 6 +-
.../beam/sdk/transforms/display/DisplayData.java | 2 +-
.../beam/sdk/transforms/join/CoGbkResult.java | 2 +-
.../beam/sdk/transforms/join/UnionCoder.java | 2 +-
.../reflect/ByteBuddyDoFnInvokerFactory.java | 2 +-
.../reflect/ByteBuddyOnTimerInvokerFactory.java | 2 +-
.../beam/sdk/transforms/reflect/DoFnSignature.java | 2 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 2 +-
.../splittabledofn/ByteKeyRangeTracker.java | 2 +-
.../splittabledofn/GrowableOffsetRangeTracker.java | 2 +-
.../splittabledofn/OffsetRangeTracker.java | 2 +-
.../splittabledofn/RestrictionTracker.java | 2 +-
.../sdk/transforms/splittabledofn/SplitResult.java | 2 +-
.../splittabledofn/WatermarkEstimators.java | 2 +-
.../beam/sdk/transforms/windowing/AfterPane.java | 2 +-
.../transforms/windowing/AfterProcessingTime.java | 2 +-
.../windowing/AfterSynchronizedProcessingTime.java | 2 +-
.../sdk/transforms/windowing/AfterWatermark.java | 2 +-
.../sdk/transforms/windowing/GlobalWindows.java | 2 +-
.../windowing/MergeOverlappingIntervalWindows.java | 2 +-
.../beam/sdk/transforms/windowing/Never.java | 2 +-
.../transforms/windowing/TimestampCombiner.java | 2 +-
.../beam/sdk/transforms/windowing/Trigger.java | 2 +-
.../beam/sdk/transforms/windowing/Window.java | 2 +-
.../java/org/apache/beam/sdk/util/ApiSurface.java | 6 +-
.../org/apache/beam/sdk/util/AppliedCombineFn.java | 2 +-
.../java/org/apache/beam/sdk/util/CoderUtils.java | 4 +-
.../util/EmptyOnDeserializationThreadLocal.java | 2 +-
.../sdk/util/ExposedByteArrayOutputStream.java | 2 +-
.../sdk/util/FilePatternMatchingShardedFile.java | 2 +-
.../org/apache/beam/sdk/util/FluentBackoff.java | 2 +-
.../org/apache/beam/sdk/util/InstanceBuilder.java | 2 +-
.../java/org/apache/beam/sdk/util/MoreFutures.java | 2 +-
.../apache/beam/sdk/util/MutationDetectors.java | 2 +-
.../java/org/apache/beam/sdk/util/NameUtils.java | 2 +-
.../java/org/apache/beam/sdk/util/NoopLock.java | 2 +-
.../apache/beam/sdk/util/NumberedShardedFile.java | 2 +-
.../org/apache/beam/sdk/util/Preconditions.java | 2 +-
.../java/org/apache/beam/sdk/util/ReleaseInfo.java | 2 +-
.../java/org/apache/beam/sdk/util/RowJson.java | 2 +-
.../beam/sdk/util/SerializableThrowable.java | 2 +-
.../apache/beam/sdk/util/SerializableUtils.java | 2 +-
.../java/org/apache/beam/sdk/util/ShardedKey.java | 2 +-
.../java/org/apache/beam/sdk/util/StreamUtils.java | 2 +-
.../apache/beam/sdk/util/UserCodeException.java | 2 +-
.../java/org/apache/beam/sdk/util/ZipFiles.java | 2 +-
.../sdk/util/common/ElementByteSizeObserver.java | 2 +-
.../beam/sdk/util/common/ReflectHelpers.java | 2 +-
.../org/apache/beam/sdk/values/PCollection.java | 2 +-
.../apache/beam/sdk/values/PCollectionList.java | 2 +-
.../beam/sdk/values/PCollectionRowTuple.java | 2 +-
.../apache/beam/sdk/values/PCollectionTuple.java | 2 +-
.../apache/beam/sdk/values/PCollectionView.java | 2 +-
.../apache/beam/sdk/values/PCollectionViews.java | 2 +-
.../java/org/apache/beam/sdk/values/PValue.java | 2 +-
.../org/apache/beam/sdk/values/PValueBase.java | 2 +-
.../java/org/apache/beam/sdk/values/PValues.java | 2 +-
.../main/java/org/apache/beam/sdk/values/Row.java | 2 +-
.../java/org/apache/beam/sdk/values/RowUtils.java | 2 +-
.../org/apache/beam/sdk/values/RowWithGetters.java | 2 +-
.../apache/beam/sdk/values/TimestampedValue.java | 2 +-
.../org/apache/beam/sdk/values/TypeDescriptor.java | 2 +-
.../apache/beam/sdk/values/TypeDescriptors.java | 2 +-
.../org/apache/beam/sdk/values/TypeParameter.java | 2 +-
.../java/org/apache/beam/sdk/PipelineTest.java | 2 +-
.../java/org/apache/beam/sdk/io/AvroIOTest.java | 2 +-
.../beam/sdk/io/DefaultFilenamePolicyTest.java | 2 +-
.../org/apache/beam/sdk/io/FileBasedSinkTest.java | 8 +-
.../org/apache/beam/sdk/io/FileSystemsTest.java | 2 +-
.../apache/beam/sdk/io/LocalFileSystemTest.java | 4 +-
.../apache/beam/sdk/io/LocalResourceIdTest.java | 14 +-
.../test/java/org/apache/beam/sdk/io/ReadTest.java | 2 +-
.../org/apache/beam/sdk/io/TFRecordIOTest.java | 2 +-
.../org/apache/beam/sdk/io/TextIOReadTest.java | 2 +-
.../org/apache/beam/sdk/io/TextIOWriteTest.java | 2 +-
.../sdk/options/PipelineOptionsFactoryTest.java | 4 +-
.../sdk/options/ProxyInvocationHandlerTest.java | 6 +-
.../apache/beam/sdk/schemas/SchemaCoderTest.java | 2 +-
.../beam/sdk/schemas/SchemaRegistryTest.java | 2 +-
.../beam/sdk/schemas/transforms/CoGroupTest.java | 2 +-
.../beam/sdk/schemas/transforms/GroupTest.java | 2 +-
.../beam/sdk/schemas/transforms/JoinTestUtils.java | 2 +-
.../beam/sdk/schemas/utils/AvroUtilsTest.java | 2 +-
.../beam/sdk/schemas/utils/JavaBeanUtilsTest.java | 2 +-
.../beam/sdk/schemas/utils/POJOUtilsTest.java | 2 +-
.../beam/sdk/testing/FileChecksumMatcherTest.java | 6 +-
.../org/apache/beam/sdk/testing/PAssertTest.java | 2 +-
.../apache/beam/sdk/transforms/CombineTest.java | 4 +-
.../apache/beam/sdk/transforms/GroupByKeyTest.java | 2 +-
.../org/apache/beam/sdk/transforms/KeysTest.java | 4 +-
.../org/apache/beam/sdk/transforms/KvSwapTest.java | 2 +-
.../beam/sdk/transforms/ParDoLifecycleTest.java | 2 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 2 +-
.../beam/sdk/transforms/SplittableDoFnTest.java | 6 +-
.../org/apache/beam/sdk/transforms/TopTest.java | 4 +-
.../org/apache/beam/sdk/transforms/ValuesTest.java | 4 +-
.../sdk/transforms/reflect/DoFnInvokersTest.java | 2 +-
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 2 +-
.../GrowableOffsetRangeTrackerTest.java | 2 +-
.../splittabledofn/OffsetRangeTrackerTest.java | 2 +-
.../org/apache/beam/sdk/util/ApiSurfaceTest.java | 2 +-
.../util/FilePatternMatchingShardedFileTest.java | 2 +-
.../apache/beam/sdk/util/InstanceBuilderTest.java | 2 +-
.../beam/sdk/util/NumberedShardedFileTest.java | 2 +-
.../java/org/apache/beam/sdk/values/RowTest.java | 2 +-
.../sdk/expansion/service/ExpansionService.java | 2 +-
.../expansion/service/ExpansionServiceTest.java | 2 +-
.../beam/sdk/expansion/service/ExternalTest.java | 2 +-
.../core/client/operator/AssignEventTime.java | 4 +-
.../euphoria/core/client/operator/CountByKey.java | 4 +-
.../euphoria/core/client/operator/Distinct.java | 4 +-
.../euphoria/core/client/operator/Filter.java | 4 +-
.../euphoria/core/client/operator/FlatMap.java | 2 +-
.../euphoria/core/client/operator/FullJoin.java | 2 +-
.../euphoria/core/client/operator/Join.java | 2 +-
.../euphoria/core/client/operator/LeftJoin.java | 2 +-
.../euphoria/core/client/operator/MapElements.java | 2 +-
.../euphoria/core/client/operator/ReduceByKey.java | 4 +-
.../core/client/operator/ReduceWindow.java | 4 +-
.../euphoria/core/client/operator/RightJoin.java | 2 +-
.../euphoria/core/client/operator/SumByKey.java | 4 +-
.../euphoria/core/client/operator/TopPerKey.java | 2 +-
.../euphoria/core/client/operator/Union.java | 2 +-
.../core/client/operator/WindowBuilder.java | 2 +-
.../core/client/operator/base/Builders.java | 4 +-
.../euphoria/core/client/type/TypeUtils.java | 2 +-
.../translate/BroadcastHashJoinTranslator.java | 2 +-
.../translate/CompositeOperatorTranslator.java | 2 +-
.../euphoria/core/translate/ExtractKey.java | 2 +-
.../euphoria/core/translate/JoinTranslator.java | 2 +-
.../core/translate/LazyAccumulatorProvider.java | 2 +-
.../euphoria/core/translate/OperatorTransform.java | 2 +-
.../core/translate/OperatorTranslator.java | 2 +-
.../core/translate/ReduceByKeyTranslator.java | 4 +-
.../core/translate/SingleValueContext.java | 2 +-
.../core/translate/TimestampExtractTransform.java | 2 +-
.../euphoria/core/translate/UnionTranslator.java | 2 +-
.../translate/collector/AdaptableCollector.java | 2 +-
.../translate/collector/SingleValueCollector.java | 2 +-
.../provider/GenericTranslatorProvider.java | 2 +-
.../euphoria/core/util/InstanceUtils.java | 2 +-
.../euphoria/core/client/lib/SplitTest.java | 2 +-
.../core/client/operator/CountByKeyTest.java | 2 +-
.../core/client/operator/DistinctTest.java | 2 +-
.../euphoria/core/client/operator/FilterTest.java | 2 +-
.../euphoria/core/client/operator/FlatMapTest.java | 2 +-
.../euphoria/core/client/operator/JoinTest.java | 2 +-
.../core/client/operator/MapElementsTest.java | 2 +-
.../core/client/operator/ReduceByKeyTest.java | 2 +-
.../core/client/operator/ReduceWindowTest.java | 2 +-
.../core/client/operator/SumByKeyTest.java | 2 +-
.../core/client/operator/TopPerKeyTest.java | 2 +-
.../euphoria/core/client/operator/UnionTest.java | 2 +-
.../core/client/type/TypePropagationAssert.java | 2 +-
.../core/docs/DocumentationExamplesTest.java | 2 +-
.../core/testkit/BroadcastHashJoinTest.java | 2 +-
.../collector/SingleValueCollectorTest.java | 2 +-
.../core/translate/provider/ProviderTestUtils.java | 2 +-
.../extensions/gcp/auth/NoopCredentialFactory.java | 2 +-
.../sdk/extensions/gcp/options/GcpOptions.java | 2 +-
.../gcp/options/GoogleApiDebugOptions.java | 2 +-
.../sdk/extensions/gcp/storage/GcsFileSystem.java | 2 +-
.../sdk/extensions/gcp/util/CustomHttpErrors.java | 2 +-
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 2 +-
.../gcp/util/RetryHttpRequestInitializer.java | 2 +-
.../gcp/util/UploadIdResponseInterceptor.java | 2 +-
.../sdk/extensions/gcp/util/gcsfs/GcsPath.java | 2 +-
.../beam/sdk/extensions/jackson/AsJsons.java | 2 +-
.../beam/sdk/extensions/jackson/ParseJsons.java | 2 +-
.../beam/sdk/extensions/ml/AnnotateImages.java | 2 +-
.../beam/sdk/extensions/ml/AnnotateText.java | 2 +-
.../ml/AnnotateVideoBytesWithContextFn.java | 2 +-
.../beam/sdk/extensions/ml/AnnotateVideoFn.java | 2 +-
.../extensions/ml/AnnotateVideoFromBytesFn.java | 2 +-
.../sdk/extensions/ml/AnnotateVideoFromURIFn.java | 2 +-
.../ml/AnnotateVideoURIWithContextFn.java | 2 +-
.../beam/sdk/extensions/ml/DLPDeidentifyText.java | 2 +-
.../beam/sdk/extensions/ml/DLPInspectText.java | 2 +-
.../beam/sdk/extensions/ml/DLPReidentifyText.java | 2 +-
.../extensions/protobuf/ProtoByteBuddyUtils.java | 4 +-
.../beam/sdk/extensions/protobuf/ProtoCoder.java | 2 +-
.../beam/sdk/extensions/protobuf/ProtoDomain.java | 4 +-
.../protobuf/ProtoDynamicMessageSchema.java | 4 +-
.../extensions/protobuf/ProtoMessageSchema.java | 8 +-
.../protobuf/ProtoSchemaLogicalTypes.java | 2 +-
.../extensions/protobuf/ProtoSchemaTranslator.java | 2 +-
.../beam/sdk/extensions/protobuf/ProtobufUtil.java | 2 +-
.../protobuf/ProtoDynamicMessageSchemaTest.java | 2 +-
.../protobuf/ProtoSchemaTranslatorTest.java | 2 +-
.../sdk/extensions/python/bootstrap_beam_venv.py | 2 +-
.../ExternalSchemaIOTransformRegistrar.java | 2 +-
.../extensions/sketching/SketchFrequencies.java | 2 +-
.../sdk/extensions/sketching/TDigestQuantiles.java | 2 +-
.../sorter/BufferedExternalSorterTest.java | 2 +-
.../sdk/extensions/sorter/SorterTestUtils.java | 2 +-
.../sql/meta/provider/datacatalog/SchemaUtils.java | 4 +-
.../provider/hcatalog/HCatalogTableProvider.java | 2 +-
.../sql/meta/provider/hcatalog/package-info.java | 3 +-
.../sql/jdbc/BeamSqlLineTestingUtils.java | 2 +-
.../apache/beam/sdk/extensions/sql/BeamSqlCli.java | 2 +-
.../sdk/extensions/sql/example/model/Customer.java | 2 +-
.../sdk/extensions/sql/impl/BeamCalciteSchema.java | 2 +-
.../sql/impl/BeamCalciteSchemaFactory.java | 2 +-
.../sdk/extensions/sql/impl/BeamCalciteTable.java | 4 +-
.../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 4 +-
.../extensions/sql/impl/CalciteQueryPlanner.java | 4 +-
.../sdk/extensions/sql/impl/JdbcConnection.java | 2 +-
.../beam/sdk/extensions/sql/impl/JdbcDriver.java | 4 +-
.../beam/sdk/extensions/sql/impl/QueryPlanner.java | 2 +-
.../extensions/sql/impl/ScalarFunctionImpl.java | 4 +-
.../extensions/sql/impl/TVFSlidingWindowFn.java | 2 +-
.../extensions/sql/impl/TableResolutionUtils.java | 2 +-
.../beam/sdk/extensions/sql/impl/UdafImpl.java | 4 +-
.../beam/sdk/extensions/sql/impl/UdfImpl.java | 2 +-
.../sql/impl/UdfImplReflectiveFunctionBase.java | 2 +-
.../sdk/extensions/sql/impl/cep/CEPLiteral.java | 2 +-
.../sdk/extensions/sql/impl/cep/CEPPattern.java | 2 +-
.../beam/sdk/extensions/sql/impl/cep/CEPUtils.java | 2 +-
.../beam/sdk/extensions/sql/impl/nfa/NFA.java | 2 +-
.../sql/impl/parser/SqlCreateExternalTable.java | 2 +-
.../sql/impl/parser/SqlSetOptionBeam.java | 2 +-
.../extensions/sql/impl/planner/BeamRuleSets.java | 2 +-
.../sql/impl/planner/RelMdNodeStats.java | 2 +-
.../sql/impl/rel/AbstractBeamCalcRel.java | 2 +-
.../sql/impl/rel/BeamAggregationRel.java | 4 +-
.../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 4 +-
.../extensions/sql/impl/rel/BeamCoGBKJoinRel.java | 2 +-
.../sql/impl/rel/BeamEnumerableConverter.java | 2 +-
.../sql/impl/rel/BeamLogicalConvention.java | 2 +-
.../sdk/extensions/sql/impl/rel/BeamMatchRel.java | 4 +-
.../sdk/extensions/sql/impl/rel/BeamRelNode.java | 2 +-
.../sql/impl/rel/BeamSetOperatorRelBase.java | 4 +-
.../sdk/extensions/sql/impl/rel/BeamSortRel.java | 4 +-
.../extensions/sql/impl/rel/BeamSqlRelUtils.java | 2 +-
.../sql/impl/rel/BeamTableFunctionScanRel.java | 4 +-
.../extensions/sql/impl/rel/BeamUncollectRel.java | 2 +-
.../sdk/extensions/sql/impl/rel/BeamUnnestRel.java | 2 +-
.../sdk/extensions/sql/impl/rel/BeamWindowRel.java | 4 +-
.../impl/rule/BeamAggregateProjectMergeRule.java | 2 +-
.../sql/impl/rule/BeamAggregationRule.java | 4 +-
.../sql/impl/rule/BeamBasicAggregationRule.java | 2 +-
.../sql/impl/rule/BeamIOPushDownRule.java | 2 +-
.../sql/impl/rule/BeamTableFunctionScanRule.java | 2 +-
.../sql/impl/rule/JoinRelOptRuleCall.java | 2 +-
.../extensions/sql/impl/schema/BeamTableUtils.java | 2 +-
.../impl/transform/BeamBuiltinAggregations.java | 4 +-
.../transform/BeamBuiltinAnalyticFunctions.java | 4 +-
.../sql/impl/transform/BeamJoinTransforms.java | 2 +-
.../impl/transform/BeamSetOperatorsTransforms.java | 2 +-
.../transform/agg/AggregationCombineFnAdapter.java | 4 +-
.../sql/impl/transform/agg/CovarianceFn.java | 4 +-
.../sql/impl/transform/agg/VarianceFn.java | 2 +-
.../sql/impl/udf/BeamBuiltinFunctionProvider.java | 2 +-
.../impl/udf/BuiltinTrigonometricFunctions.java | 2 +-
.../sql/meta/provider/FullNameTableProvider.java | 2 +-
.../sql/meta/provider/ReadOnlyTableProvider.java | 2 +-
.../provider/SchemaIOTableProviderWrapper.java | 2 +-
.../sql/meta/provider/TableProvider.java | 2 +-
.../sql/meta/provider/UdfUdafProvider.java | 2 +-
.../provider/bigquery/BeamBigQuerySqlDialect.java | 2 +-
.../provider/bigquery/BeamSqlUnparseContext.java | 4 +-
.../sql/meta/provider/bigquery/BigQueryFilter.java | 2 +-
.../sql/meta/provider/bigquery/BigQueryTable.java | 4 +-
.../sql/meta/provider/kafka/BeamKafkaTable.java | 2 +-
.../sql/meta/provider/mongodb/MongoDbTable.java | 2 +-
.../sql/meta/provider/test/TestTableFilter.java | 2 +-
.../sql/meta/provider/test/TestTableProvider.java | 4 +-
.../sql/meta/provider/test/TestTableUtils.java | 2 +-
.../sql/meta/provider/test/TestUnboundedTable.java | 2 +-
.../sql/meta/provider/text/TextTable.java | 2 +-
.../sql/meta/provider/text/TextTableProvider.java | 2 +-
.../sql/meta/store/InMemoryMetaStore.java | 2 +-
.../sdk/extensions/sql/BeamComplexTypeTest.java | 6 +-
.../sql/BeamSqlDslSqlStdOperatorsTest.java | 4 +-
.../provider/pubsub/PubsubTableProviderIT.java | 2 +-
.../sdk/extensions/sql/zetasql/DateTimeUtils.java | 2 +-
.../sdk/extensions/sql/zetasql/QueryTrait.java | 2 +-
.../sdk/extensions/sql/zetasql/SqlAnalyzer.java | 2 +-
.../extensions/sql/zetasql/TableResolution.java | 2 +-
.../extensions/sql/zetasql/ZetaSQLPlannerImpl.java | 2 +-
.../sql/zetasql/ZetaSQLQueryPlanner.java | 4 +-
.../sql/zetasql/ZetaSqlBeamTranslationUtils.java | 2 +-
.../zetasql/ZetaSqlCalciteTranslationUtils.java | 2 +-
.../translation/AggregateScanConverter.java | 2 +-
.../translation/ArrayScanColumnRefToUncollect.java | 2 +-
.../zetasql/translation/ExpressionConverter.java | 2 +-
.../LimitOffsetScanToLimitConverter.java | 2 +-
.../LimitOffsetScanToOrderByLimitConverter.java | 2 +-
.../translation/QueryStatementConverter.java | 2 +-
.../translation/SqlNullIfOperatorRewriter.java | 2 +-
.../sql/zetasql/translation/SqlOperators.java | 2 +-
.../translation/SqlWindowTableFunction.java | 2 +-
.../sql/zetasql/translation/TVFScanConverter.java | 2 +-
.../zetasql/translation/WithRefScanConverter.java | 2 +-
.../zetasql/unnest/BeamZetaSqlUncollectRel.java | 2 +-
.../sql/zetasql/unnest/BeamZetaSqlUnnestRel.java | 2 +-
.../sql/zetasql/ZetaSQLPushDownTest.java | 2 +-
.../beam/sdk/extensions/zetasketch/HllCount.java | 2 +-
.../zetasketch/HllCountMergePartialFn.java | 2 +-
.../sdk/fn/data/BeamFnDataOutboundAggregator.java | 2 +-
.../sdk/fn/data/BeamFnDataOutboundObserver.java | 2 +-
.../server/GrpcContextHeaderAccessorProvider.java | 2 +-
.../apache/beam/sdk/fn/server/GrpcFnServer.java | 4 +-
.../apache/beam/sdk/fn/server/ServerFactory.java | 2 +-
.../sdk/fn/splittabledofn/RestrictionTrackers.java | 2 +-
.../org/apache/beam/sdk/fn/stream/DataStreams.java | 4 +-
.../org/apache/beam/sdk/fn/test/TestExecutors.java | 2 +-
.../fn/splittabledofn/RestrictionTrackersTest.java | 2 +-
.../beam/fn/harness/AssignWindowsRunner.java | 2 +-
.../beam/fn/harness/BeamFnDataReadRunner.java | 4 +-
.../beam/fn/harness/BeamFnDataWriteRunner.java | 4 +-
.../org/apache/beam/fn/harness/CombineRunners.java | 4 +-
.../org/apache/beam/fn/harness/FlattenRunner.java | 2 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 4 +-
.../java/org/apache/beam/fn/harness/FnHarness.java | 2 +-
.../org/apache/beam/fn/harness/MapFnRunners.java | 2 +-
.../beam/fn/harness/PTransformRunnerFactory.java | 2 +-
.../beam/fn/harness/PrecombineGroupingTable.java | 2 +-
.../apache/beam/fn/harness/ToStringFnRunner.java | 2 +-
.../beam/fn/harness/WindowMappingFnRunner.java | 2 +-
.../beam/fn/harness/WindowMergingFnRunner.java | 2 +-
.../fn/harness/control/FinalizeBundleHandler.java | 2 +-
.../fn/harness/control/ProcessBundleHandler.java | 4 +-
.../harness/data/PCollectionConsumerRegistry.java | 4 +-
.../apache/beam/fn/harness/state/BagUserState.java | 4 +-
.../harness/state/BeamFnStateGrpcClientCache.java | 2 +-
.../beam/fn/harness/state/FnApiStateAccessor.java | 4 +-
.../beam/fn/harness/state/IterableSideInput.java | 2 +-
.../beam/fn/harness/state/MultimapSideInput.java | 4 +-
.../beam/fn/harness/state/MultimapUserState.java | 4 +-
.../beam/fn/harness/state/SideInputSpec.java | 2 +-
.../beam/fn/harness/state/StateBackedIterable.java | 2 +-
.../fn/harness/state/StateFetchingIterators.java | 2 +-
.../beam/fn/harness/status/MemoryMonitor.java | 2 +-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 4 +-
.../harness/control/ProcessBundleHandlerTest.java | 2 +-
.../data/PCollectionConsumerRegistryTest.java | 2 +-
.../fn/harness/state/StateBackedIterableTest.java | 2 +-
.../apache/beam/sdk/io/aws/coders/AwsCoders.java | 2 +-
.../beam/sdk/io/aws/dynamodb/DynamoDBIO.java | 2 +-
.../apache/beam/sdk/io/aws/s3/S3FileSystem.java | 2 +-
.../io/aws/s3/S3ReadableSeekableByteChannel.java | 2 +-
.../apache/beam/sdk/io/aws/s3/S3ResourceId.java | 2 +-
.../beam/sdk/io/aws/s3/S3WritableByteChannel.java | 2 +-
.../beam/sdk/io/aws/sns/PublishResultCoders.java | 2 +-
.../java/org/apache/beam/sdk/io/aws/sns/SnsIO.java | 2 +-
.../beam/sdk/io/aws/sqs/SqsCheckpointMark.java | 2 +-
.../beam/sdk/io/aws/sqs/SqsConfiguration.java | 2 +-
.../java/org/apache/beam/sdk/io/aws/sqs/SqsIO.java | 2 +-
.../beam/sdk/io/aws/sqs/SqsUnboundedReader.java | 2 +-
.../beam/sdk/io/aws/sqs/SqsUnboundedSource.java | 2 +-
.../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java | 2 +-
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 2 +-
.../beam/sdk/io/aws2/kinesis/KinesisReader.java | 2 +-
.../beam/sdk/io/aws2/kinesis/KinesisRecord.java | 2 +-
.../beam/sdk/io/aws2/kinesis/KinesisSource.java | 2 +-
.../beam/sdk/io/aws2/kinesis/ShardCheckpoint.java | 2 +-
.../beam/sdk/io/aws2/kinesis/ShardReadersPool.java | 2 +-
.../io/aws2/kinesis/SimplifiedKinesisClient.java | 2 +-
.../beam/sdk/io/aws2/kinesis/StartingPoint.java | 2 +-
.../apache/beam/sdk/io/aws2/kinesis/TimeUtil.java | 2 +-
.../apache/beam/sdk/io/aws2/s3/S3FileSystem.java | 2 +-
.../io/aws2/s3/S3ReadableSeekableByteChannel.java | 2 +-
.../apache/beam/sdk/io/aws2/s3/S3ResourceId.java | 2 +-
.../beam/sdk/io/aws2/s3/S3WritableByteChannel.java | 2 +-
.../org/apache/beam/sdk/io/aws2/sns/SnsIO.java | 6 +-
.../beam/sdk/io/aws2/sns/SnsResponseCoder.java | 2 +-
.../beam/sdk/io/aws2/sqs/SqsCheckpointMark.java | 2 +-
.../org/apache/beam/sdk/io/aws2/sqs/SqsIO.java | 2 +-
.../beam/sdk/io/aws2/sqs/SqsUnboundedReader.java | 2 +-
.../beam/sdk/io/aws2/sqs/SqsUnboundedSource.java | 2 +-
.../beam/sdk/io/aws2/s3/MatchResultMatcher.java | 2 +-
.../beam/sdk/io/aws2/s3/S3FileSystemTest.java | 2 +-
.../beam/sdk/io/aws2/s3/S3ResourceIdTest.java | 2 +-
.../sdk/io/aws2/s3/S3WritableByteChannelTest.java | 2 +-
.../beam/sdk/io/aws2/s3/SSECustomerKeyTest.java | 2 +-
.../java/org/apache/beam/sdk/io/amqp/AmqpIO.java | 2 +-
.../sdk/io/azure/blobstore/AzfsResourceId.java | 2 +-
.../azure/blobstore/AzureBlobStoreFileSystem.java | 2 +-
.../DefaultBlobstoreClientBuilderFactory.java | 2 +-
.../beam/sdk/io/azure/options/AzureModule.java | 2 +-
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 4 +-
.../beam/sdk/io/cassandra/ConnectionManager.java | 2 +-
.../beam/sdk/io/cassandra/DefaultObjectMapper.java | 2 +-
.../io/cassandra/DefaultObjectMapperFactory.java | 4 +-
.../org/apache/beam/sdk/io/cassandra/ReadFn.java | 4 +-
.../apache/beam/sdk/io/cassandra/RingRange.java | 2 +-
.../beam/sdk/io/cassandra/CassandraIOTest.java | 2 +-
.../beam/sdk/io/clickhouse/ClickHouseIO.java | 2 +-
.../beam/sdk/io/clickhouse/ClickHouseWriter.java | 2 +-
.../apache/beam/sdk/io/clickhouse/TableSchema.java | 2 +-
.../beam/sdk/io/clickhouse/BaseClickHouseTest.java | 2 +-
.../sdk/io/contextualtextio/ContextualTextIO.java | 2 +-
.../contextualtextio/ContextualTextIOSource.java | 2 +-
.../io/contextualtextio/RecordWithMetadata.java | 2 +-
.../io/debezium/DebeziumTransformRegistrar.java | 2 +-
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 2 +-
.../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 6 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 2 +-
.../io/gcp/bigquery/BigQuerySchemaIOProvider.java | 2 +-
.../BigQuerySchemaTransformReadConfiguration.java | 2 +-
.../BigQuerySchemaTransformReadProvider.java | 2 +-
.../BigQuerySchemaTransformWriteProvider.java | 2 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 2 +-
.../gcp/bigquery/BigQueryStorageStreamSource.java | 5 +
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 2 +-
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 33 ++-
.../beam/sdk/io/gcp/bigtable/BigtableConfig.java | 2 +-
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 2 +-
.../sdk/io/gcp/bigtable/BigtableReadOptions.java | 2 +-
.../sdk/io/gcp/bigtable/BigtableServiceImpl.java | 2 +-
.../sdk/io/gcp/bigtable/BigtableWriteResult.java | 2 +-
.../gcp/datastore/DataStoreV1SchemaIOProvider.java | 2 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 2 +-
.../beam/sdk/io/gcp/datastore/EntityToRow.java | 2 +-
.../beam/sdk/io/gcp/datastore/RowToEntity.java | 2 +-
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 2 +-
.../apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java | 2 +-
.../beam/sdk/io/gcp/healthcare/HL7v2Message.java | 2 +-
.../sdk/io/gcp/healthcare/HealthcareIOError.java | 2 +-
.../io/gcp/healthcare/HealthcareIOErrorCoder.java | 2 +-
.../healthcare/HealthcareIOErrorToTableRow.java | 2 +-
.../io/gcp/healthcare/HttpHealthcareApiClient.java | 2 +-
.../beam/sdk/io/gcp/healthcare/JsonArrayCoder.java | 2 +-
.../sdk/io/gcp/pubsub/AddTimestampAttribute.java | 2 +-
.../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 2 +-
.../io/gcp/pubsub/PubSubPayloadTranslation.java | 4 +-
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java | 2 +-
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubMessage.java | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java | 2 +-
...bsubMessageWithAttributesAndMessageIdCoder.java | 2 +-
.../pubsub/PubsubMessageWithAttributesCoder.java | 2 +-
.../pubsub/PubsubMessageWithMessageIdCoder.java | 2 +-
.../sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java | 2 +-
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 2 +-
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 2 +-
.../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 2 +-
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 2 +-
.../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java | 2 +-
.../gcp/pubsublite/UuidDeduplicationOptions.java | 2 +-
.../io/gcp/pubsublite/internal/PubsubLiteSink.java | 2 +-
.../beam/sdk/io/gcp/pubsublite/internal/Uuid.java | 2 +-
.../beam/sdk/io/gcp/spanner/BatchSpannerRead.java | 2 +-
.../sdk/io/gcp/spanner/CreateTransactionFn.java | 2 +-
.../beam/sdk/io/gcp/spanner/NaiveSpannerRead.java | 2 +-
.../beam/sdk/io/gcp/spanner/ReadOperation.java | 2 +-
.../beam/sdk/io/gcp/spanner/ReadSpannerSchema.java | 2 +-
.../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 2 +-
.../beam/sdk/io/gcp/spanner/SpannerConfig.java | 2 +-
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 2 +-
.../beam/sdk/io/gcp/spanner/SpannerSchema.java | 2 +-
.../beam/sdk/io/gcp/spanner/StructUtils.java | 2 +-
.../beam/sdk/io/gcp/spanner/Transaction.java | 2 +-
.../dofn/DetectNewPartitionsDoFn.java | 4 +-
.../DetectNewPartitionsRangeTracker.java | 2 +-
.../ReadChangeStreamPartitionRangeTracker.java | 2 +-
.../restriction/TimestampRangeTracker.java | 2 +-
.../beam/sdk/io/gcp/testing/BigqueryClient.java | 2 +-
.../beam/sdk/io/gcp/testing/BigqueryMatcher.java | 2 +-
.../sdk/io/gcp/testing/FakeBigQueryServices.java | 2 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 2 +-
.../beam/sdk/io/gcp/testing/FakeJobService.java | 2 +-
.../gcp/bigquery/BeamRowToStorageApiProtoTest.java | 2 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 2 +-
.../gcp/bigquery/TableRowToStorageApiProtoIT.java | 2 +-
.../bigquery/TableRowToStorageApiProtoTest.java | 88 ++++++-
...storeV1FnBatchWriteWithDeadLetterQueueTest.java | 2 +-
.../FirestoreV1FnBatchWriteWithSummaryTest.java | 2 +-
.../sdk/io/gcp/firestore/RpcQosOptionsTest.java | 2 +-
.../sdk/io/hadoop/SerializableConfiguration.java | 2 +-
.../beam/sdk/io/hdfs/HadoopFileSystemModule.java | 2 +-
.../beam/sdk/io/hdfs/HadoopFileSystemOptions.java | 2 +-
.../apache/beam/sdk/io/hdfs/HadoopResourceId.java | 2 +-
.../beam/sdk/io/hadoop/format/HadoopFormatIO.java | 4 +-
.../beam/sdk/io/hadoop/format/HadoopFormats.java | 2 +-
.../io/hadoop/format/HadoopFormatIOReadTest.java | 2 +-
.../java/org/apache/beam/sdk/io/hbase/HBaseIO.java | 2 +-
.../org/apache/beam/sdk/io/hcatalog/HCatToRow.java | 2 +-
.../beam/sdk/io/hcatalog/HCatalogBeamSchema.java | 2 +-
.../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 5 +-
.../apache/beam/sdk/io/hcatalog/HCatalogUtils.java | 2 +-
.../beam/sdk/io/hcatalog/PartitionPollerFn.java | 2 +-
.../beam/sdk/io/hcatalog/PartitionReaderFn.java | 2 +-
.../apache/beam/sdk/io/hcatalog/SchemaUtils.java | 2 +-
.../apache/beam/sdk/io/hcatalog/package-info.java | 3 +-
.../apache/beam/sdk/io/influxdb/InfluxDbIO.java | 2 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 4 +-
.../beam/sdk/io/jdbc/JdbcSchemaIOProvider.java | 2 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java | 2 +-
.../org/apache/beam/sdk/io/jdbc/LogicalTypes.java | 2 +-
.../org/apache/beam/sdk/io/jdbc/SchemaUtil.java | 2 +-
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 2 +-
.../java/org/apache/beam/sdk/io/jms/JmsRecord.java | 2 +-
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 2 +-
...onfluentSchemaRegistryDeserializerProvider.java | 8 +-
.../beam/sdk/io/kafka/KafkaCheckpointMark.java | 2 +-
.../beam/sdk/io/kafka/KafkaCommitOffset.java | 4 +-
.../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 4 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 4 +-
.../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 2 +-
.../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 4 +-
.../beam/sdk/io/kafka/KafkaSourceDescriptor.java | 2 +-
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 4 +-
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 2 +-
.../org/apache/beam/sdk/io/kafka/KafkaWriter.java | 2 +-
.../sdk/io/kafka/LocalDeserializerProvider.java | 2 +-
.../beam/sdk/io/kafka/ProducerRecordCoder.java | 4 +-
.../org/apache/beam/sdk/io/kafka/ProducerSpEL.java | 2 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 4 +-
...uentSchemaRegistryDeserializerProviderTest.java | 2 +-
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 2 +-
.../apache/beam/sdk/io/kafka/KafkaIOUtilsTest.java | 2 +-
.../beam/sdk/io/kafka/KafkaRecordCoderTest.java | 2 +-
.../beam/sdk/io/kafka/ProducerRecordCoderTest.java | 2 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 2 +-
.../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 2 +-
.../apache/beam/sdk/io/kinesis/KinesisReader.java | 2 +-
.../apache/beam/sdk/io/kinesis/KinesisRecord.java | 2 +-
.../apache/beam/sdk/io/kinesis/KinesisSource.java | 2 +-
.../sdk/io/kinesis/KinesisTransformRegistrar.java | 2 +-
.../beam/sdk/io/kinesis/ShardCheckpoint.java | 2 +-
.../beam/sdk/io/kinesis/ShardReadersPool.java | 2 +-
.../sdk/io/kinesis/SimplifiedKinesisClient.java | 2 +-
.../apache/beam/sdk/io/kinesis/StartingPoint.java | 2 +-
.../java/org/apache/beam/sdk/io/kudu/KuduIO.java | 4 +-
.../org/apache/beam/sdk/io/kudu/KuduService.java | 2 +-
.../apache/beam/sdk/io/kudu/KuduServiceImpl.java | 4 +-
.../org/apache/beam/sdk/io/mongodb/FindQuery.java | 2 +-
.../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 2 +-
.../org/apache/beam/sdk/io/mongodb/MongoDbIO.java | 2 +-
.../org/apache/beam/sdk/io/mongodb/SSLUtils.java | 2 +-
.../beam/sdk/io/mongodb/UpdateConfiguration.java | 2 +-
.../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 2 +-
.../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 4 +-
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 4 +-
.../apache/beam/sdk/io/rabbitmq/RabbitMqIO.java | 2 +-
.../beam/sdk/io/rabbitmq/RabbitMqMessage.java | 2 +-
.../sdk/io/redis/RedisConnectionConfiguration.java | 2 +-
.../java/org/apache/beam/sdk/io/redis/RedisIO.java | 2 +-
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 2 +-
.../crosslanguage/CrossLanguageConfiguration.java | 2 +-
.../io/snowflake/crosslanguage/WriteBuilder.java | 2 +-
.../sdk/io/snowflake/data/SnowflakeColumn.java | 2 +-
.../io/snowflake/data/SnowflakeTableSchema.java | 2 +-
.../io/snowflake/data/text/SnowflakeBinary.java | 2 +-
.../io/snowflake/data/text/SnowflakeVarchar.java | 2 +-
.../services/SnowflakeBatchServiceConfig.java | 2 +-
.../services/SnowflakeBatchServiceImpl.java | 2 +-
.../services/SnowflakeStreamingServiceImpl.java | 2 +-
.../beam/sdk/io/solr/AuthorizedSolrClient.java | 4 +-
.../java/org/apache/beam/sdk/io/solr/SolrIO.java | 4 +-
.../org/apache/beam/sdk/io/solr/SolrIOTest.java | 2 +-
.../apache/beam/sdk/io/solr/SolrIOTestUtils.java | 2 +-
.../beam/sdk/io/splunk/HttpEventPublisher.java | 2 +-
.../beam/sdk/io/splunk/SplunkEventWriter.java | 2 +-
.../org/apache/beam/sdk/io/splunk/SplunkIO.java | 2 +-
.../sdk/io/synthetic/SyntheticBoundedSource.java | 2 +-
.../beam/sdk/io/synthetic/SyntheticOptions.java | 2 +-
.../sdk/io/synthetic/SyntheticSourceOptions.java | 2 +-
.../sdk/io/synthetic/SyntheticUnboundedSource.java | 2 +-
.../beam/sdk/io/synthetic/BundleSplitterTest.java | 2 +-
.../org/apache/beam/sdk/io/thrift/ThriftCoder.java | 2 +-
.../org/apache/beam/sdk/io/thrift/ThriftIO.java | 2 +-
.../org/apache/beam/sdk/io/tika/ParseResult.java | 2 +-
.../java/org/apache/beam/sdk/io/tika/TikaIO.java | 2 +-
.../java/org/apache/beam/sdk/io/xml/JAXBCoder.java | 2 +-
.../java/org/apache/beam/sdk/io/xml/XmlIO.java | 2 +-
.../java/org/apache/beam/sdk/io/xml/XmlSource.java | 2 +-
.../testing/expansion/TestExpansionService.java | 2 +-
.../apache/beam/sdk/loadtests/CombineLoadTest.java | 2 +-
.../org/apache/beam/sdk/loadtests/LoadTest.java | 2 +-
.../beam/sdk/loadtests/SyntheticDataPublisher.java | 4 +-
.../java/org/apache/beam/sdk/nexmark/Main.java | 4 +-
.../java/org/apache/beam/sdk/nexmark/Monitor.java | 2 +-
.../beam/sdk/nexmark/NexmarkConfiguration.java | 2 +-
.../apache/beam/sdk/nexmark/NexmarkLauncher.java | 6 +-
.../apache/beam/sdk/nexmark/NexmarkQueryName.java | 2 +-
.../org/apache/beam/sdk/nexmark/NexmarkUtils.java | 2 +-
.../org/apache/beam/sdk/nexmark/model/Auction.java | 2 +-
.../apache/beam/sdk/nexmark/model/AuctionBid.java | 2 +-
.../org/apache/beam/sdk/nexmark/model/Bid.java | 2 +-
.../org/apache/beam/sdk/nexmark/model/Done.java | 2 +-
.../org/apache/beam/sdk/nexmark/model/Event.java | 2 +-
.../beam/sdk/nexmark/model/IdNameReserve.java | 2 +-
.../beam/sdk/nexmark/model/NameCityStateId.java | 2 +-
.../org/apache/beam/sdk/nexmark/model/Person.java | 2 +-
.../beam/sdk/nexmark/model/sql/SelectEvent.java | 2 +-
.../sdk/nexmark/queries/BoundedSideInputJoin.java | 2 +-
.../beam/sdk/nexmark/queries/NexmarkQuery.java | 2 +-
.../sdk/nexmark/queries/NexmarkQueryModel.java | 2 +-
.../sdk/nexmark/queries/NexmarkQueryTransform.java | 2 +-
.../beam/sdk/nexmark/queries/NexmarkQueryUtil.java | 2 +-
.../apache/beam/sdk/nexmark/queries/Query0.java | 2 +-
.../apache/beam/sdk/nexmark/queries/Query10.java | 2 +-
.../apache/beam/sdk/nexmark/queries/Query13.java | 2 +-
.../apache/beam/sdk/nexmark/queries/Query3.java | 2 +-
.../beam/sdk/nexmark/queries/Query3Model.java | 2 +-
.../beam/sdk/nexmark/queries/Query4Model.java | 2 +-
.../beam/sdk/nexmark/queries/Query5Model.java | 2 +-
.../beam/sdk/nexmark/queries/Query6Model.java | 2 +-
.../beam/sdk/nexmark/queries/Query7Model.java | 2 +-
.../beam/sdk/nexmark/queries/Query8Model.java | 2 +-
.../apache/beam/sdk/nexmark/queries/Query9.java | 2 +-
.../sdk/nexmark/queries/SessionSideInputJoin.java | 2 +-
.../nexmark/queries/SessionSideInputJoinModel.java | 2 +-
.../beam/sdk/nexmark/queries/WinningBids.java | 2 +-
.../sdk/nexmark/queries/WinningBidsSimulator.java | 2 +-
.../queries/sql/SqlBoundedSideInputJoin.java | 2 +-
.../beam/sdk/nexmark/queries/sql/SqlQuery0.java | 2 +-
.../sdk/nexmark/sources/UnboundedEventSource.java | 2 +-
.../apache/beam/sdk/nexmark/NexmarkUtilsTest.java | 2 +-
.../nexmark/queries/BoundedSideInputJoinTest.java | 2 +-
.../nexmark/queries/SessionSideInputJoinTest.java | 2 +-
.../queries/sql/SqlBoundedSideInputJoinTest.java | 2 +-
.../testutils/publishing/InfluxDBPublisher.java | 2 +-
.../sdk/testutils/publishing/InfluxDBSettings.java | 2 +-
.../sdk/testing/watermarks/WatermarkLatency.java | 2 +-
sdks/python/apache_beam/coders/typecoders.py | 4 +-
sdks/python/apache_beam/dataframe/frames.py | 12 +-
.../transforms/aggregation/combineglobally_test.py | 2 +-
.../runners/portability/portable_runner.py | 8 +-
.../runners/portability/samza_runner_test.py | 2 +-
.../apache_beam/runners/worker/statecache.py | 2 +-
sdks/python/apache_beam/transforms/stats.py | 2 +-
website/CONTRIBUTE.md | 2 +-
website/www/site/content/en/contribute/_index.md | 2 +-
.../www/site/content/en/contribute/dependencies.md | 23 +-
.../en/contribute/get-started-contributing.md | 6 +-
.../site/content/en/contribute/release-guide.md | 20 +-
.../dsls/dataframes/differences-from-pandas.md | 8 +-
.../site/content/en/documentation/io/built-in.md | 8 +-
.../documentation/io/built-in/google-bigquery.md | 2 +-
.../en/documentation/io/built-in/snowflake.md | 8 +-
.../content/en/documentation/patterns/overview.md | 2 +-
.../content/en/documentation/programming-guide.md | 12 +-
.../en/documentation/sdks/go-cross-compilation.md | 2 +-
.../en/documentation/sdks/java/testing/nexmark.md | 4 +-
.../python/aggregation/approximatequantiles.md | 2 +-
.../python/aggregation/approximateunique.md | 2 +-
.../python/aggregation/combinewithcontext.md | 2 +-
.../transforms/python/elementwise/pardo.md | 2 +-
.../transforms/python/elementwise/reify.md | 2 +-
.../transforms/python/elementwise/withkeys.md | 2 +-
.../transforms/python/other/create.md | 2 +-
.../transforms/python/other/flatten.md | 2 +-
.../transforms/python/other/passert.md | 2 +-
.../transforms/python/other/reshuffle.md | 2 +-
.../documentation/transforms/python/other/view.md | 2 +-
.../transforms/python/other/windowinto.md | 2 +-
.../en/get-started/mobile-gaming-example.md | 2 +-
.../site/content/en/get-started/quickstart-java.md | 12 +-
.../content/en/get-started/wordcount-example.md | 6 +-
.../site/content/en/roadmap/connectors-java-sdk.md | 2 +-
website/www/site/content/en/roadmap/euphoria.md | 2 +-
1506 files changed, 2298 insertions(+), 2735 deletions(-)
create mode 100644 .github/workflows/self-assign.yml
delete mode 100644 .test-infra/jenkins/jira_utils/__init__.py
delete mode 100644 .test-infra/jenkins/jira_utils/jira_client.py
delete mode 100644 .test-infra/jenkins/jira_utils/jira_manager.py
delete mode 100644 .test-infra/jenkins/jira_utils/jira_manager_test.py