You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2018/12/18 13:16:08 UTC
[beam] 01/01: Merge pull request #7007 from coheigea/return
This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit af5d7bf51ef7b44864b2d1f0cc3c21904a730425
Merge: c29092e 0cdfca4
Author: Robert Bradshaw <ro...@gmail.com>
AuthorDate: Tue Dec 18 14:15:56 2018 +0100
Merge pull request #7007 from coheigea/return
Avoid creating a variable and immediately returning it.
.../beam/examples/complete/TrafficRoutes.java | 3 +-
.../beam/examples/cookbook/FilterExamples.java | 3 +-
.../beam/examples/cookbook/TriggerExample.java | 3 +-
.../runners/core/LateDataDroppingDoFnRunner.java | 17 +++----
.../apache/beam/runners/core/SideInputHandler.java | 3 +-
.../runners/direct/ParDoMultiOverrideFactory.java | 32 +++++-------
.../runners/direct/WindowEvaluatorFactory.java | 3 +-
.../direct/portable/WindowEvaluatorFactory.java | 3 +-
.../beam/runners/direct/DirectRunnerTest.java | 6 +--
.../direct/UnboundedReadEvaluatorFactoryTest.java | 3 +-
.../runners/direct/WindowEvaluatorFactoryTest.java | 3 +-
.../dataflow/worker/IsmSideInputReader.java | 3 +-
.../worker/graph/LengthPrefixUnknownCoders.java | 3 +-
.../common/worker/BatchingShuffleEntryReader.java | 3 +-
.../runners/dataflow/worker/ConcatReaderTest.java | 3 +-
.../dataflow/worker/ShuffleReaderFactoryTest.java | 3 +-
.../apache/beam/runners/local/StructuralKey.java | 14 +++---
.../beam/runners/spark/examples/WordCount.java | 4 +-
.../spark/translation/TranslationUtils.java | 5 +-
.../org/apache/beam/sdk/options/ValueProvider.java | 6 +--
.../beam/sdk/schemas/FieldTypeDescriptors.java | 3 +-
.../reflect/ByteBuddyOnTimerInvokerFactory.java | 4 +-
.../java/org/apache/beam/sdk/util/CoderUtils.java | 3 +-
.../main/java/org/apache/beam/sdk/values/Row.java | 8 ++-
.../apache/beam/sdk/values/TypeDescriptors.java | 28 +++--------
.../java/org/apache/beam/sdk/util/GcsUtil.java | 31 ++++++------
.../operator/BeamSqlLocalRefExpression.java | 4 +-
.../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 29 +++++------
.../sql/impl/rel/BeamSetOperatorRelBase.java | 10 ++--
.../impl/transform/agg/CovarianceAccumulator.java | 37 ++++++--------
.../meta/provider/kafka/KafkaTableProvider.java | 3 +-
.../sql/meta/provider/test/TestTableProvider.java | 3 +-
.../org/apache/beam/sdk/io/aws/sns/SnsIOTest.java | 3 +-
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 12 ++---
.../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 10 ++--
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 3 +-
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 29 +++++------
.../org/apache/beam/sdk/nexmark/NexmarkUtils.java | 58 +++++++++++-----------
.../sdk/nexmark/sources/generator/Generator.java | 3 +-
39 files changed, 159 insertions(+), 245 deletions(-)