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