You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2020/02/02 13:52:34 UTC
[beam] branch master updated (db3fb24 -> 2bd3c5c)
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