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(-)