You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/05/04 22:55:30 UTC
[3/3] beam git commit: This closes #2695
This closes #2695
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/defb5540
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/defb5540
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/defb5540
Branch: refs/heads/master
Commit: defb55405f1bbbd33e74dd3551b2d0f0c358a55d
Parents: 8af5c28 d59d9b7
Author: Thomas Groh <tg...@google.com>
Authored: Thu May 4 15:55:17 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Thu May 4 15:55:17 2017 -0700
----------------------------------------------------------------------
.../beam/runners/core/BaseExecutionContext.java | 9 --
.../apache/beam/runners/core/DoFnAdapters.java | 111 ++++++++++---
.../beam/runners/core/ExecutionContext.java | 10 +-
...eBoundedSplittableProcessElementInvoker.java | 13 +-
.../beam/runners/core/SimpleDoFnRunner.java | 161 +++++++++++++++----
.../beam/runners/core/SplittableParDo.java | 35 ++--
.../beam/runners/core/SimpleDoFnRunnerTest.java | 4 +-
.../beam/runners/core/SplittableParDoTest.java | 4 +-
runners/google-cloud-dataflow-java/pom.xml | 2 +-
.../runners/dataflow/BatchViewOverrides.java | 2 +-
.../java/org/apache/beam/sdk/io/WriteFiles.java | 7 +-
.../beam/sdk/options/PipelineOptions.java | 3 +-
.../org/apache/beam/sdk/transforms/Combine.java | 5 +-
.../org/apache/beam/sdk/transforms/DoFn.java | 79 ++++++---
.../apache/beam/sdk/transforms/DoFnTester.java | 62 ++++---
.../beam/sdk/transforms/GroupIntoBatches.java | 2 +-
.../org/apache/beam/sdk/transforms/ParDo.java | 5 +-
.../reflect/ByteBuddyDoFnInvokerFactory.java | 19 ++-
.../sdk/transforms/reflect/DoFnInvoker.java | 19 ++-
.../sdk/transforms/reflect/DoFnSignature.java | 42 +++--
.../sdk/transforms/reflect/DoFnSignatures.java | 58 +++++--
.../beam/sdk/transforms/windowing/PaneInfo.java | 3 +-
.../apache/beam/sdk/metrics/MetricsTest.java | 4 +-
.../beam/sdk/transforms/DoFnTesterTest.java | 8 +-
.../beam/sdk/transforms/ParDoLifecycleTest.java | 16 +-
.../apache/beam/sdk/transforms/ParDoTest.java | 75 ++-------
.../beam/sdk/transforms/SplittableDoFnTest.java | 4 +-
.../transforms/reflect/DoFnInvokersTest.java | 22 ++-
.../transforms/reflect/DoFnSignaturesTest.java | 15 +-
.../control/ProcessBundleHandlerTest.java | 17 +-
.../sdk/io/elasticsearch/ElasticsearchIO.java | 12 +-
.../sdk/io/gcp/bigquery/StreamingWriteFn.java | 4 +-
.../sdk/io/gcp/bigquery/TagWithUniqueIds.java | 2 +-
.../io/gcp/bigquery/WriteBundlesToFiles.java | 17 +-
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 4 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 10 +-
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 4 +-
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 4 +-
.../java/org/apache/beam/sdk/io/hdfs/Write.java | 7 +-
.../org/apache/beam/sdk/io/hbase/HBaseIO.java | 7 +-
.../org/apache/beam/sdk/io/jdbc/JdbcIO.java | 11 +-
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 6 +-
.../org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 +-
.../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 4 +-
.../apache/beam/sdk/io/mongodb/MongoDbIO.java | 10 +-
45 files changed, 603 insertions(+), 317 deletions(-)
----------------------------------------------------------------------