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(-) ----------------------------------------------------------------------
