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