You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by re...@apache.org on 2019/01/16 02:09:55 UTC
[beam] 01/01: Merge pull request #7523: Apply spotless across Beam
This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit b83b302ef97767e4ca245ea24e8bd40a6692e72c
Merge: 1891410 2662f2b
Author: reuvenlax <re...@google.com>
AuthorDate: Tue Jan 15 18:09:44 2019 -0800
Merge pull request #7523: Apply spotless across Beam
.../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(-)