This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1891410 Merge pull request #7519 from tvalentyn/pip_retries add 2662f2b Apply spotless. new b83b302 Merge pull request #7523: Apply spotless across Beam The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../apache/beam/examples/WindowedWordCount.java | 3 +- .../apache/beam/examples/common/ExampleUtils.java | 6 +- .../beam/examples/cookbook/TriggerExample.java | 25 +++-- .../examples/complete/game/LeaderBoardTest.java | 12 ++- .../apache/beam/runners/apex/TestApexRunner.java | 2 +- .../runners/apex/translation/ParDoTranslator.java | 12 +-- .../translation/operators/ApexParDoOperator.java | 2 +- .../beam/runners/apex/ApexYarnLauncherTest.java | 4 +- .../core/construction/CombineTranslation.java | 3 +- .../CreatePCollectionViewTranslation.java | 3 +- .../construction/ExecutableStageTranslation.java | 5 +- .../core/construction/ParDoTranslation.java | 5 +- .../construction/PipelineOptionsTranslation.java | 2 +- .../core/construction/PipelineResources.java | 3 +- .../core/construction/PipelineTranslation.java | 8 +- .../construction/SplittableParDoNaiveBounded.java | 6 +- .../UnboundedReadFromBoundedSource.java | 3 +- .../core/construction/WriteFilesTranslation.java | 15 ++- .../core/construction/graph/ExecutableStage.java | 23 ++--- .../core/construction/graph/FusedPipeline.java | 3 +- .../graph/GreedyPCollectionFusers.java | 6 +- .../construction/graph/GreedyPipelineFuser.java | 42 ++------ .../graph/ImmutableExecutableStage.java | 3 +- .../runners/core/construction/graph/Networks.java | 9 +- .../construction/graph/OutputDeduplicator.java | 7 +- .../core/construction/graph/QueryablePipeline.java | 53 ++++------ .../ExecutableStageTranslationTest.java | 4 +- .../SingleInputOutputOverrideFactoryTest.java | 6 +- .../construction/graph/ExecutableStageMatcher.java | 9 +- .../graph/GreedyPipelineFuserTest.java | 15 +-- .../construction/graph/GreedyStageFuserTest.java | 4 +- .../core/construction/graph/NetworksTest.java | 8 +- .../construction/graph/OutputDeduplicatorTest.java | 24 +---- .../construction/graph/QueryablePipelineTest.java | 5 +- .../runners/core/LateDataDroppingDoFnRunner.java | 4 +- .../core/SplittableParDoViaKeyedWorkItems.java | 6 +- .../apache/beam/runners/core/ReduceFnTester.java | 3 +- ...DirectGBKIntoKeyedWorkItemsOverrideFactory.java | 6 +- .../direct/DirectGroupByKeyOverrideFactory.java | 6 +- .../direct/ExecutorServiceParallelExecutor.java | 3 +- .../direct/GroupAlsoByWindowEvaluatorFactory.java | 9 +- .../beam/runners/direct/MultiStepCombine.java | 15 ++- .../apache/beam/runners/direct/ParDoEvaluator.java | 4 +- .../runners/direct/ParDoMultiOverrideFactory.java | 9 +- .../SplittableProcessElementsEvaluatorFactory.java | 3 +- .../direct/StatefulParDoEvaluatorFactory.java | 9 +- .../beam/runners/direct/ViewOverrideFactory.java | 6 +- .../runners/direct/WriteWithShardingFactory.java | 6 +- .../portable/ExecutorServiceParallelExecutor.java | 3 +- .../runners/direct/portable/ReferenceRunner.java | 3 +- .../portable/job/ReferenceRunnerJobServer.java | 7 +- .../beam/runners/direct/DirectRunnerTest.java | 3 +- .../direct/StatefulParDoEvaluatorFactoryTest.java | 6 +- .../direct/WriteWithShardingFactoryTest.java | 3 +- .../portable/RemoteStageEvaluatorFactoryTest.java | 8 +- .../extensions/metrics/MetricsGraphiteSink.java | 30 +++--- .../runners/flink/CreateStreamingFlinkView.java | 6 +- .../FlinkBatchPortablePipelineTranslator.java | 2 +- .../flink/FlinkBatchTransformTranslators.java | 6 +- .../flink/FlinkBatchTranslationContext.java | 5 +- .../runners/flink/FlinkExecutionEnvironments.java | 6 +- .../beam/runners/flink/FlinkJobInvocation.java | 3 +- .../beam/runners/flink/FlinkJobServerDriver.java | 33 +++--- .../flink/FlinkStreamingPipelineTranslator.java | 6 +- .../FlinkStreamingPortablePipelineTranslator.java | 5 +- .../flink/FlinkStreamingTransformTranslators.java | 3 +- .../flink/FlinkStreamingTranslationContext.java | 5 +- .../flink/PipelineTranslationModeOptimizer.java | 5 +- .../FlinkDefaultExecutableStageContext.java | 3 +- .../functions/FlinkExecutableStageFunction.java | 2 +- .../functions/SideInputInitializer.java | 4 +- .../streaming/ExecutableStageDoFnOperator.java | 11 +- .../streaming/io/UnboundedSourceWrapperTest.java | 7 +- .../dataflow/BatchStatefulParDoOverrides.java | 15 ++- .../dataflow/DataflowPipelineTranslator.java | 15 +-- .../beam/runners/dataflow/DataflowRunner.java | 15 +-- .../dataflow/PrimitiveParDoSingleFactory.java | 3 +- .../runners/dataflow/internal/CustomSources.java | 2 +- .../runners/dataflow/util/DataflowTransport.java | 3 +- .../worker/BeamFnMapTaskExecutorFactory.java | 3 +- .../worker/fn/control/BeamFnMapTaskExecutor.java | 4 +- .../graph/CreateExecutableStageNodeFunction.java | 3 +- .../dataflow/worker/status/ThreadzServlet.java | 4 +- .../dataflow/worker/graph/NetworksTest.java | 8 +- .../fnexecution/InProcessServerFactory.java | 6 +- .../beam/runners/fnexecution/ServerFactory.java | 3 +- .../BeamFileSystemArtifactRetrievalService.java | 7 +- .../control/ProcessBundleDescriptors.java | 7 +- .../environment/DockerEnvironmentFactory.java | 9 +- .../BeamFileSystemArtifactServicesTest.java | 4 +- ...gleEnvironmentInstanceJobBundleFactoryTest.java | 8 +- .../runners/samza/adapter/BoundedSourceSystem.java | 3 +- .../samza/adapter/UnboundedSourceSystem.java | 5 +- .../samza/metrics/SamzaMetricsContainer.java | 2 +- .../apache/beam/runners/samza/runtime/DoFnOp.java | 5 +- .../samza/runtime/SamzaStoreStateInternals.java | 2 +- .../beam/runners/samza/runtime/WindowAssignOp.java | 3 +- .../translation/ParDoBoundMultiTranslator.java | 9 +- .../runners/samza/adapter/TestBoundedSource.java | 3 +- .../runners/samza/adapter/TestCheckpointMark.java | 2 +- .../runners/samza/adapter/TestUnboundedSource.java | 3 +- .../runners/spark/SparkNativePipelineVisitor.java | 3 +- .../beam/runners/spark/coders/CoderHelpers.java | 3 +- .../apache/beam/runners/spark/io/CreateStream.java | 4 +- .../beam/runners/spark/io/SourceDStream.java | 4 +- .../SparkGroupAlsoByWindowViaWindowSet.java | 10 +- .../spark/stateful/SparkStateInternals.java | 2 +- .../runners/spark/stateful/StateSpecFunctions.java | 8 +- .../runners/spark/translation/BoundedDataset.java | 3 +- .../spark/translation/EvaluationContext.java | 5 +- .../spark/translation/SparkAbstractCombineFn.java | 2 +- .../spark/translation/SparkGlobalCombineFn.java | 4 +- .../SparkGroupAlsoByWindowViaOutputBufferFn.java | 2 +- .../spark/translation/SparkKeyedCombineFn.java | 4 +- .../spark/translation/SparkPCollectionView.java | 2 +- .../SparkRunnerStreamingContextFactory.java | 2 +- .../runners/spark/util/SparkSideInputReader.java | 6 +- .../aggregators/metrics/sink/InMemoryMetrics.java | 10 +- .../ResumeFromCheckpointStreamingTest.java | 11 +- .../apache/beam/sdk/annotations/Experimental.java | 3 +- .../java/org/apache/beam/sdk/coders/RowCoder.java | 4 +- .../main/java/org/apache/beam/sdk/io/TextIO.java | 3 +- .../beam/sdk/options/PipelineOptionsFactory.java | 3 +- .../beam/sdk/options/ProxyInvocationHandler.java | 3 +- .../apache/beam/sdk/schemas/AutoValueSchema.java | 3 +- .../beam/sdk/schemas/FieldAccessDescriptor.java | 8 +- .../beam/sdk/schemas/FieldTypeDescriptors.java | 1 + .../apache/beam/sdk/schemas/JavaBeanSchema.java | 6 +- .../apache/beam/sdk/schemas/JavaFieldSchema.java | 6 +- .../java/org/apache/beam/sdk/schemas/Schema.java | 7 +- .../apache/beam/sdk/schemas/transforms/Cast.java | 3 +- .../beam/sdk/schemas/transforms/CoGroup.java | 5 +- .../apache/beam/sdk/schemas/transforms/Filter.java | 8 +- .../sdk/schemas/transforms/SchemaAggregateFn.java | 3 +- .../apache/beam/sdk/schemas/transforms/Unnest.java | 1 + .../beam/sdk/schemas/utils/AutoValueUtils.java | 9 +- .../apache/beam/sdk/schemas/utils/AvroUtils.java | 3 +- .../beam/sdk/schemas/utils/JavaBeanUtils.java | 3 +- .../sdk/schemas/utils/StaticSchemaInference.java | 7 +- .../org/apache/beam/sdk/transforms/DoFnTester.java | 9 +- .../beam/sdk/transforms/GroupIntoBatches.java | 2 +- .../beam/sdk/transforms/reflect/DoFnSignature.java | 12 +-- .../sdk/transforms/reflect/DoFnSignatures.java | 6 +- .../sdk/util/FilePatternMatchingShardedFile.java | 3 +- .../java/org/apache/beam/sdk/util/MoreFutures.java | 11 +- .../apache/beam/sdk/util/RowJsonDeserializer.java | 5 +- .../org/apache/beam/sdk/coders/AvroCoderTest.java | 8 +- .../org/apache/beam/sdk/io/TextIOWriteTest.java | 9 +- .../beam/sdk/schemas/FieldTypeDescriptorsTest.java | 1 + .../beam/sdk/schemas/transforms/UnnestTest.java | 16 ++- .../beam/sdk/transforms/FlatMapElementsTest.java | 6 +- .../reflect/DoFnSignaturesSplittableDoFnTest.java | 7 +- .../sdk/extensions/gcp/options/GcpOptions.java | 3 +- .../java/org/apache/beam/sdk/util/Transport.java | 3 +- .../sdk/extensions/sql/example/BeamSqlExample.java | 6 +- .../sdk/extensions/sql/impl/JdbcConnection.java | 5 +- .../beam/sdk/extensions/sql/impl/UdafImpl.java | 2 +- .../sql/impl/rel/BeamAggregationRel.java | 3 +- .../sql/impl/rel/BeamEnumerableConverter.java | 16 +-- .../sdk/extensions/sql/impl/rel/BeamRelNode.java | 3 +- .../sdk/extensions/sql/impl/rel/BeamSortRel.java | 3 +- .../extensions/sql/impl/rel/BeamSqlRelUtils.java | 3 +- .../extensions/sql/impl/schema/BeamTableUtils.java | 2 +- .../impl/transform/BeamSetOperatorsTransforms.java | 3 +- .../sql/impl/udf/BeamBuiltinFunctionProvider.java | 3 +- .../sql/impl/udf/BuiltinStringFunctions.java | 112 +++++++++------------ .../impl/udf/BuiltinTrigonometricFunctions.java | 21 ++-- .../beam/sdk/extensions/sql/impl/udf/IsInf.java | 14 ++- .../beam/sdk/extensions/sql/impl/udf/IsNan.java | 14 ++- .../extensions/sql/impl/utils/CalciteUtils.java | 2 +- .../meta/provider/pubsub/PubsubMessageToRow.java | 4 +- .../sql/meta/provider/test/TestTableProvider.java | 4 +- .../sql/meta/provider/test/TestTableUtils.java | 3 +- .../beam/sdk/extensions/sql/BeamSqlDslBase.java | 4 +- .../sql/BeamSqlDslSqlStdOperatorsTest.java | 4 +- .../sdk/extensions/sql/impl/JdbcDriverTest.java | 9 +- .../sql/impl/parser/BeamDDLNestedTypesTest.java | 5 +- .../sql/impl/utils/CalciteUtilsTest.java | 4 +- .../sql/meta/provider/pubsub/PubsubJsonIT.java | 5 +- .../harness/SplittableProcessElementsRunner.java | 4 +- .../harness/data/QueueingBeamFnDataClientTest.java | 2 +- .../apache/beam/sdk/io/aws/options/AwsModule.java | 7 +- .../apache/beam/sdk/io/aws/s3/S3FileSystem.java | 3 +- .../java/org/apache/beam/sdk/io/aws/sns/SnsIO.java | 4 +- .../beam/sdk/io/aws/s3/S3FileSystemTest.java | 6 +- .../sdk/io/cassandra/CassandraServiceImpl.java | 11 +- .../beam/sdk/io/clickhouse/ClickHouseIO.java | 4 +- .../apache/beam/sdk/io/clickhouse/TableSchema.java | 4 +- .../sdk/io/elasticsearch/ElasticsearchIOTest.java | 2 +- .../sdk/io/elasticsearch/ElasticsearchIOTest.java | 2 +- .../sdk/io/elasticsearch/ElasticsearchIOTest.java | 2 +- .../elasticsearch/ElasticsearchIOTestCommon.java | 7 +- .../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 12 +-- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 6 +- .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 3 +- .../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 10 +- .../beam/sdk/io/gcp/bigquery/TestBigQuery.java | 3 +- .../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 3 +- .../io/gcp/bigquery/BigQueryServicesImplTest.java | 3 +- .../sdk/io/gcp/bigquery/BigQueryToTableIT.java | 22 ++-- .../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 13 ++- .../beam/sdk/io/gcp/datastore/V1TestUtil.java | 2 +- .../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 3 +- .../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 13 +-- .../apache/beam/sdk/io/hdfs/HadoopFileSystem.java | 3 +- .../sdk/io/hadoop/format/HDFSSynchronization.java | 2 +- .../beam/sdk/io/hadoop/format/HadoopFormatIO.java | 3 +- .../hadoop/format/HadoopFormatIOCassandraTest.java | 2 +- .../format/HadoopFormatIOSequenceFileTest.java | 6 +- .../hadoop/format/HadoopFormatIOTestOptions.java | 4 +- .../sdk/io/hadoop/format/TestEmployeeDataSet.java | 13 +-- .../HIFIOWithEmbeddedCassandraTest.java | 2 +- .../sdk/io/hadoop/inputformat/HIFITestOptions.java | 4 +- .../io/hadoop/inputformat/TestEmployeeDataSet.java | 13 +-- .../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 6 +- .../sdk/io/hcatalog/HiveDatabaseTestHelper.java | 1 + 216 files changed, 642 insertions(+), 857 deletions(-)