You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2019/10/25 20:28:42 UTC
[beam] branch master updated (9f8fdd1 -> 23f9e5c)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9f8fdd1 Merge pull request #9757: [BEAM-8484] RowJsonDeserializer/ToJson cleanup
add 90f5dff [BEAM-8456] Add pipeline option to have Data Catalog truncate sub-millisecond precision.
add b2329dc Inline Data Catalog TableUtils to its only use
add 01c355b Make BigQueryUtils, PubsubUtils, GcsUtils implementations of TableFactory; respect truncateTimestamps option
add 23f9e5c Merge pull request #9849: [BEAM-8456] Add pipeline option to have Data Catalog truncate sub-millisecond precision
No new revisions were added by this update.
Summary of changes:
...igQueryUtils.java => BigQueryTableFactory.java} | 32 ++++++---
.../{PubsubUtils.java => ChainedTableFactory.java} | 43 ++++++------
.../datacatalog/DataCatalogPipelineOptions.java | 8 +++
.../datacatalog/DataCatalogTableProvider.java | 81 +++++++++++++++-------
.../{GcsUtils.java => GcsTableFactory.java} | 29 ++++----
.../{PubsubUtils.java => PubsubTableFactory.java} | 26 ++++---
...talogPipelineOptions.java => TableFactory.java} | 28 ++++----
.../sql/meta/provider/datacatalog/TableUtils.java | 68 ------------------
8 files changed, 157 insertions(+), 158 deletions(-)
rename sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/{BigQueryUtils.java => BigQueryTableFactory.java} (65%)
copy sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/{PubsubUtils.java => ChainedTableFactory.java} (51%)
rename sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/{GcsUtils.java => GcsTableFactory.java} (77%)
rename sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/{PubsubUtils.java => PubsubTableFactory.java} (71%)
copy sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/{DataCatalogPipelineOptions.java => TableFactory.java} (58%)
delete mode 100644 sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/TableUtils.java