You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bh...@apache.org on 2021/03/03 03:21:39 UTC
[beam] branch master updated (2e9e9a8 -> d378d57)
This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 2e9e9a8 [BEAM-10632] Checkerframework nullness cleanups (#14107)
add 3d41ad2 never run checkerframework on tests
add ebe1105 Remove nullness warning suppression
add c159f45 Remove some false positives
add d378d57 [BEAM-11436] Never run checkerframework on tests (#14101)
No new revisions were added by this update.
Summary of changes:
.../groovy/org/apache/beam/gradle/BeamModulePlugin.groovy | 13 ++++++-------
.../java/org/apache/beam/examples/WindowedWordCountIT.java | 3 ---
.../apache/beam/examples/complete/TrafficMaxLaneFlowIT.java | 3 ---
.../org/apache/beam/examples/complete/TrafficRoutesIT.java | 3 ---
.../runners/core/construction/CoderTranslationTest.java | 1 -
.../beam/runners/core/construction/CommonCoderTest.java | 1 -
.../core/construction/DefaultArtifactResolverTest.java | 3 ---
.../runners/core/construction/ForwardingPTransformTest.java | 3 ---
.../beam/runners/core/construction/MorePipelineTest.java | 1 -
.../core/construction/PCollectionTranslationTest.java | 3 ---
.../runners/core/construction/PTransformMatchersTest.java | 1 -
.../core/construction/PTransformReplacementsTest.java | 3 ---
.../core/construction/PTransformTranslationTest.java | 3 ---
.../core/construction/PipelineOptionsTranslationTest.java | 3 ---
.../runners/core/construction/PipelineTranslationTest.java | 1 -
.../runners/core/construction/ReplacementOutputsTest.java | 3 ---
.../runners/core/construction/SchemaTranslationTest.java | 3 ---
.../beam/runners/core/construction/SdkComponentsTest.java | 3 ---
.../apache/beam/runners/core/construction/TimerTest.java | 3 ---
.../runners/core/construction/TriggerTranslationTest.java | 3 ---
.../construction/UnboundedReadFromBoundedSourceTest.java | 3 ---
.../core/construction/UnsupportedOverrideFactoryTest.java | 1 -
.../runners/core/construction/ValidateRunnerXlangTest.java | 3 ---
.../core/construction/WindowingStrategyTranslationTest.java | 1 -
.../core/construction/graph/GreedyPipelineFuserTest.java | 3 ---
.../core/construction/graph/GreedyStageFuserTest.java | 3 ---
.../core/construction/graph/OutputDeduplicatorTest.java | 1 -
.../resources/ClasspathScanningResourcesDetectorTest.java | 3 ---
.../core/construction/resources/PipelineResourcesTest.java | 3 ---
.../beam/runners/core/InMemoryTimerInternalsTest.java | 3 ---
.../beam/runners/core/LateDataDroppingDoFnRunnerTest.java | 3 ---
...utAndTimeBoundedSplittableProcessElementInvokerTest.java | 1 -
.../java/org/apache/beam/runners/core/ReduceFnTester.java | 1 -
.../org/apache/beam/runners/core/SideInputHandlerTest.java | 3 ---
.../org/apache/beam/runners/core/SimpleDoFnRunnerTest.java | 1 -
.../runners/core/SimplePushbackSideInputDoFnRunnerTest.java | 1 -
.../beam/runners/core/SplittableParDoProcessFnTest.java | 3 ---
.../org/apache/beam/runners/core/StateInternalsTest.java | 3 ---
.../apache/beam/runners/core/StatefulDoFnRunnerTest.java | 1 -
.../java/org/apache/beam/runners/core/WindowMatchers.java | 3 ---
.../runners/core/metrics/ExecutionStateSamplerTest.java | 3 ---
.../runners/core/metrics/ExecutionStateTrackerTest.java | 3 ---
.../beam/runners/core/metrics/LabeledMetricsTest.java | 3 ---
.../beam/runners/core/metrics/MetricUpdateMatchers.java | 3 ---
.../beam/runners/core/metrics/MetricsContainerImplTest.java | 3 ---
.../runners/core/metrics/MetricsContainerStepMapTest.java | 3 ---
.../apache/beam/runners/core/metrics/MetricsPusherTest.java | 3 ---
.../runners/core/metrics/MonitoringInfoMetricNameTest.java | 3 ---
.../beam/runners/core/metrics/MonitoringInfoTestUtil.java | 1 -
.../beam/runners/core/metrics/SimpleExecutionStateTest.java | 3 ---
.../core/metrics/SimpleMonitoringInfoBuilderTest.java | 3 ---
.../beam/runners/core/metrics/SimpleStateRegistryTest.java | 3 ---
.../apache/beam/runners/core/metrics/TestMetricsSink.java | 3 ---
.../runners/core/triggers/AfterAllStateMachineTest.java | 3 ---
.../runners/core/triggers/AfterEachStateMachineTest.java | 3 ---
.../runners/core/triggers/AfterFirstStateMachineTest.java | 3 ---
.../runners/core/triggers/AfterPaneStateMachineTest.java | 3 ---
.../core/triggers/AfterWatermarkStateMachineTest.java | 3 ---
.../core/triggers/DefaultTriggerStateMachineTest.java | 3 ---
.../beam/runners/core/triggers/NeverStateMachineTest.java | 3 ---
.../runners/core/triggers/OrFinallyStateMachineTest.java | 3 ---
.../runners/core/triggers/RepeatedlyStateMachineTest.java | 3 ---
.../beam/runners/core/triggers/TriggerStateMachineTest.java | 3 ---
.../runners/core/triggers/TriggerStateMachineTester.java | 3 ---
.../runners/direct/BoundedReadEvaluatorFactoryTest.java | 1 -
.../beam/runners/direct/CloningBundleFactoryTest.java | 3 ---
.../direct/CopyOnAccessInMemoryStateInternalsTest.java | 3 ---
.../org/apache/beam/runners/direct/DirectMetricsTest.java | 3 ---
.../beam/runners/direct/DirectRunnerApiSurfaceTest.java | 3 ---
.../org/apache/beam/runners/direct/DirectRunnerTest.java | 1 -
.../beam/runners/direct/DirectTimerInternalsTest.java | 1 -
.../beam/runners/direct/DirectTransformExecutorTest.java | 1 -
.../DoFnLifecycleManagerRemovingTransformEvaluatorTest.java | 3 ---
.../beam/runners/direct/DoFnLifecycleManagersTest.java | 3 ---
.../apache/beam/runners/direct/EvaluationContextTest.java | 1 -
.../beam/runners/direct/FlattenEvaluatorFactoryTest.java | 2 +-
.../beam/runners/direct/GroupByKeyEvaluatorFactoryTest.java | 3 ---
.../runners/direct/GroupByKeyOnlyEvaluatorFactoryTest.java | 3 ---
.../direct/ImmutabilityCheckingBundleFactoryTest.java | 3 ---
.../runners/direct/ImmutabilityEnforcementFactoryTest.java | 3 ---
.../beam/runners/direct/ImmutableListBundleFactoryTest.java | 3 ---
.../beam/runners/direct/KeyedPValueTrackingVisitorTest.java | 3 ---
.../org/apache/beam/runners/direct/ParDoEvaluatorTest.java | 2 +-
.../apache/beam/runners/direct/SideInputContainerTest.java | 3 ---
.../runners/direct/StatefulParDoEvaluatorFactoryTest.java | 1 -
.../apache/beam/runners/direct/StepTransformResultTest.java | 3 ---
.../beam/runners/direct/TestStreamEvaluatorFactoryTest.java | 3 +--
.../beam/runners/direct/TransformExecutorServicesTest.java | 3 ---
.../runners/direct/UnboundedReadEvaluatorFactoryTest.java | 3 +--
.../beam/runners/direct/ViewEvaluatorFactoryTest.java | 3 ---
.../beam/runners/direct/WatermarkCallbackExecutorTest.java | 3 ---
.../apache/beam/runners/direct/WatermarkManagerTest.java | 1 -
.../beam/runners/direct/WindowEvaluatorFactoryTest.java | 3 ---
.../runners/extensions/metrics/MetricsGraphiteSinkTest.java | 3 ---
.../runners/extensions/metrics/MetricsHttpSinkTest.java | 3 ---
.../beam/runners/extensions/metrics/NetworkMockServer.java | 3 ---
.../apache/beam/runners/flink/FlinkRunnerTestCompat.java | 3 ---
.../flink/translation/types/CoderTypeSerializerTest.java | 1 -
.../beam/runners/flink/FlinkExecutionEnvironmentsTest.java | 3 ---
.../flink/FlinkPipelineExecutionEnvironmentTest.java | 1 -
.../apache/beam/runners/flink/FlinkPipelineOptionsTest.java | 3 ---
.../beam/runners/flink/FlinkRequiresStableInputTest.java | 3 ---
.../java/org/apache/beam/runners/flink/FlinkRunnerTest.java | 3 ---
.../org/apache/beam/runners/flink/FlinkSavepointTest.java | 1 -
.../flink/FlinkStreamingTransformTranslatorsTest.java | 1 -
.../org/apache/beam/runners/flink/FlinkSubmissionTest.java | 1 -
.../beam/runners/flink/FlinkTransformOverridesTest.java | 3 ---
.../apache/beam/runners/flink/PortableExecutionTest.java | 3 ---
.../beam/runners/flink/PortableStateExecutionTest.java | 3 ---
.../beam/runners/flink/PortableTimersExecutionTest.java | 3 ---
.../apache/beam/runners/flink/ReadSourcePortableTest.java | 3 ---
.../apache/beam/runners/flink/ReadSourceStreamingTest.java | 3 ---
.../java/org/apache/beam/runners/flink/ReadSourceTest.java | 3 ---
.../beam/runners/flink/batch/NonMergingGroupByKeyTest.java | 3 ---
.../org/apache/beam/runners/flink/batch/ReshuffleTest.java | 3 ---
.../runners/flink/metrics/FlinkMetricContainerTest.java | 3 ---
.../flink/streaming/FlinkBroadcastStateInternalsTest.java | 3 ---
.../runners/flink/streaming/FlinkStateInternalsTest.java | 1 -
.../beam/runners/flink/streaming/GroupByNullKeyTest.java | 3 ---
.../runners/flink/streaming/GroupByWithNullValuesTest.java | 3 ---
.../runners/flink/streaming/TopWikipediaSessionsTest.java | 3 ---
.../flink/translation/functions/FlinkDoFnFunctionTest.java | 1 -
.../functions/FlinkExecutableStageFunctionTest.java | 1 -
.../functions/FlinkStatefulDoFnFunctionTest.java | 1 -
.../translation/wrappers/streaming/DoFnOperatorTest.java | 2 +-
.../wrappers/streaming/ExecutableStageDoFnOperatorTest.java | 1 -
.../wrappers/streaming/StreamRecordStripper.java | 3 ---
.../wrappers/streaming/WindowDoFnOperatorTest.java | 1 -
.../wrappers/streaming/io/TestCountingSource.java | 3 ---
.../wrappers/streaming/io/UnboundedSourceWrapperTest.java | 1 -
.../runners/dataflow/BatchStatefulParDoOverridesTest.java | 3 ---
.../apache/beam/runners/dataflow/DataflowMetricsTest.java | 1 -
.../runners/dataflow/DataflowPTransformMatchersTest.java | 3 ---
.../beam/runners/dataflow/DataflowPipelineJobTest.java | 3 ---
.../runners/dataflow/DataflowPipelineTranslatorTest.java | 1 -
.../beam/runners/dataflow/DataflowRunnerInfoTest.java | 3 ---
.../apache/beam/runners/dataflow/DataflowRunnerTest.java | 3 ---
.../beam/runners/dataflow/RecordingPipelineVisitor.java | 3 ---
.../beam/runners/dataflow/TestDataflowRunnerTest.java | 3 ---
.../dataflow/options/DataflowPipelineOptionsTest.java | 3 ---
.../dataflow/options/DataflowWorkerLoggingOptionsTest.java | 3 ---
.../runners/dataflow/transforms/DataflowGroupByKeyTest.java | 3 ---
.../beam/runners/dataflow/transforms/DataflowViewTest.java | 3 ---
.../apache/beam/runners/dataflow/util/CloudObjectsTest.java | 1 -
.../beam/runners/dataflow/util/MonitoringUtilTest.java | 3 ---
.../apache/beam/runners/dataflow/util/PackageUtilTest.java | 3 ---
.../org/apache/beam/runners/dataflow/util/StructsTest.java | 3 ---
.../org/apache/beam/runners/dataflow/util/TimeUtilTest.java | 3 ---
.../beam/runners/dataflow/harness/test/TestExecutors.java | 3 ---
.../runners/dataflow/harness/test/TestExecutorsTest.java | 1 -
.../beam/runners/dataflow/harness/test/TestStreamsTest.java | 3 ---
.../dataflow/worker/ApplianceShuffleCountersTest.java | 3 ---
.../runners/dataflow/worker/AvroByteReaderFactoryTest.java | 1 -
.../beam/runners/dataflow/worker/AvroByteReaderTest.java | 1 -
.../runners/dataflow/worker/BatchDataflowWorkerTest.java | 3 ---
.../dataflow/worker/BatchModeExecutionContextTest.java | 3 ---
.../runners/dataflow/worker/ConcatReaderFactoryTest.java | 3 ---
.../beam/runners/dataflow/worker/ConcatReaderTest.java | 1 -
.../worker/CreateIsmShardKeyAndSortKeyDoFnFactoryTest.java | 3 ---
.../dataflow/worker/DataflowBatchWorkerHarnessTest.java | 3 ---
.../worker/DataflowElementExecutionTrackerTest.java | 3 ---
.../dataflow/worker/DataflowExecutionStateTrackerTest.java | 3 ---
.../dataflow/worker/DataflowOperationContextTest.java | 3 ---
.../dataflow/worker/DataflowWorkProgressUpdaterTest.java | 3 ---
.../runners/dataflow/worker/DataflowWorkUnitClientTest.java | 3 ---
.../dataflow/worker/DataflowWorkerHarnessHelperTest.java | 3 ---
.../runners/dataflow/worker/DefaultParDoFnFactoryTest.java | 1 -
.../beam/runners/dataflow/worker/DeltaCounterCellTest.java | 3 ---
.../runners/dataflow/worker/DoFnInstanceManagersTest.java | 3 ---
.../beam/runners/dataflow/worker/FakeWindmillServer.java | 3 ---
.../runners/dataflow/worker/FnApiWindowMappingFnTest.java | 1 -
.../runners/dataflow/worker/GroupingShuffleReaderTest.java | 1 -
.../beam/runners/dataflow/worker/HotKeyLoggerTest.java | 3 ---
.../runners/dataflow/worker/InMemoryReaderFactoryTest.java | 3 ---
.../worker/IntrinsicMapTaskExecutorFactoryTest.java | 1 -
.../dataflow/worker/IntrinsicMapTaskExecutorTest.java | 3 ---
.../beam/runners/dataflow/worker/IsmReaderFactoryTest.java | 3 ---
.../apache/beam/runners/dataflow/worker/IsmReaderTest.java | 1 -
.../runners/dataflow/worker/IsmSideInputReaderTest.java | 2 +-
.../worker/LazilyInitializedSideInputReaderTest.java | 1 -
.../beam/runners/dataflow/worker/LogRecordMatcher.java | 3 ---
.../beam/runners/dataflow/worker/LogRecordMatcherTest.java | 1 -
.../dataflow/worker/NoOpSourceOperationExecutorTest.java | 3 ---
.../dataflow/worker/PairWithConstantKeyDoFnFactoryTest.java | 3 ---
.../dataflow/worker/PartialGroupByKeyParDoFnsTest.java | 1 -
.../dataflow/worker/PartitioningShuffleReaderTest.java | 3 ---
.../beam/runners/dataflow/worker/PubsubReaderTest.java | 3 ---
.../apache/beam/runners/dataflow/worker/PubsubSinkTest.java | 3 ---
.../beam/runners/dataflow/worker/ReaderCacheTest.java | 3 ---
.../beam/runners/dataflow/worker/ReaderFactoryTest.java | 1 -
.../beam/runners/dataflow/worker/ReaderTestUtils.java | 3 ---
.../worker/ReifyTimestampAndWindowsParDoFnFactoryTest.java | 3 ---
.../runners/dataflow/worker/SdkHarnessRegistryTest.java | 3 ---
.../runners/dataflow/worker/ShuffleReaderFactoryTest.java | 1 -
.../beam/runners/dataflow/worker/ShuffleSinkTest.java | 3 ---
.../beam/runners/dataflow/worker/SimpleParDoFnTest.java | 3 ---
.../dataflow/worker/SourceOperationExecutorFactoryTest.java | 3 ---
.../beam/runners/dataflow/worker/StateFetcherTest.java | 3 ---
.../dataflow/worker/StreamingDataflowWorkerTest.java | 3 ---
.../dataflow/worker/StreamingGroupAlsoByWindowFnsTest.java | 3 ---
.../StreamingGroupAlsoByWindowsReshuffleDoFnTest.java | 3 ---
.../StreamingKeyedWorkItemSideInputDoFnRunnerTest.java | 3 ---
.../dataflow/worker/StreamingModeExecutionContextTest.java | 3 ---
.../StreamingPCollectionViewWriterDoFnFactoryTest.java | 1 -
.../dataflow/worker/StreamingSideInputDoFnRunnerTest.java | 3 ---
.../dataflow/worker/StreamingSideInputFetcherTest.java | 3 ---
.../beam/runners/dataflow/worker/TestOperationContext.java | 3 ---
.../dataflow/worker/TestShuffleReadCounterFactory.java | 3 ---
.../beam/runners/dataflow/worker/TestShuffleReaderTest.java | 3 ---
.../worker/ToIsmRecordForMultimapDoFnFactoryTest.java | 3 ---
.../runners/dataflow/worker/UngroupedShuffleReaderTest.java | 3 ---
.../runners/dataflow/worker/UserParDoFnFactoryTest.java | 3 ---
.../beam/runners/dataflow/worker/ValuesDoFnFactoryTest.java | 3 ---
.../runners/dataflow/worker/WindmillKeyedWorkItemTest.java | 3 ---
.../runners/dataflow/worker/WindmillStateCacheTest.java | 3 ---
.../runners/dataflow/worker/WindmillStateInternalsTest.java | 1 -
.../runners/dataflow/worker/WindmillStateReaderTest.java | 1 -
.../runners/dataflow/worker/WindmillStateTestUtils.java | 3 ---
.../beam/runners/dataflow/worker/WindmillTimeUtilsTest.java | 3 ---
.../runners/dataflow/worker/WorkItemStatusClientTest.java | 3 ---
.../runners/dataflow/worker/WorkerCustomSourcesTest.java | 3 ---
.../beam/runners/dataflow/worker/apiary/ApiaryTest.java | 2 +-
.../counters/DistributionCounterUpdateAggregatorTest.java | 3 ---
.../worker/counters/MeanCounterUpdateAggregatorTest.java | 3 ---
.../worker/counters/SumCounterUpdateAggregatorTest.java | 3 ---
.../dataflow/worker/fn/BeamFnControlServiceTest.java | 3 ---
.../worker/fn/control/BeamFnMapTaskExecutorTest.java | 1 -
.../fn/control/DataflowSideInputHandlerFactoryTest.java | 1 -
...ntCountMonitoringInfoToCounterUpdateTransformerTest.java | 3 ---
...ionTimeMonitoringInfoToCounterUpdateTransformerTest.java | 3 ---
.../FnApiMonitoringInfoToCounterUpdateTransformerTest.java | 3 ---
...teCountMonitoringInfoToCounterUpdateTransformerTest.java | 3 ---
.../fn/control/RegisterAndProcessBundleOperationTest.java | 1 -
.../control/SingularProcessBundleProgressTrackerTest.java | 1 -
...ibutionMonitoringInfoToCounterUpdateTransformerTest.java | 3 ---
.../UserMonitoringInfoToCounterUpdateTransformerTest.java | 3 ---
.../dataflow/worker/fn/data/BeamFnDataGrpcServiceTest.java | 1 -
.../worker/fn/data/RemoteGrpcPortReadOperationTest.java | 3 ---
.../worker/fn/data/RemoteGrpcPortWriteOperationTest.java | 3 ---
.../worker/fn/logging/BeamFnLoggingServiceTest.java | 3 ---
.../worker/fn/stream/ServerStreamObserverFactoryTest.java | 3 ---
.../worker/graph/CloneAmbiguousFlattensFunctionTest.java | 3 ---
.../worker/graph/CreateRegisterFnOperationFunctionTest.java | 3 ---
.../worker/graph/LengthPrefixUnknownCodersTest.java | 3 ---
.../beam/runners/dataflow/worker/graph/NetworksTest.java | 3 ---
.../beam/runners/dataflow/worker/graph/NodesTest.java | 1 -
.../worker/graph/ReplacePgbkWithPrecombineFunctionTest.java | 3 ---
.../worker/logging/DataflowWorkerLoggingHandlerTest.java | 3 ---
.../logging/DataflowWorkerLoggingInitializerTest.java | 3 ---
.../logging/JulHandlerPrintStreamAdapterFactoryTest.java | 3 ---
.../dataflow/worker/profiler/ScopedProfilerTest.java | 3 ---
.../runners/dataflow/worker/status/DebugCaptureTest.java | 3 ---
.../dataflow/worker/status/WorkerStatusPagesTest.java | 3 ---
.../dataflow/worker/testing/GenericJsonMatcherTest.java | 3 ---
.../dataflow/worker/testing/RestoreDataflowLoggingMDC.java | 3 ---
.../runners/dataflow/worker/testing/TestCountingSource.java | 3 ---
.../dataflow/worker/util/CounterHamcrestMatchers.java | 3 ---
.../dataflow/worker/util/GroupAlsoByWindowProperties.java | 3 ---
.../runners/dataflow/worker/util/MemoryMonitorTest.java | 3 ---
.../worker/util/common/TaggedReiteratorListTest.java | 2 +-
.../util/common/worker/BatchingShuffleEntryReaderTest.java | 3 ---
.../worker/util/common/worker/ExecutorTestUtils.java | 1 -
.../common/worker/GroupingShuffleEntryIteratorTest.java | 1 -
.../worker/util/common/worker/GroupingTablesTest.java | 3 ---
.../worker/util/common/worker/MapTaskExecutorTest.java | 3 ---
.../util/common/worker/OutputObjectAndByteCounterTest.java | 3 ---
.../worker/util/common/worker/ReadOperationTest.java | 3 ---
.../worker/util/common/worker/ShuffleEntryTest.java | 3 ---
.../dataflow/worker/util/common/worker/StubbedExecutor.java | 3 ---
.../worker/util/common/worker/TestOutputReceiver.java | 3 ---
.../worker/util/common/worker/WorkProgressUpdaterTest.java | 3 ---
.../dataflow/worker/windmill/GrpcWindmillServerTest.java | 1 -
.../apache/beam/runners/fnexecution/EmbeddedSdkHarness.java | 3 ---
.../fnexecution/artifact/ArtifactRetrievalServiceTest.java | 3 ---
.../fnexecution/artifact/ArtifactStagingServiceTest.java | 3 ---
.../fnexecution/control/DefaultJobBundleFactoryTest.java | 3 ---
.../control/FnApiControlClientPoolServiceTest.java | 3 ---
.../runners/fnexecution/control/FnApiControlClientTest.java | 3 ---
.../fnexecution/control/ProcessBundleDescriptorsTest.java | 3 ---
.../runners/fnexecution/control/RemoteExecutionTest.java | 5 ++---
.../runners/fnexecution/control/SdkHarnessClientTest.java | 1 -
.../SingleEnvironmentInstanceJobBundleFactoryTest.java | 3 ---
.../environment/DockerEnvironmentFactoryTest.java | 3 ---
.../environment/ProcessEnvironmentFactoryTest.java | 3 ---
.../runners/fnexecution/environment/ProcessManagerTest.java | 3 ---
.../runners/fnexecution/state/GrpcStateServiceTest.java | 1 -
.../fnexecution/status/BeamWorkerStatusGrpcServiceTest.java | 3 ---
.../runners/fnexecution/status/WorkerStatusClientTest.java | 3 ---
.../translation/BatchSideInputHandlerFactoryTest.java | 3 ---
.../beam/runners/fnexecution/wire/ByteStringCoderTest.java | 3 ---
.../fnexecution/wire/LengthPrefixUnknownCodersTest.java | 3 ---
.../beam/runners/jobsubmission/InMemoryJobServiceTest.java | 3 ---
.../beam/runners/jobsubmission/JobInvocationTest.java | 3 ---
.../jobsubmission/PortablePipelineJarCreatorTest.java | 3 ---
.../java/org/apache/beam/runners/jet/TestJetRunner.java | 1 -
.../test/java/org/apache/beam/runners/jet/TestStreamP.java | 1 -
.../beam/runners/samza/adapter/BoundedSourceSystemTest.java | 3 ---
.../beam/runners/samza/adapter/TestSourceHelpers.java | 3 ---
.../beam/runners/samza/adapter/TestUnboundedSource.java | 3 ---
.../runners/samza/adapter/UnboundedSourceSystemTest.java | 3 ---
.../beam/runners/samza/runtime/BundleManagerTest.java | 2 --
.../runners/samza/runtime/SamzaStoreStateInternalsTest.java | 1 -
.../samza/runtime/SamzaTimerInternalsFactoryTest.java | 1 -
.../beam/runners/samza/translation/ConfigGeneratorTest.java | 3 ---
.../runners/samza/translation/SamzaImpulseSystemTest.java | 1 -
.../apache/beam/runners/samza/util/TestHashIdGenerator.java | 3 ---
.../test/java/org/apache/beam/runners/spark/CacheTest.java | 1 -
.../beam/runners/spark/GlobalWatermarkHolderTest.java | 3 ---
.../apache/beam/runners/spark/ProvidedSparkContextTest.java | 3 ---
.../apache/beam/runners/spark/SparkPipelineStateTest.java | 3 ---
.../spark/aggregators/metrics/sink/InMemoryMetrics.java | 3 ---
.../org/apache/beam/runners/spark/io/AvroPipelineTest.java | 3 ---
.../org/apache/beam/runners/spark/io/NumShardsTest.java | 3 ---
.../beam/runners/spark/io/ReaderToIteratorAdapterTest.java | 3 ---
.../StructuredStreamingPipelineStateTest.java | 3 ---
.../aggregators/metrics/sink/InMemoryMetrics.java | 3 ---
.../aggregators/metrics/sink/SparkMetricsSinkTest.java | 3 ---
.../structuredstreaming/translation/batch/CombineTest.java | 3 ---
.../translation/batch/ComplexSourceTest.java | 3 ---
.../structuredstreaming/translation/batch/FlattenTest.java | 3 ---
.../translation/batch/GroupByKeyTest.java | 3 ---
.../structuredstreaming/translation/batch/ParDoTest.java | 3 ---
.../translation/batch/SimpleSourceTest.java | 3 ---
.../translation/batch/WindowAssignTest.java | 3 ---
.../translation/streaming/SimpleSourceTest.java | 3 ---
.../structuredstreaming/utils/SerializationDebugger.java | 3 ---
.../spark/translation/SparkExecutableStageFunctionTest.java | 1 -
.../streaming/ResumeFromCheckpointStreamingTest.java | 1 -
.../translation/streaming/TrackStreamingSourcesTest.java | 1 -
.../translation/streaming/utils/EmbeddedKafkaCluster.java | 3 ---
sdks/java/core/build.gradle | 1 -
.../src/test/java/org/apache/beam/sdk/PipelineTest.java | 1 -
.../core/src/test/java/org/apache/beam/sdk/TestUtils.java | 3 ---
.../test/java/org/apache/beam/sdk/coders/AvroCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/AvroCoderTestPojo.java | 3 ---
.../org/apache/beam/sdk/coders/BigDecimalCoderTest.java | 3 ---
.../apache/beam/sdk/coders/BigEndianIntegerCoderTest.java | 3 ---
.../org/apache/beam/sdk/coders/BigEndianLongCoderTest.java | 3 ---
.../org/apache/beam/sdk/coders/BigIntegerCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/BitSetCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/ByteArrayCoderTest.java | 3 ---
.../test/java/org/apache/beam/sdk/coders/ByteCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/CoderRegistryTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/coders/CoderTest.java | 3 ---
.../org/apache/beam/sdk/coders/CollectionCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/DequeCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/DoubleCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/DurationCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/FloatCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/InstantCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/IterableCoderTest.java | 3 ---
.../test/java/org/apache/beam/sdk/coders/KvCoderTest.java | 3 ---
.../test/java/org/apache/beam/sdk/coders/ListCoderTest.java | 3 ---
.../test/java/org/apache/beam/sdk/coders/MapCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/NullableCoderTest.java | 3 ---
.../apache/beam/sdk/coders/PCollectionCustomCoderTest.java | 3 ---
.../org/apache/beam/sdk/coders/PrintBase64Encodings.java | 3 ---
.../org/apache/beam/sdk/coders/SerializableCoderTest.java | 3 ---
.../test/java/org/apache/beam/sdk/coders/SetCoderTest.java | 3 ---
.../org/apache/beam/sdk/coders/StringUtf8CoderTest.java | 3 ---
.../org/apache/beam/sdk/coders/StructuredCoderTest.java | 3 ---
.../org/apache/beam/sdk/coders/TextualIntegerCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/VarIntCoderTest.java | 3 ---
.../java/org/apache/beam/sdk/coders/VarLongCoderTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/AvroIOTest.java | 1 -
.../test/java/org/apache/beam/sdk/io/AvroSourceTest.java | 3 ---
.../beam/sdk/io/BoundedReadFromUnboundedSourceTest.java | 3 ---
.../org/apache/beam/sdk/io/ClassLoaderFileSystemTest.java | 3 ---
.../java/org/apache/beam/sdk/io/CompressedSourceTest.java | 3 ---
.../java/org/apache/beam/sdk/io/CountingSourceTest.java | 3 ---
.../org/apache/beam/sdk/io/DefaultFilenamePolicyTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/FileBasedSinkTest.java | 1 -
.../java/org/apache/beam/sdk/io/FileBasedSourceTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/FileIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/FileSystemsTest.java | 3 ---
.../java/org/apache/beam/sdk/io/LocalFileSystemTest.java | 3 ---
.../java/org/apache/beam/sdk/io/LocalResourceIdTest.java | 3 ---
.../java/org/apache/beam/sdk/io/OffsetBasedSourceTest.java | 3 ---
.../core/src/test/java/org/apache/beam/sdk/io/ReadTest.java | 1 -
.../src/test/java/org/apache/beam/sdk/io/SimpleSink.java | 3 ---
.../test/java/org/apache/beam/sdk/io/TFRecordIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/TextIOReadTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/TextIOWriteTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/TextSourceTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/WriteFilesTest.java | 3 ---
.../beam/sdk/io/range/ByteKeyRangeInterpolateKeyTest.java | 3 ---
.../java/org/apache/beam/sdk/io/range/ByteKeyRangeTest.java | 3 ---
.../org/apache/beam/sdk/metrics/MetricResultsMatchers.java | 3 ---
.../org/apache/beam/sdk/metrics/MetricsEnvironmentTest.java | 3 ---
.../test/java/org/apache/beam/sdk/metrics/MetricsTest.java | 3 ---
.../apache/beam/sdk/options/PipelineOptionsFactoryTest.java | 1 -
.../beam/sdk/options/PipelineOptionsValidatorTest.java | 3 ---
.../apache/beam/sdk/options/ProxyInvocationHandlerTest.java | 3 ---
.../beam/sdk/options/RemoteEnvironmentOptionsTest.java | 3 ---
.../org/apache/beam/sdk/options/SdkHarnessOptionsTest.java | 3 ---
.../org/apache/beam/sdk/runners/TransformHierarchyTest.java | 3 ---
.../java/org/apache/beam/sdk/runners/TransformTreeTest.java | 3 ---
.../org/apache/beam/sdk/schemas/AutoValueSchemaTest.java | 3 ---
.../java/org/apache/beam/sdk/schemas/AvroSchemaTest.java | 3 ---
.../apache/beam/sdk/schemas/FieldAccessDescriptorTest.java | 3 ---
.../org/apache/beam/sdk/schemas/JavaBeanSchemaTest.java | 3 ---
.../org/apache/beam/sdk/schemas/JavaFieldSchemaTest.java | 3 ---
.../java/org/apache/beam/sdk/schemas/SchemaCoderTest.java | 1 -
.../java/org/apache/beam/sdk/schemas/SchemaOptionsTest.java | 3 ---
.../org/apache/beam/sdk/schemas/SchemaRegistryTest.java | 1 -
.../test/java/org/apache/beam/sdk/schemas/SchemaTest.java | 3 ---
.../beam/sdk/schemas/logicaltypes/LogicalTypesTest.java | 3 ---
.../apache/beam/sdk/schemas/transforms/AddFieldsTest.java | 3 ---
.../beam/sdk/schemas/transforms/CastValidatorTest.java | 3 ---
.../org/apache/beam/sdk/schemas/transforms/CoGroupTest.java | 1 -
.../org/apache/beam/sdk/schemas/transforms/ConvertTest.java | 3 ---
.../org/apache/beam/sdk/schemas/transforms/FilterTest.java | 3 ---
.../org/apache/beam/sdk/schemas/transforms/GroupTest.java | 1 -
.../org/apache/beam/sdk/schemas/transforms/JoinTest.java | 3 ---
.../org/apache/beam/sdk/schemas/transforms/SelectTest.java | 3 ---
.../org/apache/beam/sdk/schemas/utils/AvroGenerators.java | 3 ---
.../org/apache/beam/sdk/schemas/utils/AvroUtilsTest.java | 1 -
.../apache/beam/sdk/schemas/utils/JavaBeanUtilsTest.java | 1 -
.../org/apache/beam/sdk/schemas/utils/POJOUtilsTest.java | 1 -
.../org/apache/beam/sdk/schemas/utils/SchemaTestUtils.java | 3 ---
.../apache/beam/sdk/schemas/utils/SelectHelpersTest.java | 3 ---
.../org/apache/beam/sdk/schemas/utils/TestJavaBeans.java | 3 ---
.../java/org/apache/beam/sdk/schemas/utils/TestPOJOs.java | 3 ---
.../java/org/apache/beam/sdk/state/StateContextsTest.java | 3 ---
.../org/apache/beam/sdk/testing/CoderPropertiesTest.java | 3 ---
.../test/java/org/apache/beam/sdk/testing/ExpectedLogs.java | 3 ---
.../java/org/apache/beam/sdk/testing/ExpectedLogsTest.java | 3 ---
.../apache/beam/sdk/testing/FileChecksumMatcherTest.java | 3 ---
.../apache/beam/sdk/testing/InterceptingUrlClassLoader.java | 3 ---
.../test/java/org/apache/beam/sdk/testing/PAssertTest.java | 1 -
.../apache/beam/sdk/testing/RestoreSystemProperties.java | 3 ---
.../beam/sdk/testing/RestoreSystemPropertiesTest.java | 3 ---
.../apache/beam/sdk/testing/SerializableMatchersTest.java | 3 ---
.../org/apache/beam/sdk/testing/SourceTestUtilsTest.java | 3 ---
.../java/org/apache/beam/sdk/testing/TestStreamTest.java | 3 ---
.../java/org/apache/beam/sdk/testing/ThreadLeakTracker.java | 3 ---
.../apache/beam/sdk/transforms/ApproximateUniqueTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/CombineFnsTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/CombineTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/CreateTest.java | 1 -
.../java/org/apache/beam/sdk/transforms/DistinctTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/FilterTest.java | 3 ---
.../org/apache/beam/sdk/transforms/FlatMapElementsTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/FlattenTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/JsonToRowTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/KvSwapTest.java | 1 -
.../java/org/apache/beam/sdk/transforms/LatestFnTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/LatestTest.java | 3 ---
.../org/apache/beam/sdk/transforms/MapElementsTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/PTransformTest.java | 3 ---
.../org/apache/beam/sdk/transforms/ParDoLifecycleTest.java | 1 -
.../org/apache/beam/sdk/transforms/ParDoSchemaTest.java | 3 ---
.../test/java/org/apache/beam/sdk/transforms/ParDoTest.java | 1 -
.../java/org/apache/beam/sdk/transforms/PartitionTest.java | 3 ---
.../java/org/apache/beam/sdk/transforms/SampleTest.java | 3 ---
.../test/java/org/apache/beam/sdk/transforms/SetsTest.java | 3 ---
.../org/apache/beam/sdk/transforms/SimpleStatsFnsTest.java | 3 ---
.../org/apache/beam/sdk/transforms/SplittableDoFnTest.java | 1 -
.../test/java/org/apache/beam/sdk/transforms/ViewTest.java | 3 ---
.../test/java/org/apache/beam/sdk/transforms/WaitTest.java | 3 ---
.../test/java/org/apache/beam/sdk/transforms/WatchTest.java | 3 ---
.../org/apache/beam/sdk/transforms/WithFailuresTest.java | 3 ---
.../org/apache/beam/sdk/transforms/WithTimestampsTest.java | 3 ---
.../beam/sdk/transforms/display/DisplayDataEvaluator.java | 3 ---
.../beam/sdk/transforms/display/DisplayDataMatchers.java | 3 ---
.../apache/beam/sdk/transforms/display/DisplayDataTest.java | 3 ---
.../apache/beam/sdk/transforms/join/CoGroupByKeyTest.java | 3 ---
.../beam/sdk/transforms/reflect/DoFnInvokersTest.java | 1 -
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 1 -
.../beam/sdk/transforms/reflect/DoFnSignaturesTest.java | 3 ---
.../beam/sdk/transforms/reflect/OnTimerInvokersTest.java | 3 ---
.../reflect/testhelper/DoFnInvokersTestHelper.java | 3 ---
.../transforms/splittabledofn/ByteKeyRangeTrackerTest.java | 3 ---
.../splittabledofn/GrowableOffsetRangeTrackerTest.java | 1 -
.../transforms/splittabledofn/OffsetRangeTrackerTest.java | 1 -
.../beam/sdk/transforms/splittabledofn/SplitResultTest.java | 3 ---
.../beam/sdk/transforms/windowing/RepeatedlyTest.java | 3 ---
.../apache/beam/sdk/transforms/windowing/StubTrigger.java | 3 ---
.../apache/beam/sdk/transforms/windowing/TriggerTest.java | 3 ---
.../apache/beam/sdk/transforms/windowing/WindowTest.java | 3 ---
.../java/org/apache/beam/sdk/util/CombineFnUtilTest.java | 3 ---
.../beam/sdk/util/FilePatternMatchingShardedFileTest.java | 3 ---
.../test/java/org/apache/beam/sdk/util/NameUtilsTest.java | 3 ---
.../org/apache/beam/sdk/util/NumberedShardedFileTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/util/RowJsonTest.java | 3 ---
.../org/apache/beam/sdk/util/SerializableUtilsTest.java | 3 ---
.../test/java/org/apache/beam/sdk/util/StreamUtilsTest.java | 3 ---
.../org/apache/beam/sdk/util/UnownedInputStreamTest.java | 3 ---
.../org/apache/beam/sdk/util/UnownedOutputStreamTest.java | 3 ---
.../org/apache/beam/sdk/util/UserCodeExceptionTest.java | 3 ---
.../test/java/org/apache/beam/sdk/util/ZipFilesTest.java | 3 ---
.../org/apache/beam/sdk/util/common/ReflectHelpersTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/values/KVTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/values/RowTest.java | 1 -
.../org/apache/beam/sdk/values/TimestampedValueTest.java | 3 ---
.../java/org/apache/beam/sdk/values/TypeDescriptorTest.java | 3 ---
.../euphoria/core/client/operator/FlatMapTest.java | 1 -
.../extensions/euphoria/core/client/operator/JoinTest.java | 1 -
.../euphoria/core/client/operator/ReduceByKeyTest.java | 1 -
.../euphoria/core/client/operator/SumByKeyTest.java | 1 -
.../extensions/euphoria/core/client/operator/TestUtils.java | 3 ---
.../euphoria/core/client/type/TypePropagationAssert.java | 1 -
.../extensions/euphoria/core/client/util/IOUtilsTest.java | 3 ---
.../sdk/extensions/euphoria/core/testkit/FlatMapTest.java | 3 ---
.../beam/sdk/extensions/euphoria/core/testkit/JoinTest.java | 3 ---
.../extensions/euphoria/core/testkit/MapElementsTest.java | 3 ---
.../extensions/euphoria/core/testkit/ReduceByKeyTest.java | 3 ---
.../sdk/extensions/euphoria/core/testkit/SumByKeyTest.java | 3 ---
.../core/translate/SingleJvmAccumulatorProviderTest.java | 3 ---
.../core/translate/collector/SingleValueCollectorTest.java | 1 -
.../apache/beam/sdk/transforms/windowing/WindowDesc.java | 3 ---
.../beam/sdk/extensions/gcp/GcpCoreApiSurfaceTest.java | 3 ---
.../beam/sdk/extensions/gcp/options/GcpOptionsTest.java | 3 ---
.../beam/sdk/extensions/gcp/storage/GcsFileSystemTest.java | 3 ---
.../sdk/extensions/gcp/storage/GcsPathValidatorTest.java | 3 ---
.../beam/sdk/extensions/gcp/storage/GcsResourceIdTest.java | 3 ---
.../org/apache/beam/sdk/extensions/gcp/util/GcsUtilIT.java | 3 ---
.../apache/beam/sdk/extensions/gcp/util/GcsUtilTest.java | 3 ---
.../util/LatencyRecordingHttpRequestInitializerTest.java | 3 ---
.../gcp/util/RetryHttpRequestInitializerTest.java | 3 ---
.../gcp/util/UploadIdResponseInterceptorTest.java | 3 ---
.../beam/sdk/extensions/jackson/JacksonTransformsTest.java | 3 ---
.../apache/beam/sdk/extensions/ml/AnnotateImagesTest.java | 3 ---
.../apache/beam/sdk/extensions/ml/AnnotateVideoTest.java | 3 ---
.../beam/sdk/extensions/ml/BatchRequestForDlpTest.java | 3 ---
.../org/apache/beam/sdk/extensions/ml/CloudVisionIT.java | 3 ---
.../org/apache/beam/sdk/extensions/ml/CloudVisionTest.java | 3 ---
.../beam/sdk/extensions/ml/MapStringToDlpRowTest.java | 3 ---
.../beam/sdk/extensions/protobuf/ByteStringCoderTest.java | 3 ---
.../beam/sdk/extensions/protobuf/DynamicProtoCoderTest.java | 3 ---
.../apache/beam/sdk/extensions/protobuf/ProtoCoderTest.java | 3 ---
.../sdk/extensions/protobuf/ProtoMessageSchemaTest.java | 3 ---
.../sdk/extensions/protobuf/ProtoSchemaTranslatorTest.java | 1 -
.../sql/meta/provider/hcatalog/BeamSqlHiveSchemaTest.java | 3 ---
.../apache/beam/sdk/extensions/sql/BeamComplexTypeTest.java | 3 ---
.../org/apache/beam/sdk/extensions/sql/BeamSqlCliTest.java | 3 ---
.../extensions/sql/BeamSqlDslAggregationCovarianceTest.java | 3 ---
.../extensions/sql/BeamSqlDslAggregationNullableTest.java | 3 ---
.../beam/sdk/extensions/sql/BeamSqlDslAggregationTest.java | 3 ---
.../extensions/sql/BeamSqlDslAggregationVarianceTest.java | 3 ---
.../org/apache/beam/sdk/extensions/sql/BeamSqlDslBase.java | 3 ---
.../apache/beam/sdk/extensions/sql/BeamSqlDslJoinTest.java | 3 ---
.../beam/sdk/extensions/sql/BeamSqlDslProjectTest.java | 3 ---
.../sdk/extensions/sql/BeamSqlDslSqlStdOperatorsTest.java | 3 ---
.../beam/sdk/extensions/sql/BeamSqlDslUdfUdafTest.java | 3 ---
.../apache/beam/sdk/extensions/sql/BeamSqlExplainTest.java | 3 ---
.../beam/sdk/extensions/sql/InferredJavaBeanSqlTest.java | 3 ---
.../java/org/apache/beam/sdk/extensions/sql/TestUtils.java | 3 ---
.../apache/beam/sdk/extensions/sql/impl/JdbcDriverTest.java | 3 ---
.../extensions/sql/impl/parser/BeamDDLNestedTypesTest.java | 3 ---
.../beam/sdk/extensions/sql/impl/parser/BeamDDLTest.java | 3 ---
.../beam/sdk/extensions/sql/impl/planner/NodeStatsTest.java | 3 ---
.../beam/sdk/extensions/sql/impl/rel/BaseRelTest.java | 3 ---
.../sql/impl/rel/BeamCoGBKJoinRelBoundedVsBoundedTest.java | 3 ---
.../impl/rel/BeamCoGBKJoinRelUnboundedVsUnboundedTest.java | 3 ---
.../sql/impl/rel/BeamEnumerableConverterTest.java | 3 ---
.../extensions/sql/impl/rel/BeamSideInputJoinRelTest.java | 3 ---
.../sql/impl/rel/BeamSideInputLookupJoinRelTest.java | 3 ---
.../beam/sdk/extensions/sql/impl/rel/BeamSortRelTest.java | 3 ---
.../sql/impl/rule/BeamAggregateProjectMergeRuleTest.java | 3 ---
.../sdk/extensions/sql/impl/rule/IOPushDownRuleTest.java | 3 ---
.../sdk/extensions/sql/impl/rule/JoinReorderingTest.java | 6 ------
.../sql/impl/schema/transform/BeamTransformBaseTest.java | 3 ---
.../sdk/extensions/sql/impl/utils/CalciteUtilsTest.java | 3 ---
.../BeamSqlBuiltinFunctionsIntegrationTestBase.java | 3 ---
.../BeamSqlDateFunctionsIntegrationTest.java | 3 ---
.../sdk/extensions/sql/meta/CustomTableResolverTest.java | 3 ---
.../sql/meta/provider/bigquery/BigQueryFilterTest.java | 3 ---
.../sql/meta/provider/bigquery/BigQueryTestTable.java | 3 ---
.../meta/provider/bigquery/BigQueryTestTableProvider.java | 3 ---
.../sql/meta/provider/bigtable/BigtableFilterTest.java | 3 ---
.../bigtable/BigtableTableCreationFailuresTest.java | 3 ---
.../sql/meta/provider/bigtable/BigtableTableFlatTest.java | 3 ---
.../sql/meta/provider/bigtable/BigtableTableIT.java | 3 ---
.../sql/meta/provider/bigtable/BigtableTableTestUtils.java | 3 ---
.../meta/provider/bigtable/BigtableTableWithRowsTest.java | 3 ---
.../sql/meta/provider/kafka/BeamKafkaTableProtoTest.java | 3 ---
.../meta/provider/kafka/BeamKafkaTableStatisticsTest.java | 3 ---
.../sql/meta/provider/kafka/BeamKafkaTableThriftTest.java | 3 ---
.../sql/meta/provider/kafka/KafkaTableProviderIT.java | 3 ---
.../extensions/sql/meta/provider/kafka/KafkaTestTable.java | 3 ---
.../sql/meta/provider/mongodb/MongoDbFilterTest.java | 3 ---
.../sql/meta/provider/mongodb/MongoDbReadWriteIT.java | 3 ---
.../sql/meta/provider/parquet/ParquetTableProviderTest.java | 3 ---
.../sql/meta/provider/pubsub/PubsubTableProviderIT.java | 1 -
.../sql/meta/provider/test/TestTableProviderTest.java | 3 ---
.../test/TestTableProviderWithFilterAndProjectPushDown.java | 3 ---
.../provider/test/TestTableProviderWithFilterPushDown.java | 3 ---
.../provider/test/TestTableProviderWithProjectPushDown.java | 3 ---
.../extensions/sql/meta/store/InMemoryMetaStoreTest.java | 3 ---
.../apache/beam/sdk/extensions/sql/utils/RowAsserts.java | 3 ---
.../sdk/extensions/sql/zetasql/TableResolutionTest.java | 3 ---
.../apache/beam/sdk/extensions/sql/zetasql/TestInput.java | 3 ---
.../sdk/extensions/sql/zetasql/ZetaSQLPushDownTest.java | 1 -
.../sdk/extensions/sql/zetasql/ZetaSqlDialectSpecTest.java | 3 ---
.../extensions/sql/zetasql/ZetaSqlMathFunctionsTest.java | 3 ---
.../beam/sdk/extensions/sql/zetasql/ZetaSqlTestBase.java | 3 ---
.../extensions/sql/zetasql/ZetaSqlTimeFunctionsTest.java | 3 ---
.../java/org/apache/beam/sdk/fn/JvmInitializersTest.java | 3 ---
.../beam/sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 3 ---
.../BeamFnDataSizeBasedBufferingOutboundObserverTest.java | 3 ---
.../BeamFnDataTimeBasedBufferingOutboundObserverTest.java | 3 ---
.../beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java | 1 -
.../java/org/apache/beam/sdk/fn/stream/DataStreamsTest.java | 3 ---
.../beam/sdk/fn/stream/OutboundObserverFactoryTest.java | 3 ---
.../java/org/apache/beam/sdk/fn/test/TestExecutorsTest.java | 3 ---
.../java/org/apache/beam/sdk/fn/test/TestStreamsTest.java | 3 ---
.../apache/beam/fn/harness/BeamFnDataReadRunnerTest.java | 3 ---
.../apache/beam/fn/harness/BeamFnDataWriteRunnerTest.java | 3 ---
.../java/org/apache/beam/fn/harness/CombineRunnersTest.java | 3 ---
.../java/org/apache/beam/fn/harness/FlattenRunnerTest.java | 3 ---
.../org/apache/beam/fn/harness/FnApiDoFnRunnerTest.java | 1 -
.../java/org/apache/beam/fn/harness/MapFnRunnersTest.java | 3 ---
.../apache/beam/fn/harness/PrecombineGroupingTableTest.java | 3 ---
.../beam/fn/harness/control/BeamFnControlClientTest.java | 3 ---
.../beam/fn/harness/control/FinalizeBundleHandlerTest.java | 3 ---
.../beam/fn/harness/control/ProcessBundleHandlerTest.java | 1 -
.../beam/fn/harness/data/BeamFnDataGrpcClientTest.java | 3 ---
.../apache/beam/fn/harness/data/FakeBeamFnTimerClient.java | 1 -
.../fn/harness/data/PCollectionConsumerRegistryTest.java | 1 -
.../beam/fn/harness/logging/BeamFnLoggingClientTest.java | 3 ---
.../org/apache/beam/fn/harness/state/BagUserStateTest.java | 3 ---
.../fn/harness/state/BeamFnStateGrpcClientCacheTest.java | 3 ---
.../beam/fn/harness/state/StateBackedIterableTest.java | 1 -
.../harness/stream/HarnessStreamObserverFactoriesTest.java | 3 ---
.../org/apache/beam/sdk/io/aws/coders/AwsCodersTest.java | 3 ---
.../beam/sdk/io/aws/dynamodb/AwsClientsProviderMock.java | 3 ---
.../org/apache/beam/sdk/io/aws/dynamodb/DynamoDBIOTest.java | 3 ---
.../beam/sdk/io/aws/dynamodb/DynamoDBIOTestHelper.java | 3 ---
.../org/apache/beam/sdk/io/aws/options/AwsModuleTest.java | 3 ---
.../org/apache/beam/sdk/io/aws/s3/MatchResultMatcher.java | 3 ---
.../org/apache/beam/sdk/io/aws/s3/S3FileSystemTest.java | 3 ---
.../org/apache/beam/sdk/io/aws/s3/S3ResourceIdTest.java | 3 ---
.../beam/sdk/io/aws/s3/S3WritableByteChannelTest.java | 3 ---
.../apache/beam/sdk/io/aws/sns/PublishResultCodersTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/aws/sns/SnsIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/aws/sqs/SqsIOTest.java | 3 ---
.../apache/beam/sdk/io/aws2/dynamodb/DynamoDBIOTest.java | 3 ---
.../beam/sdk/io/aws2/dynamodb/DynamoDBIOTestHelper.java | 1 -
.../sdk/io/aws2/dynamodb/DynamoDbClientProviderMock.java | 3 ---
.../apache/beam/sdk/io/aws2/kinesis/AmazonKinesisMock.java | 3 ---
.../sdk/io/aws2/kinesis/DynamicCheckpointGeneratorTest.java | 3 ---
.../org/apache/beam/sdk/io/aws2/kinesis/KinesisIOIT.java | 3 ---
.../sdk/io/aws2/kinesis/KinesisReaderCheckpointTest.java | 3 ---
.../apache/beam/sdk/io/aws2/kinesis/KinesisReaderTest.java | 3 ---
.../apache/beam/sdk/io/aws2/kinesis/KinesisServiceMock.java | 3 ---
.../apache/beam/sdk/io/aws2/kinesis/RecordFilterTest.java | 3 ---
.../beam/sdk/io/aws2/kinesis/ShardCheckpointTest.java | 3 ---
.../beam/sdk/io/aws2/kinesis/ShardReadersPoolTest.java | 3 ---
.../beam/sdk/io/aws2/kinesis/ShardRecordsIteratorTest.java | 3 ---
.../sdk/io/aws2/kinesis/SimplifiedKinesisClientTest.java | 3 ---
.../sdk/io/aws2/kinesis/StartingPointShardsFinderTest.java | 3 ---
.../org/apache/beam/sdk/io/aws2/kinesis/TimeUtilTest.java | 3 ---
.../apache/beam/sdk/io/aws2/sns/MockSnsAsyncBaseClient.java | 3 ---
.../apache/beam/sdk/io/aws2/sns/SnsClientMockErrors.java | 3 ---
.../apache/beam/sdk/io/aws2/sns/SnsClientMockSuccess.java | 3 ---
.../java/org/apache/beam/sdk/io/aws2/sns/SnsIOTest.java | 3 ---
.../org/apache/beam/sdk/io/aws2/sns/SnsIOWriteTest.java | 3 ---
.../org/apache/beam/sdk/io/aws2/sqs/EmbeddedSqsServer.java | 3 ---
.../apache/beam/sdk/io/aws2/sqs/SqsClientProviderMock.java | 3 ---
.../beam/sdk/io/azure/blobstore/AzfsResourceIdTest.java | 3 ---
.../apache/beam/sdk/bigqueryioperftests/BigQueryIOIT.java | 3 ---
.../org/apache/beam/sdk/io/cassandra/CassandraIOIT.java | 3 ---
.../org/apache/beam/sdk/io/cassandra/CassandraIOTest.java | 1 -
.../apache/beam/sdk/io/clickhouse/BaseClickHouseTest.java | 1 -
.../org/apache/beam/sdk/io/clickhouse/ClickHouseIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/common/HashingFn.java | 3 ---
.../test/java/org/apache/beam/sdk/io/common/IOITHelper.java | 3 ---
.../java/org/apache/beam/sdk/io/common/IOITHelperTest.java | 3 ---
.../beam/sdk/io/contextualtextio/ContextualTextIOTest.java | 3 ---
sdks/java/io/debezium/build.gradle | 1 -
.../apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java | 3 ---
.../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java | 3 ---
.../apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java | 3 ---
.../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java | 3 ---
.../apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java | 3 ---
.../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java | 3 ---
.../apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java | 3 ---
.../beam/sdk/io/elasticsearch/ElasticsearchIOTest.java | 3 ---
.../sdk/io/elasticsearch/ElasticsearchIOTestCommon.java | 3 ---
.../beam/sdk/io/elasticsearch/ElasticsearchIOTestUtils.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/avro/AvroIOIT.java | 3 ---
.../java/org/apache/beam/sdk/io/parquet/ParquetIOIT.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/text/TextIOIT.java | 3 ---
.../java/org/apache/beam/sdk/io/tfrecord/TFRecordIOIT.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/xml/XmlIOIT.java | 3 ---
.../java/org/apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 3 ---
.../beam/sdk/io/gcp/bigquery/BigQueryAvroUtilsTest.java | 3 ---
.../beam/sdk/io/gcp/bigquery/BigQueryHelpersTest.java | 3 ---
.../apache/beam/sdk/io/gcp/bigquery/BigQueryIOReadIT.java | 3 ---
.../apache/beam/sdk/io/gcp/bigquery/BigQueryIOReadTest.java | 3 ---
.../beam/sdk/io/gcp/bigquery/BigQueryIOStorageQueryIT.java | 3 ---
.../sdk/io/gcp/bigquery/BigQueryIOStorageQueryTest.java | 3 ---
.../beam/sdk/io/gcp/bigquery/BigQueryIOStorageReadIT.java | 3 ---
.../io/gcp/bigquery/BigQueryIOStorageReadTableRowIT.java | 3 ---
.../beam/sdk/io/gcp/bigquery/BigQueryIOStorageReadTest.java | 3 ---
.../beam/sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 3 ---
.../apache/beam/sdk/io/gcp/bigquery/BigQueryKmsKeyIT.java | 3 ---
.../sdk/io/gcp/bigquery/BigQuerySchemaUpdateOptionsIT.java | 3 ---
.../beam/sdk/io/gcp/bigquery/BigQueryServicesImplTest.java | 3 ---
.../gcp/bigquery/BigQueryTimePartitioningClusteringIT.java | 3 ---
.../apache/beam/sdk/io/gcp/bigquery/BigQueryToTableIT.java | 3 ---
.../apache/beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java | 3 ---
.../apache/beam/sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 3 ---
.../apache/beam/sdk/io/gcp/bigtable/BigtableConfigTest.java | 3 ---
.../org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 3 ---
.../beam/sdk/io/gcp/bigtable/BigtableRowToBeamRowTest.java | 3 ---
.../beam/sdk/io/gcp/bigtable/BigtableServiceImplTest.java | 3 ---
.../apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java | 3 ---
.../io/gcp/datastore/DataStoreV1SchemaIOProviderTest.java | 3 ---
.../apache/beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 3 ---
.../sdk/io/gcp/datastore/EntityToRowRowToEntityTest.java | 3 ---
.../apache/beam/sdk/io/gcp/datastore/SplitQueryFnIT.java | 3 ---
.../java/org/apache/beam/sdk/io/gcp/datastore/V1ReadIT.java | 3 ---
.../org/apache/beam/sdk/io/gcp/datastore/V1TestUtil.java | 3 ---
.../org/apache/beam/sdk/io/gcp/datastore/V1WriteIT.java | 3 ---
.../org/apache/beam/sdk/io/gcp/healthcare/FhirIOLROIT.java | 3 ---
.../org/apache/beam/sdk/io/gcp/healthcare/FhirIOReadIT.java | 3 ---
.../apache/beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java | 3 ---
.../apache/beam/sdk/io/gcp/healthcare/FhirIOTestUtil.java | 3 ---
.../apache/beam/sdk/io/gcp/healthcare/FhirIOWriteIT.java | 3 ---
.../beam/sdk/io/gcp/healthcare/HL7V2MessagePagesTest.java | 3 ---
.../apache/beam/sdk/io/gcp/healthcare/HL7v2IOReadIT.java | 3 ---
.../beam/sdk/io/gcp/healthcare/HL7v2IOReadWriteIT.java | 3 ---
.../apache/beam/sdk/io/gcp/healthcare/HL7v2IOTestUtil.java | 3 ---
.../apache/beam/sdk/io/gcp/healthcare/HL7v2IOWriteIT.java | 3 ---
.../apache/beam/sdk/io/gcp/pubsub/PubsubGrpcClientTest.java | 3 ---
.../apache/beam/sdk/io/gcp/pubsub/PubsubIOExternalTest.java | 3 ---
.../org/apache/beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 3 ---
.../apache/beam/sdk/io/gcp/pubsub/PubsubJsonClientTest.java | 3 ---
.../beam/sdk/io/gcp/pubsub/PubsubMessageToRowTest.java | 3 ---
.../apache/beam/sdk/io/gcp/pubsub/PubsubTestClientTest.java | 3 ---
.../beam/sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java | 3 ---
.../beam/sdk/io/gcp/pubsub/PubsubUnboundedSourceTest.java | 3 ---
.../beam/sdk/io/gcp/pubsublite/AddUuidsTransformTest.java | 3 ---
.../apache/beam/sdk/io/gcp/pubsublite/FakeSerializable.java | 3 ---
.../beam/sdk/io/gcp/pubsublite/PubsubLiteSinkTest.java | 3 ---
.../apache/beam/sdk/io/gcp/spanner/FakeServiceFactory.java | 3 ---
.../beam/sdk/io/gcp/spanner/MutationKeyEncoderTest.java | 3 ---
.../beam/sdk/io/gcp/spanner/MutationSizeEstimatorTest.java | 3 ---
.../org/apache/beam/sdk/io/gcp/spanner/OrderedCodeTest.java | 3 ---
.../beam/sdk/io/gcp/spanner/ReadSpannerSchemaTest.java | 3 ---
.../apache/beam/sdk/io/gcp/spanner/SpannerAccessorTest.java | 3 ---
.../apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java | 3 ---
.../apache/beam/sdk/io/gcp/spanner/SpannerIOWriteTest.java | 3 ---
.../org/apache/beam/sdk/io/gcp/spanner/SpannerReadIT.java | 3 ---
.../org/apache/beam/sdk/io/gcp/spanner/SpannerWriteIT.java | 3 ---
.../org/apache/beam/sdk/io/gcp/storage/GcsKmsKeyIT.java | 3 ---
.../apache/beam/sdk/io/gcp/testing/BigqueryClientTest.java | 3 ---
.../apache/beam/sdk/io/gcp/testing/BigqueryMatcherTest.java | 3 ---
.../beam/sdk/io/hadoop/SerializableConfigurationTest.java | 3 ---
.../beam/sdk/io/hdfs/HadoopFileSystemRegistrarTest.java | 3 ---
.../org/apache/beam/sdk/io/hdfs/HadoopFileSystemTest.java | 3 ---
.../org/apache/beam/sdk/io/hdfs/HadoopResourceIdTest.java | 3 ---
.../io/hadoop/format/ConfigurableEmployeeInputFormat.java | 3 ---
.../java/org/apache/beam/sdk/io/hadoop/format/Employee.java | 3 ---
.../beam/sdk/io/hadoop/format/EmployeeInputFormat.java | 3 ---
.../beam/sdk/io/hadoop/format/EmployeeOutputFormat.java | 3 ---
.../beam/sdk/io/hadoop/format/HDFSSynchronizationTest.java | 3 ---
.../sdk/io/hadoop/format/HadoopFormatIOCassandraIT.java | 3 ---
.../sdk/io/hadoop/format/HadoopFormatIOCassandraTest.java | 3 ---
.../beam/sdk/io/hadoop/format/HadoopFormatIOElasticIT.java | 3 ---
.../apache/beam/sdk/io/hadoop/format/HadoopFormatIOIT.java | 3 ---
.../beam/sdk/io/hadoop/format/HadoopFormatIOReadTest.java | 1 -
.../io/hadoop/format/HadoopFormatIOSequenceFileTest.java | 3 ---
.../beam/sdk/io/hadoop/format/HadoopFormatIOWriteTest.java | 3 ---
.../beam/sdk/io/hadoop/format/IterableCombinerTest.java | 3 ---
.../io/hadoop/format/ReuseObjectsEmployeeInputFormat.java | 3 ---
.../apache/beam/sdk/io/hadoop/format/TestRowDBWritable.java | 3 ---
.../test/java/org/apache/beam/sdk/io/hbase/HBaseIOIT.java | 3 ---
.../test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 3 ---
.../apache/beam/sdk/io/hcatalog/HCatalogBeamSchemaTest.java | 3 ---
.../java/org/apache/beam/sdk/io/hcatalog/HCatalogIOIT.java | 3 ---
.../org/apache/beam/sdk/io/hcatalog/HCatalogIOTest.java | 3 ---
.../apache/beam/sdk/io/hcatalog/HiveDatabaseTestHelper.java | 3 ---
.../org/apache/beam/sdk/io/hcatalog/SchemaUtilsTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOIT.java | 3 ---
.../test/java/org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 3 ---
.../java/org/apache/beam/sdk/io/jdbc/JdbcTestHelper.java | 3 ---
.../java/org/apache/beam/sdk/io/jdbc/SchemaUtilTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 1 -
.../ConfluentSchemaRegistryDeserializerProviderTest.java | 1 -
.../io/kafka/CustomTimestampPolicyWithLimitedDelayTest.java | 3 ---
.../org/apache/beam/sdk/io/kafka/KafkaIOExternalTest.java | 1 -
.../test/java/org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 3 ---
.../test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 3 ---
.../java/org/apache/beam/sdk/io/kafka/KafkaIOUtilsTest.java | 1 -
.../apache/beam/sdk/io/kafka/ProducerRecordCoderTest.java | 1 -
.../org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 1 -
.../org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java | 3 ---
.../beam/sdk/io/kinesis/DynamicCheckpointGeneratorTest.java | 3 ---
.../java/org/apache/beam/sdk/io/kinesis/KinesisIOIT.java | 3 ---
.../apache/beam/sdk/io/kinesis/KinesisMockWriteTest.java | 3 ---
.../beam/sdk/io/kinesis/KinesisReaderCheckpointTest.java | 3 ---
.../org/apache/beam/sdk/io/kinesis/KinesisReaderTest.java | 3 ---
.../org/apache/beam/sdk/io/kinesis/KinesisServiceMock.java | 3 ---
.../org/apache/beam/sdk/io/kinesis/RecordFilterTest.java | 3 ---
.../org/apache/beam/sdk/io/kinesis/ShardCheckpointTest.java | 3 ---
.../apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java | 3 ---
.../beam/sdk/io/kinesis/ShardRecordsIteratorTest.java | 3 ---
.../beam/sdk/io/kinesis/SimplifiedKinesisClientTest.java | 3 ---
.../beam/sdk/io/kinesis/StartingPointShardsFinderTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/kudu/KuduIOIT.java | 3 ---
.../test/java/org/apache/beam/sdk/io/kudu/KuduIOTest.java | 3 ---
.../org/apache/beam/sdk/io/mongodb/MongoDBGridFSIOTest.java | 3 ---
.../java/org/apache/beam/sdk/io/mongodb/MongoDBIOIT.java | 3 ---
.../java/org/apache/beam/sdk/io/mongodb/MongoDbIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 3 ---
.../java/org/apache/beam/sdk/io/parquet/ParquetIOTest.java | 3 ---
.../org/apache/beam/sdk/io/rabbitmq/ExchangeTestPlan.java | 3 ---
.../org/apache/beam/sdk/io/rabbitmq/RabbitMqIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/redis/RedisIOTest.java | 3 ---
.../beam/sdk/io/snowflake/test/BatchSnowflakeIOIT.java | 3 ---
.../sdk/io/snowflake/test/FakeSnowflakeBasicDataSource.java | 3 ---
.../io/snowflake/test/FakeSnowflakeBatchServiceImpl.java | 3 ---
.../beam/sdk/io/snowflake/test/FakeSnowflakeDatabase.java | 3 ---
.../snowflake/test/FakeSnowflakeStreamingServiceImpl.java | 3 ---
.../beam/sdk/io/snowflake/test/StreamingSnowflakeIOIT.java | 3 ---
.../org/apache/beam/sdk/io/snowflake/test/TestUtils.java | 1 -
.../io/snowflake/test/unit/DataSourceConfigurationTest.java | 3 ---
.../io/snowflake/test/unit/read/SnowflakeIOReadTest.java | 1 -
.../io/snowflake/test/unit/write/CreateDispositionTest.java | 1 -
.../test/unit/write/QueryDispositionLocationTest.java | 1 -
.../io/snowflake/test/unit/write/SchemaDispositionTest.java | 1 -
.../io/snowflake/test/unit/write/SnowflakeIOWriteTest.java | 1 -
.../io/snowflake/test/unit/write/StreamingWriteTest.java | 1 -
.../org/apache/beam/sdk/io/solr/JavaBinCodecCoderTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/solr/SolrIOTest.java | 1 -
.../apache/beam/sdk/io/splunk/SplunkEventWriterTest.java | 3 ---
.../java/org/apache/beam/sdk/io/splunk/SplunkIOTest.java | 3 ---
.../apache/beam/sdk/io/synthetic/BundleSplitterTest.java | 1 -
.../beam/sdk/io/synthetic/SyntheticBoundedSourceTest.java | 3 ---
.../beam/sdk/io/synthetic/SyntheticUnboundedSourceTest.java | 3 ---
.../java/org/apache/beam/sdk/io/thrift/ThriftIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/tika/TikaIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/xml/JAXBCoderTest.java | 3 ---
.../src/test/java/org/apache/beam/sdk/io/xml/XmlIOTest.java | 3 ---
.../test/java/org/apache/beam/sdk/io/xml/XmlSourceTest.java | 3 ---
.../beam/sdk/testing/expansion/TestExpansionService.java | 1 -
.../java/org/apache/beam/sdk/nexmark/NexmarkUtilsTest.java | 1 -
.../org/apache/beam/sdk/nexmark/PerfsToBigQueryTest.java | 3 ---
.../apache/beam/sdk/testutils/fakes/FakeBigQueryClient.java | 3 ---
.../sdk/testutils/fakes/FakeBigQueryResultsPublisher.java | 3 ---
.../beam/sdk/testutils/jvmverification/JvmVerification.java | 3 ---
.../testutils/publishing/BigQueryResultsPublisherTest.java | 3 ---
845 files changed, 16 insertions(+), 2259 deletions(-)