You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by re...@apache.org on 2019/12/05 05:15:42 UTC
[beam] branch master updated (403fcd9 -> 5124385)
This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 403fcd9 [BEAM-8884] Fix mongodb splitVector command result type issue (#10282)
add 5124385 Merge pull request #10247: [BEAM-7274] In preparation for protocol-buffer schemas, add OneOf and Enumeration logical types
No new revisions were added by this update.
Summary of changes:
.../core/construction/CoderTranslators.java | 1 +
.../core/construction/CoderTranslationTest.java | 4 +-
.../runners/core/construction/CommonCoderTest.java | 1 +
.../core/construction/SchemaTranslationTest.java | 6 +-
.../util/SchemaCoderCloudObjectTranslator.java | 2 +-
.../runners/dataflow/util/CloudObjectsTest.java | 4 +-
.../org/apache/beam/sdk/schemas/LogicalTypes.java | 114 --------------
.../java/org/apache/beam/sdk/schemas/Schema.java | 55 +++++--
.../beam/sdk/schemas}/SchemaTranslation.java | 3 +-
.../sdk/schemas/logicaltypes/EnumerationType.java | 165 ++++++++++++++++++++
.../beam/sdk/schemas/logicaltypes/FixedBytes.java | 83 ++++++++++
.../beam/sdk/schemas/logicaltypes/OneOfType.java | 172 +++++++++++++++++++++
.../logicaltypes/PassThroughLogicalType.java | 68 ++++++++
.../{parser => logicaltypes}/package-info.java | 4 +-
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 64 +++++---
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 36 +++--
.../sdk/schemas/utils/StaticSchemaInference.java | 9 ++
.../main/java/org/apache/beam/sdk/values/Row.java | 25 ++-
.../apache/beam/sdk/schemas/AvroSchemaTest.java | 51 +++++-
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 48 ++++++
.../org/apache/beam/sdk/schemas/SchemaTest.java | 4 +-
.../sdk/schemas/logicaltypes/LogicalTypesTest.java | 74 +++++++++
.../beam/sdk/schemas/utils/SchemaTestUtils.java | 2 +-
.../apache/beam/sdk/schemas/utils/TestPOJOs.java | 41 +++++
.../java/org/apache/beam/sdk/util/RowJsonTest.java | 6 +-
.../extensions/sql/impl/utils/CalciteUtils.java | 12 +-
.../sdk/extensions/sql/BeamComplexTypeTest.java | 20 +++
.../beam/sdk/io/clickhouse/ClickHouseIO.java | 4 +-
.../apache/beam/sdk/io/clickhouse/TableSchema.java | 4 +-
.../beam/sdk/io/clickhouse/ClickHouseIOTest.java | 4 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 14 +-
.../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 6 +
.../java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java | 6 +-
.../org/apache/beam/sdk/io/jdbc/LogicalTypes.java | 66 +++++---
34 files changed, 952 insertions(+), 226 deletions(-)
delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/LogicalTypes.java
rename {runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction => sdks/java/core/src/main/java/org/apache/beam/sdk/schemas}/SchemaTranslation.java (99%)
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/FixedBytes.java
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/PassThroughLogicalType.java
copy sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/{parser => logicaltypes}/package-info.java (90%)
create mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/logicaltypes/LogicalTypesTest.java