This is an automated email from the ASF dual-hosted git repository. iemejia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from db3fb24 Merge pull request #10740 from apache/dataflow-py-container add 3d956fd [BEAM-9236] Mark missing Schema based classes and methods as Experimental add 4afc6e1 [BEAM-9236] Remove unneeded schema related class FieldValueSetterFactory add f6787b0 [BEAM-9236] Remove unused schema related class FieldValueGetterFactory add 2bd3c5c Merge pull request #10741: [BEAM-9236] Mark missing Schema based classes and methods as Experimental No new revisions were added by this update. Summary of changes: .../core/construction/CoderTranslators.java | 3 + .../util/SchemaCoderCloudObjectTranslator.java | 3 + .../main/java/org/apache/beam/sdk/Pipeline.java | 3 + .../java/org/apache/beam/sdk/coders/RowCoder.java | 3 +- .../apache/beam/sdk/coders/RowCoderGenerator.java | 3 + .../main/java/org/apache/beam/sdk/io/AvroIO.java | 1 + .../beam/sdk/schemas/FieldTypeDescriptors.java | 3 + .../beam/sdk/schemas/FieldValueGetterFactory.java | 34 ----------- .../beam/sdk/schemas/FieldValueSetterFactory.java | 34 ----------- .../beam/sdk/schemas/FromRowUsingCreator.java | 3 + .../apache/beam/sdk/schemas/JavaBeanSchema.java | 3 +- .../apache/beam/sdk/schemas/SchemaTranslation.java | 3 + .../sdk/schemas/logicaltypes/EnumerationType.java | 3 + .../beam/sdk/schemas/logicaltypes/FixedBytes.java | 3 + .../beam/sdk/schemas/logicaltypes/OneOfType.java | 3 + .../logicaltypes/PassThroughLogicalType.java | 3 + .../beam/sdk/schemas/transforms/AddFields.java | 7 ++- .../apache/beam/sdk/schemas/transforms/Cast.java | 3 +- .../beam/sdk/schemas/transforms/CoGroup.java | 3 +- .../apache/beam/sdk/schemas/transforms/Join.java | 3 +- .../beam/sdk/schemas/utils/AutoValueUtils.java | 3 + .../beam/sdk/schemas/utils/AvroByteBuddyUtils.java | 3 + .../apache/beam/sdk/schemas/utils/AvroUtils.java | 3 +- .../beam/sdk/schemas/utils/ConvertHelpers.java | 3 + .../sdk/schemas/utils/FieldValueTypeSupplier.java | 3 + .../beam/sdk/schemas/utils/ReflectUtils.java | 3 + .../beam/sdk/schemas/utils/SchemaZipFold.java | 3 + .../beam/sdk/schemas/utils/SelectHelpers.java | 3 + .../sdk/schemas/utils/StaticSchemaInference.java | 3 + .../org/apache/beam/sdk/testing/TestStream.java | 4 ++ .../org/apache/beam/sdk/transforms/Create.java | 1 + .../beam/sdk/transforms/DoFnSchemaInformation.java | 3 + .../org/apache/beam/sdk/transforms/JsonToRow.java | 3 +- .../java/org/apache/beam/sdk/util/RowJson.java | 3 + .../apache/beam/sdk/util/RowJsonValidation.java | 3 + .../main/java/org/apache/beam/sdk/values/Row.java | 3 +- .../org/apache/beam/sdk/values/RowWithGetters.java | 3 + .../org/apache/beam/sdk/values/RowWithStorage.java | 3 + .../extensions/protobuf/ProtoByteBuddyUtils.java | 6 ++ .../protobuf/ProtoSchemaLogicalTypes.java | 3 + .../sql/meta/provider/datacatalog/SchemaUtils.java | 3 + .../provider/hcatalog/HCatalogTableProvider.java | 2 +- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 5 +- .../io/gcp/bigquery/BigQueryQuerySourceDef.java | 3 + .../io/gcp/bigquery/BigQueryTableSourceDef.java | 3 + .../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 9 +++ .../beam/sdk/io/gcp/bigquery/TestBigQuery.java | 7 +++ .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 2 + .../org/apache/beam/sdk/io/hcatalog/HCatToRow.java | 5 +- .../beam/sdk/io/hcatalog/HCatalogBeamSchema.java | 3 +- .../apache/beam/sdk/io/hcatalog/SchemaUtils.java | 3 + .../sdk/io/jdbc/BeamSchemaInferenceException.java | 4 +- .../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 2 +- .../java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java | 71 ++++++++++------------ .../org/apache/beam/sdk/io/jdbc/LogicalTypes.java | 37 +++++------ .../org/apache/beam/sdk/io/jdbc/SchemaUtil.java | 11 ++-- 56 files changed, 209 insertions(+), 147 deletions(-) delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueGetterFactory.java delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueSetterFactory.java