This is an automated email from the ASF dual-hosted git repository. iemejia pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1414dd56e79e73fe944e2af38db5730cd612e4e5 Merge: f6dd249 f620e9c Author: Ismaël Mejía <[email protected]> AuthorDate: Thu May 31 18:55:37 2018 +0200 Merge pull request #4748: Avoid fully qualified class names, when there is an existing (static)… .../apache/beam/runners/apex/ApexYarnLauncher.java | 2 +- .../beam/runners/apex/ApexYarnLauncherTest.java | 4 +- .../core/construction/CoderTranslationTest.java | 2 +- .../construction/PCollectionTranslationTest.java | 9 ++-- .../core/construction/ParDoTranslationTest.java | 13 +++--- .../core/construction/ReadTranslationTest.java | 5 +-- .../core/construction/ReplacementOutputsTest.java | 4 +- .../core/construction/SdkComponentsTest.java | 3 +- .../construction/TestStreamTranslationTest.java | 3 +- .../WindowingStrategyTranslationTest.java | 3 +- .../beam/runners/core/ReduceFnRunnerTest.java | 48 +++++++++++----------- .../SimplePushbackSideInputDoFnRunnerTest.java | 5 +-- .../beam/runners/core/StateInternalsTest.java | 2 +- .../direct/UnboundedReadEvaluatorFactory.java | 3 +- .../direct/BoundedReadEvaluatorFactoryTest.java | 6 +-- .../runners/direct/CloningBundleFactoryTest.java | 3 +- .../runners/direct/DirectGraphVisitorTest.java | 2 +- .../direct/DirectTransformExecutorTest.java | 8 ++-- ...cycleManagerRemovingTransformEvaluatorTest.java | 2 +- .../beam/runners/direct/EvaluationContextTest.java | 5 +-- .../direct/ImmutableListBundleFactoryTest.java | 9 ++-- .../beam/runners/direct/ParDoEvaluatorTest.java | 2 +- .../runners/direct/StepTransformResultTest.java | 3 +- .../direct/UnboundedReadEvaluatorFactoryTest.java | 4 +- .../runners/direct/ViewOverrideFactoryTest.java | 5 +-- .../beam/runners/direct/WatermarkManagerTest.java | 17 ++++---- .../flink/FlinkStreamingTransformTranslators.java | 2 +- .../gearpump/translators/GroupByKeyTranslator.java | 4 +- .../beam/runners/dataflow/BatchViewOverrides.java | 3 +- .../beam/runners/dataflow/DataflowMetrics.java | 32 +++++++-------- .../beam/runners/dataflow/DataflowRunner.java | 3 +- .../dataflow/PrimitiveParDoSingleFactory.java | 2 +- .../beam/runners/dataflow/util/MonitoringUtil.java | 2 +- .../dataflow/DataflowPipelineTranslatorTest.java | 10 ++--- .../beam/runners/dataflow/DataflowRunnerTest.java | 2 +- .../beam/runners/spark/io/SourceDStream.java | 2 +- .../apache/beam/runners/spark/io/SourceRDD.java | 8 ++-- .../runners/spark/stateful/StateSpecFunctions.java | 4 +- .../java/org/apache/beam/sdk/coders/AvroCoder.java | 6 +-- .../main/java/org/apache/beam/sdk/io/FileIO.java | 2 +- .../java/org/apache/beam/sdk/PipelineTest.java | 9 ++-- .../sdk/options/PipelineOptionsReflectorTest.java | 12 +++--- .../beam/sdk/runners/TransformHierarchyTest.java | 14 +++---- .../org/apache/beam/sdk/transforms/ViewTest.java | 15 ++++--- .../org/apache/beam/sdk/transforms/WatchTest.java | 20 ++++----- .../sdk/transforms/display/DisplayDataTest.java | 6 +-- .../transforms/windowing/CalendarWindowsTest.java | 3 +- .../sdk/transforms/windowing/FixedWindowsTest.java | 3 +- .../beam/sdk/values/PCollectionListTest.java | 3 +- .../beam/sdk/values/PCollectionTupleTest.java | 3 +- .../operator/string/BeamSqlTrimExpressionTest.java | 9 ++-- .../stream/HarnessStreamObserverFactories.java | 2 +- .../beam/sdk/io/aws/s3/S3ResourceIdTest.java | 20 ++++----- .../java/org/apache/beam/sdk/io/amqp/AmqpIO.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryHelpersTest.java | 12 +++--- .../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 8 ++-- .../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 11 +++-- .../beam/sdk/io/gcp/datastore/V1TestUtil.java | 2 +- .../io/hadoop/inputformat/HIFIOCassandraIT.java | 2 +- .../hadoop/inputformat/HIFIOWithElasticTest.java | 2 +- .../HIFIOWithEmbeddedCassandraTest.java | 2 +- .../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 3 +- .../beam/sdk/io/kinesis/ShardReadersPoolTest.java | 17 ++++---- .../apache/beam/sdk/io/mongodb/MongoDbIOTest.java | 2 +- .../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 2 +- .../java/org/apache/beam/sdk/io/tika/TikaIO.java | 2 +- 66 files changed, 206 insertions(+), 234 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
