You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2018/05/31 16:55:45 UTC
[beam] 01/01: Merge pull request #4748: Avoid fully qualified class names, when there is an existing (static)…
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 <ie...@gmail.com>
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
iemejia@apache.org.