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
