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 <[email protected]> Authored: Tue Aug 29 14:07:06 2017 -0700 Committer: Eugene Kirpichov <[email protected]> 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(-) ----------------------------------------------------------------------
