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/11/19 04:15:15 UTC
[beam] branch master updated (1bc180c -> b3c12d2)
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 1bc180c Merge pull request #10129: Make sdk_worker_parallelism an integer
add b3c12d2 Merge pull request #10003: [BEAM-6756] Create Iterable type for Schema
No new revisions were added by this update.
Summary of changes:
model/pipeline/src/main/proto/schema.proto | 11 +-
.../core/construction/SchemaTranslation.java | 9 ++
.../core/construction/SchemaTranslationTest.java | 5 +
.../apache/beam/sdk/coders/RowCoderGenerator.java | 17 ++-
.../beam/sdk/schemas/FieldAccessDescriptor.java | 4 +-
.../beam/sdk/schemas/FieldTypeDescriptors.java | 16 +++
.../sdk/schemas/FieldValueTypeInformation.java | 20 +--
.../beam/sdk/schemas/FromRowUsingCreator.java | 42 +++++-
.../java/org/apache/beam/sdk/schemas/Schema.java | 18 ++-
.../org/apache/beam/sdk/schemas/SchemaCoder.java | 4 +
.../beam/sdk/schemas/transforms/AddFields.java | 13 +-
.../apache/beam/sdk/schemas/transforms/Cast.java | 6 +-
.../beam/sdk/schemas/transforms/RenameFields.java | 2 +
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 9 +-
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 25 +++-
.../beam/sdk/schemas/utils/SchemaZipFold.java | 1 +
.../beam/sdk/schemas/utils/SelectHelpers.java | 22 ++-
.../sdk/schemas/utils/StaticSchemaInference.java | 27 ++--
.../java/org/apache/beam/sdk/util/RowJson.java | 7 +-
.../main/java/org/apache/beam/sdk/values/Row.java | 89 ++++++++++--
.../org/apache/beam/sdk/values/RowWithGetters.java | 31 ++++
.../org/apache/beam/sdk/coders/RowCoderTest.java | 56 +++++++-
.../beam/sdk/schemas/FieldTypeDescriptorsTest.java | 28 ++++
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 18 +++
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 19 +++
.../org/apache/beam/sdk/schemas/SchemaTest.java | 28 ++++
.../beam/sdk/schemas/transforms/AddFieldsTest.java | 67 ++++++---
.../beam/sdk/schemas/transforms/GroupTest.java | 1 +
.../beam/sdk/schemas/utils/SelectHelpersTest.java | 159 +++++++++++++++++++++
.../beam/sdk/schemas/utils/TestJavaBeans.java | 59 +++++++-
.../apache/beam/sdk/schemas/utils/TestPOJOs.java | 45 +++++-
.../java/org/apache/beam/sdk/values/RowTest.java | 111 +++++++++++++-
.../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 1 +
.../sql/impl/rel/BeamEnumerableConverter.java | 5 +
.../extensions/sql/impl/utils/CalciteUtils.java | 2 +
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 9 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java | 1 +
.../org/apache/beam/sdk/io/jdbc/SchemaUtil.java | 1 +
38 files changed, 897 insertions(+), 91 deletions(-)