You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/08/29 21:26:18 UTC
[2/2] beam git commit: This closes #3663: [BEAM-2390] Add support for
TimePartitioning in BigQueryIO
This closes #3663: [BEAM-2390] Add support for TimePartitioning in BigQueryIO
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6280d497
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6280d497
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6280d497
Branch: refs/heads/master
Commit: 6280d497b5264536a485993ccdf21034f2a1c3d8
Parents: 1c26b74 b0e03a3
Author: Eugene Kirpichov <ki...@google.com>
Authored: Tue Aug 29 14:07:06 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Tue Aug 29 14:07:06 2017 -0700
----------------------------------------------------------------------
pom.xml | 2 +-
...aultCoderCloudObjectTranslatorRegistrar.java | 2 +
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 4 +-
.../sdk/io/gcp/bigquery/BigQueryHelpers.java | 8 +++
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 47 ++++++++++++++++
.../beam/sdk/io/gcp/bigquery/CreateTables.java | 15 +++--
.../bigquery/DynamicDestinationsHelpers.java | 27 ++++++++-
.../sdk/io/gcp/bigquery/TableDestination.java | 39 ++++++++++++-
.../io/gcp/bigquery/TableDestinationCoder.java | 2 +
.../gcp/bigquery/TableDestinationCoderV2.java | 59 ++++++++++++++++++++
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 7 ++-
.../sdk/io/gcp/bigquery/BigQueryIOTest.java | 50 +++++++++++++++++
.../sdk/io/gcp/bigquery/FakeJobService.java | 32 +++++++++--
.../sdk/io/gcp/bigquery/TableContainer.java | 2 +
14 files changed, 278 insertions(+), 18 deletions(-)
----------------------------------------------------------------------