You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2016/03/31 01:28:50 UTC

[2/2] incubator-beam git commit: This closes #45

This closes #45


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c6aac3b2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c6aac3b2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c6aac3b2

Branch: refs/heads/master
Commit: c6aac3b263df2da3bd8c335fdf131e462ef9268d
Parents: 78abd96 a8eeaf5
Author: Luke Cwik <lc...@google.com>
Authored: Wed Mar 30 16:28:31 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Mar 30 16:28:31 2016 -0700

----------------------------------------------------------------------
 .../dataflow/examples/common/DataflowExampleUtils.java  |  8 +++-----
 .../com/google/cloud/dataflow/sdk/io/BigQueryIO.java    |  3 +++
 .../dataflow/sdk/io/BoundedReadFromUnboundedSource.java |  6 +++---
 .../sdk/runners/BlockingDataflowPipelineRunner.java     |  3 +++
 .../cloud/dataflow/sdk/runners/DataflowPipelineJob.java |  3 +++
 .../sdk/transforms/IntraBundleParallelization.java      |  1 +
 .../cloud/dataflow/sdk/util/BigQueryTableInserter.java  |  2 ++
 .../dataflow/sdk/util/BigQueryTableRowIterator.java     | 12 +++++++-----
 .../com/google/cloud/dataflow/sdk/util/GcsUtil.java     |  4 ++++
 9 files changed, 29 insertions(+), 13 deletions(-)
----------------------------------------------------------------------