beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From taki...@apache.org
Subject [3/3] beam git commit: [BEAM-2745] This closes #3700
Date Wed, 09 Aug 2017 16:41:01 GMT
[BEAM-2745] This closes #3700


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f59dccc5
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f59dccc5
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f59dccc5

Branch: refs/heads/DSL_SQL
Commit: f59dccc51abc8326bea3918766c62add93306fda
Parents: 6628674 7c76129
Author: Tyler Akidau <takidau@apache.org>
Authored: Wed Aug 9 09:38:45 2017 -0700
Committer: Tyler Akidau <takidau@apache.org>
Committed: Wed Aug 9 09:38:45 2017 -0700

----------------------------------------------------------------------
 .../org/apache/beam/sdk/values/BeamRecord.java  |  21 ++-
 .../apache/beam/sdk/values/BeamRecordType.java  |  25 +--
 .../apache/beam/sdk/extensions/sql/BeamSql.java |   4 +-
 .../beam/sdk/extensions/sql/BeamSqlEnv.java     |   6 +-
 .../extensions/sql/example/BeamSqlExample.java  |   4 +-
 .../sql/impl/rel/BeamAggregationRel.java        |  16 +-
 .../extensions/sql/impl/rel/BeamJoinRel.java    |  10 +-
 .../extensions/sql/impl/rel/BeamValuesRel.java  |   6 +-
 .../transform/BeamAggregationTransforms.java    |  25 +--
 .../sql/impl/transform/BeamJoinTransforms.java  |  22 +--
 .../sql/impl/transform/BeamSqlProjectFn.java    |   8 +-
 .../extensions/sql/impl/utils/CalciteUtils.java |  16 +-
 .../extensions/sql/schema/BaseBeamTable.java    |   6 +-
 .../sql/schema/BeamPCollectionTable.java        |   4 +-
 .../sql/schema/BeamRecordSqlType.java           | 185 +++++++++++++++++++
 .../sql/schema/BeamSqlRecordHelper.java         |   4 +-
 .../sql/schema/BeamSqlRecordType.java           | 175 ------------------
 .../sdk/extensions/sql/schema/BeamSqlTable.java |   2 +-
 .../extensions/sql/schema/BeamTableUtils.java   |  14 +-
 .../sql/schema/kafka/BeamKafkaCSVTable.java     |  14 +-
 .../sql/schema/kafka/BeamKafkaTable.java        |   6 +-
 .../sql/schema/text/BeamTextCSVTable.java       |   6 +-
 .../schema/text/BeamTextCSVTableIOReader.java   |   6 +-
 .../schema/text/BeamTextCSVTableIOWriter.java   |   6 +-
 .../sql/schema/text/BeamTextTable.java          |   4 +-
 .../sql/BeamSqlDslAggregationTest.java          |  14 +-
 .../beam/sdk/extensions/sql/BeamSqlDslBase.java |   6 +-
 .../sdk/extensions/sql/BeamSqlDslJoinTest.java  |  10 +-
 .../extensions/sql/BeamSqlDslProjectTest.java   |  10 +-
 .../extensions/sql/BeamSqlDslUdfUdafTest.java   |   6 +-
 .../beam/sdk/extensions/sql/TestUtils.java      |  14 +-
 .../interpreter/BeamSqlFnExecutorTestBase.java  |   4 +-
 ...mSqlBuiltinFunctionsIntegrationTestBase.java |   6 +-
 ...amSqlComparisonOperatorsIntegrationTest.java |   4 +-
 .../extensions/sql/mock/MockedBoundedTable.java |   6 +-
 .../sdk/extensions/sql/mock/MockedTable.java    |   4 +-
 .../sql/mock/MockedUnboundedTable.java          |   4 +-
 .../sql/schema/BeamSqlRowCoderTest.java         |   2 +-
 .../sql/schema/kafka/BeamKafkaCSVTableTest.java |   4 +-
 .../sql/schema/text/BeamTextCSVTableTest.java   |   4 +-
 .../transform/BeamAggregationTransformTest.java |  10 +-
 .../schema/transform/BeamTransformBaseTest.java |   8 +-
 42 files changed, 368 insertions(+), 343 deletions(-)
----------------------------------------------------------------------



Mime
View raw message