[beam] branch master updated (90853454eb5 -> 2d577539f19)

[he...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

heejong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 90853454eb5 Merge pull request #17653 Revert "Better test assertion."
     new 5a5e51ea5fc [BEAM-14430] Adding a logical type support for Python callables to Row schema
     new 6797787df5b add urn, type inference for PythonCallableSource
     new e2b29662812 fix lint errors
     new 792baa26459 move logical types def
     new 514e325845c add micros_instant urn
     new 2fce769df1f put a default type hint for PythonCallableSource
     new 2d36feb2b6a add comment
     new 2d577539f19 Merge pull request #17608 from ihji/BEAM-14430

The 35944 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../beam/model/pipeline/v1/beam_runner_api.proto   |  8 +---
 .../org/apache/beam/model/pipeline/v1/schema.proto | 23 ++++++++++
 .../apache/beam/sdk/schemas/SchemaTranslation.java |  2 +
 .../sdk/schemas/logicaltypes/MicrosInstant.java    |  8 +++-
 ...{SchemaLogicalType.java => PythonCallable.java} | 36 +++++++--------
 .../sdk/schemas/utils/StaticSchemaInference.java   |  1 +
 ...{ShardedFile.java => PythonCallableSource.java} | 30 ++++++-------
 .../beam/sdk/schemas/SchemaTranslationTest.java    |  2 +
 .../extensions/python/PythonExternalTransform.java | 37 +++++++++++++++-
 ...mTest.java => PythonExternalTransformTest.java} | 51 +++++++++++++++++++++-
 sdks/python/apache_beam/portability/common_urns.py |  5 +++
 sdks/python/apache_beam/typehints/schemas.py       | 28 +++++++++++-
 sdks/python/apache_beam/typehints/schemas_test.py  | 17 ++++++++
 .../observable.py => utils/python_callable.py}     | 31 +++++++------
 14 files changed, 220 insertions(+), 59 deletions(-)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/{SchemaLogicalType.java => PythonCallable.java} (56%)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/util/{ShardedFile.java => PythonCallableSource.java} (58%)
 rename sdks/java/extensions/python/src/test/java/org/apache/beam/sdk/extensions/python/{ExternalPythonTransformTest.java => PythonExternalTransformTest.java} (83%)
 copy sdks/python/apache_beam/{coders/observable.py => utils/python_callable.py} (57%)