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 2018/07/09 18:21:10 UTC
[beam] 01/01: Merge pull request #5873: [BEAM-4453] Add schema
support for Java POJOs and Java Beans
This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 784f17ed66205976be6702a344add057705eb0a6
Merge: 997ee3a 77f66df
Author: reuvenlax <re...@google.com>
AuthorDate: Mon Jul 9 11:21:00 2018 -0700
Merge pull request #5873: [BEAM-4453] Add schema support for Java POJOs and Java Beans
.../java/org/apache/beam/sdk/coders/RowCoder.java | 4 +
.../org/apache/beam/sdk/schemas/DefaultSchema.java | 7 +-
.../sdk/schemas/GetterBasedSchemaProvider.java | 146 ++++++
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 53 ++
.../apache/beam/sdk/schemas/JavaFieldSchema.java | 53 ++
.../java/org/apache/beam/sdk/schemas/Schema.java | 19 +-
.../apache/beam/sdk/schemas/SchemaProvider.java | 9 +-
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 563 +++++++++++++++++++++
.../beam/sdk/schemas/utils/JavaBeanUtils.java | 326 ++++++++++++
.../apache/beam/sdk/schemas/utils/POJOUtils.java | 299 +++++++++++
.../beam/sdk/schemas/utils/ReflectUtils.java | 135 +++++
.../sdk/schemas/utils/StaticSchemaInference.java | 219 ++++++++
.../utils/package-info.java} | 23 +-
.../main/java/org/apache/beam/sdk/values/Row.java | 131 +++--
.../org/apache/beam/sdk/values/RowWithGetters.java | 122 +++++
.../org/apache/beam/sdk/values/RowWithStorage.java | 54 ++
.../beam/sdk/values/reflect/ByteBuddyUtils.java | 6 +-
.../beam/sdk/values/reflect/FieldValueGetter.java | 7 +-
...lueGetter.java => FieldValueGetterFactory.java} | 26 +-
...FieldValueGetter.java => FieldValueSetter.java} | 27 +-
...lueGetter.java => FieldValueSetterFactory.java} | 26 +-
.../sdk/values/reflect/GeneratedGetterFactory.java | 2 +-
...ValueGetter.java => JavaBeanGetterFactory.java} | 25 +-
...ValueGetter.java => JavaBeanSetterFactory.java} | 25 +-
...alueGetter.java => PojoValueGetterFactory.java} | 25 +-
...alueGetter.java => PojoValueSetterFactory.java} | 25 +-
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 338 +++++++++++++
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 344 +++++++++++++
.../beam/sdk/schemas/SchemaRegistryTest.java | 8 +-
.../beam/sdk/schemas/utils/JavaBeanUtilsTest.java | 220 ++++++++
.../beam/sdk/schemas/utils/POJOUtilsTest.java | 214 ++++++++
.../beam/sdk/schemas/utils/SchemaTestUtils.java | 78 +++
.../beam/sdk/schemas/utils/TestJavaBeans.java | 491 ++++++++++++++++++
.../apache/beam/sdk/schemas/utils/TestPOJOs.java | 268 ++++++++++
.../beam/sdk/transforms/ParDoSchemaTest.java | 38 ++
.../values/reflect/DefaultSchemaFactoryTest.java | 4 +-
.../extensions/sql/impl/utils/CalciteUtils.java | 1 +
.../sdk/extensions/sql/SqlSchemaFactoryTest.java | 7 +-
.../operator/BeamSqlInputRefExpressionTest.java | 2 +-
39 files changed, 4185 insertions(+), 185 deletions(-)