This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 78271e064609400a535d81482c9893f3a2bd1d37 Merge: 8130c20 a30030c Author: Kenn Knowles <[email protected]> AuthorDate: Sat Feb 3 13:05:15 2018 -0800 Merge pull request #4488: [BEAM-3292][SQL] Replace java.sql.Types with SqlTypeCoder .../org/apache/beam/sdk/values/BeamRecordType.java | 35 +++- .../beam/sdk/extensions/sql/BeamRecordSqlType.java | 178 +++----------------- .../apache/beam/sdk/extensions/sql/BeamSql.java | 3 +- .../sdk/extensions/sql/BeamSqlRecordHelper.java | 45 ++---- .../beam/sdk/extensions/sql/BeamSqlTable.java | 3 +- .../beam/sdk/extensions/sql/SqlTypeCoder.java | 156 ++++++++++++++++++ .../beam/sdk/extensions/sql/SqlTypeCoders.java | 67 ++++++++ .../sdk/extensions/sql/example/BeamSqlExample.java | 20 ++- .../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 10 +- .../extensions/sql/impl/parser/ParserUtils.java | 4 +- .../sql/impl/rel/BeamAggregationRel.java | 21 +-- .../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 12 +- .../sdk/extensions/sql/impl/rel/BeamSortRel.java | 4 +- .../sdk/extensions/sql/impl/rel/BeamValuesRel.java | 12 +- .../extensions/sql/impl/schema/BaseBeamTable.java | 12 +- .../sql/impl/schema/BeamPCollectionTable.java | 10 +- .../extensions/sql/impl/schema/BeamTableUtils.java | 27 ++-- .../impl/transform/BeamAggregationTransforms.java | 45 +++--- .../sql/impl/transform/BeamJoinTransforms.java | 42 +++-- .../sql/impl/transform/BeamSqlProjectFn.java | 8 +- .../impl/transform/agg/BigDecimalConverter.java | 31 ++-- .../extensions/sql/impl/utils/CalciteUtils.java | 85 +++++----- .../beam/sdk/extensions/sql/meta/Column.java | 5 +- .../extensions/sql/meta/provider/MetaUtils.java | 18 +-- .../sql/meta/provider/kafka/BeamKafkaCSVTable.java | 24 +-- .../sql/meta/provider/kafka/BeamKafkaTable.java | 14 +- .../meta/provider/kafka/KafkaTableProvider.java | 6 +- .../sql/meta/provider/text/BeamTextCSVTable.java | 16 +- .../provider/text/BeamTextCSVTableIOReader.java | 12 +- .../provider/text/BeamTextCSVTableIOWriter.java | 17 +- .../sql/meta/provider/text/BeamTextTable.java | 6 +- .../sql/meta/provider/text/TextTableProvider.java | 6 +- .../sdk/extensions/sql/BeamRecordSqlTypeTest.java | 115 ------------- .../extensions/sql/BeamSqlDslAggregationTest.java | 179 ++++++++++++--------- .../sql/BeamSqlDslAggregationVarianceTest.java | 13 +- .../beam/sdk/extensions/sql/BeamSqlDslBase.java | 79 +++++---- .../sdk/extensions/sql/BeamSqlDslJoinTest.java | 62 ++++--- .../sdk/extensions/sql/BeamSqlDslProjectTest.java | 34 ++-- .../sdk/extensions/sql/BeamSqlDslUdfUdafTest.java | 15 +- .../apache/beam/sdk/extensions/sql/TestUtils.java | 43 ++--- .../interpreter/BeamSqlFnExecutorTestBase.java | 4 +- .../sql/impl/parser/BeamSqlParserTest.java | 7 +- .../sql/impl/rel/BeamIntersectRelTest.java | 26 +-- .../impl/rel/BeamJoinRelBoundedVsBoundedTest.java | 62 +++---- .../rel/BeamJoinRelUnboundedVsBoundedTest.java | 57 ++++--- .../rel/BeamJoinRelUnboundedVsUnboundedTest.java | 42 ++--- .../extensions/sql/impl/rel/BeamMinusRelTest.java | 26 +-- .../sql/impl/rel/BeamSetOperatorRelBaseTest.java | 16 +- .../extensions/sql/impl/rel/BeamSortRelTest.java | 78 ++++----- .../extensions/sql/impl/rel/BeamUnionRelTest.java | 20 +-- .../extensions/sql/impl/rel/BeamValuesRelTest.java | 22 +-- .../sql/impl/schema/BeamSqlRowCoderTest.java | 8 +- .../transform/BeamAggregationTransformTest.java | 14 +- .../schema/transform/BeamTransformBaseTest.java | 10 +- .../transform/agg/BigDecimalConverterTest.java | 19 +-- ...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 41 ++--- .../BeamSqlComparisonOperatorsIntegrationTest.java | 56 ++++--- .../meta/provider/kafka/BeamKafkaCSVTableTest.java | 4 +- .../provider/kafka/KafkaTableProviderTest.java | 7 +- .../meta/provider/text/BeamTextCSVTableTest.java | 14 +- .../meta/provider/text/TextTableProviderTest.java | 7 +- .../sql/meta/store/InMemoryMetaStoreTest.java | 12 +- .../extensions/sql/mock/MockedBoundedTable.java | 8 +- .../beam/sdk/extensions/sql/mock/MockedTable.java | 6 +- .../extensions/sql/mock/MockedUnboundedTable.java | 8 +- .../beam/sdk/nexmark/model/sql/BeamRecordSize.java | 39 ++--- .../model/sql/adapter/ModelFieldsAdapter.java | 5 +- .../beam/sdk/nexmark/queries/sql/SqlQuery3.java | 17 +- .../sdk/nexmark/model/sql/BeamRecordSizeTest.java | 3 +- .../sql/adapter/ModelAdaptersMappingTest.java | 22 ++- .../sdk/nexmark/queries/sql/SqlQuery3Test.java | 15 +- 71 files changed, 1100 insertions(+), 1069 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
