This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from e8ca1e1 Merge pull request #5459: Use WindowOnlyContext in
ReduceFnContextFactory
add 5b64f73 Autoformat sdks/java/extensions/sql
add ca4dc98 Add spotless config to global gradle file
add b99d3e9 Activate spotless for SQL module
add d110f6b Merge pull request #5458: Establish and enforce exact Java
format in sdks/java/extensions/sql
No new revisions were added by this update.
Summary of changes:
build_rules.gradle | 14 +-
sdks/java/extensions/sql/build.gradle | 2 +-
.../apache/beam/sdk/extensions/sql/BeamSql.java | 84 ++--
.../apache/beam/sdk/extensions/sql/BeamSqlCli.java | 22 +-
.../sdk/extensions/sql/BeamSqlSeekableTable.java | 22 +-
.../beam/sdk/extensions/sql/BeamSqlTable.java | 26 +-
.../apache/beam/sdk/extensions/sql/BeamSqlUdf.java | 12 +-
.../beam/sdk/extensions/sql/QueryTransform.java | 58 ++-
.../beam/sdk/extensions/sql/RowSqlTypes.java | 64 ++-
.../beam/sdk/extensions/sql/SchemaHelper.java | 33 +-
.../sdk/extensions/sql/example/BeamSqlExample.java | 33 +-
.../extensions/sql/example/BeamSqlPojoExample.java | 72 ++--
.../sdk/extensions/sql/example/model/Customer.java | 4 +-
.../sdk/extensions/sql/example/model/Order.java | 4 +-
.../extensions/sql/example/model/package-info.java | 4 +-
.../sdk/extensions/sql/example/package-info.java | 4 +-
.../sdk/extensions/sql/impl/BeamCalciteSchema.java | 4 +-
.../sql/impl/BeamCalciteSchemaFactory.java | 10 +-
.../sdk/extensions/sql/impl/BeamCalciteTable.java | 4 +-
.../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 12 +-
.../beam/sdk/extensions/sql/impl/JdbcDriver.java | 25 +-
.../interpreter/BeamSqlExpressionExecutor.java | 14 +-
.../sql/impl/interpreter/BeamSqlFnExecutor.java | 76 ++--
.../operator/BeamSqlCaseExpression.java | 18 +-
.../operator/BeamSqlCastExpression.java | 100 ++---
.../operator/BeamSqlDefaultExpression.java | 5 +-
.../interpreter/operator/BeamSqlDotExpression.java | 7 +-
.../interpreter/operator/BeamSqlExpression.java | 15 +-
.../operator/BeamSqlInputRefExpression.java | 4 +-
.../interpreter/operator/BeamSqlPrimitive.java | 102 +++--
.../interpreter/operator/BeamSqlUdfExpression.java | 17 +-
.../operator/BeamSqlWindowEndExpression.java | 5 +-
.../operator/BeamSqlWindowExpression.java | 8 +-
.../operator/BeamSqlWindowStartExpression.java | 9 +-
.../sql/impl/interpreter/operator/UdafImpl.java | 12 +-
.../arithmetic/BeamSqlArithmeticExpression.java | 17 +-
.../arithmetic/BeamSqlDivideExpression.java | 7 +-
.../arithmetic/BeamSqlMinusExpression.java | 7 +-
.../operator/arithmetic/BeamSqlModExpression.java | 7 +-
.../arithmetic/BeamSqlMultiplyExpression.java | 7 +-
.../operator/arithmetic/BeamSqlPlusExpression.java | 7 +-
.../operator/arithmetic/package-info.java | 4 +-
.../operator/array/BeamSqlArrayExpression.java | 11 +-
.../operator/array/BeamSqlArrayItemExpression.java | 8 +-
.../interpreter/operator/array/package-info.java | 4 +-
.../collection/BeamSqlCardinalityExpression.java | 8 +-
.../collection/BeamSqlSingleElementExpression.java | 12 +-
.../operator/collection/package-info.java | 4 +-
.../comparison/BeamSqlCompareExpression.java | 62 ++-
.../comparison/BeamSqlEqualsExpression.java | 10 +-
.../comparison/BeamSqlGreaterThanExpression.java | 10 +-
.../BeamSqlGreaterThanOrEqualsExpression.java | 10 +-
.../comparison/BeamSqlIsNotNullExpression.java | 8 +-
.../comparison/BeamSqlIsNullExpression.java | 8 +-
.../comparison/BeamSqlLessThanExpression.java | 10 +-
.../BeamSqlLessThanOrEqualsExpression.java | 10 +-
.../comparison/BeamSqlNotEqualsExpression.java | 10 +-
.../operator/comparison/package-info.java | 4 +-
.../date/BeamSqlCurrentDateExpression.java | 6 +-
.../date/BeamSqlCurrentTimeExpression.java | 6 +-
.../date/BeamSqlCurrentTimestampExpression.java | 6 +-
.../operator/date/BeamSqlDateCeilExpression.java | 9 +-
.../operator/date/BeamSqlDateFloorExpression.java | 9 +-
.../date/BeamSqlDatetimeMinusExpression.java | 15 +-
.../date/BeamSqlDatetimePlusExpression.java | 49 ++-
.../operator/date/BeamSqlExtractExpression.java | 42 +-
.../date/BeamSqlIntervalMultiplyExpression.java | 35 +-
.../BeamSqlTimestampMinusIntervalExpression.java | 6 +-
.../BeamSqlTimestampMinusTimestampExpression.java | 21 +-
.../interpreter/operator/date/TimeUnitUtils.java | 8 +-
.../interpreter/operator/date/package-info.java | 4 +-
.../operator/logical/BeamSqlAndExpression.java | 5 +-
.../operator/logical/BeamSqlLogicalExpression.java | 4 +-
.../operator/logical/BeamSqlNotExpression.java | 3 +-
.../operator/logical/BeamSqlOrExpression.java | 13 +-
.../interpreter/operator/logical/package-info.java | 4 +-
.../operator/map/BeamSqlMapExpression.java | 14 +-
.../operator/map/BeamSqlMapItemExpression.java | 8 +-
.../interpreter/operator/map/package-info.java | 4 +-
.../operator/math/BeamSqlAbsExpression.java | 29 +-
.../operator/math/BeamSqlAcosExpression.java | 11 +-
.../operator/math/BeamSqlAsinExpression.java | 11 +-
.../operator/math/BeamSqlAtan2Expression.java | 16 +-
.../operator/math/BeamSqlAtanExpression.java | 11 +-
.../operator/math/BeamSqlCeilExpression.java | 11 +-
.../operator/math/BeamSqlCosExpression.java | 11 +-
.../operator/math/BeamSqlCotExpression.java | 11 +-
.../operator/math/BeamSqlDegreesExpression.java | 11 +-
.../operator/math/BeamSqlExpExpression.java | 11 +-
.../operator/math/BeamSqlFloorExpression.java | 11 +-
.../operator/math/BeamSqlLnExpression.java | 11 +-
.../operator/math/BeamSqlLogExpression.java | 11 +-
.../operator/math/BeamSqlMathBinaryExpression.java | 20 +-
.../operator/math/BeamSqlMathUnaryExpression.java | 16 +-
.../operator/math/BeamSqlPiExpression.java | 10 +-
.../operator/math/BeamSqlPowerExpression.java | 16 +-
.../operator/math/BeamSqlRadiansExpression.java | 11 +-
.../operator/math/BeamSqlRandExpression.java | 4 +-
.../math/BeamSqlRandIntegerExpression.java | 9 +-
.../operator/math/BeamSqlRoundExpression.java | 49 ++-
.../operator/math/BeamSqlSignExpression.java | 43 +-
.../operator/math/BeamSqlSinExpression.java | 11 +-
.../operator/math/BeamSqlTanExpression.java | 11 +-
.../operator/math/BeamSqlTruncateExpression.java | 54 ++-
.../interpreter/operator/math/package-info.java | 4 +-
.../impl/interpreter/operator/package-info.java | 4 +-
.../reinterpret/BeamSqlReinterpretExpression.java | 29 +-
.../DatetimeReinterpretConversions.java | 4 +-
.../reinterpret/IntegerReinterpretConversions.java | 4 +-
.../reinterpret/ReinterpretConversion.java | 25 +-
.../operator/reinterpret/Reinterpreter.java | 12 +-
.../operator/reinterpret/package-info.java | 4 +-
.../operator/row/BeamSqlFieldAccessExpression.java | 12 +-
.../interpreter/operator/row/package-info.java | 5 +-
.../string/BeamSqlCharLengthExpression.java | 7 +-
.../operator/string/BeamSqlConcatExpression.java | 16 +-
.../operator/string/BeamSqlInitCapExpression.java | 7 +-
.../operator/string/BeamSqlLowerExpression.java | 7 +-
.../operator/string/BeamSqlOverlayExpression.java | 17 +-
.../operator/string/BeamSqlPositionExpression.java | 20 +-
.../string/BeamSqlStringUnaryExpression.java | 7 +-
.../string/BeamSqlSubstringExpression.java | 19 +-
.../operator/string/BeamSqlTrimExpression.java | 24 +-
.../operator/string/BeamSqlUpperExpression.java | 7 +-
.../interpreter/operator/string/package-info.java | 4 +-
.../sql/impl/interpreter/package-info.java | 4 +-
.../beam/sdk/extensions/sql/impl/package-info.java | 4 +-
.../sql/impl/parser/SqlCheckConstraint.java | 15 +-
.../sql/impl/parser/SqlColumnDeclaration.java | 17 +-
.../extensions/sql/impl/parser/SqlCreateTable.java | 39 +-
.../extensions/sql/impl/parser/SqlDdlNodes.java | 18 +-
.../extensions/sql/impl/parser/SqlDropObject.java | 43 +-
.../extensions/sql/impl/parser/SqlDropTable.java | 4 +-
.../extensions/sql/impl/parser/package-info.java | 4 +-
.../sql/impl/planner/BeamQueryPlanner.java | 53 ++-
.../sql/impl/planner/BeamRelDataTypeSystem.java | 9 +-
.../extensions/sql/impl/planner/package-info.java | 3 +-
.../sql/impl/rel/BeamAggregationRel.java | 201 +++++----
.../sql/impl/rel/BeamEnumerableConverter.java | 35 +-
.../sdk/extensions/sql/impl/rel/BeamFilterRel.java | 9 +-
.../sdk/extensions/sql/impl/rel/BeamIOSinkRel.java | 21 +-
.../extensions/sql/impl/rel/BeamIOSourceRel.java | 11 +-
.../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 38 +-
.../sql/impl/rel/BeamLogicalConvention.java | 7 +-
.../sdk/extensions/sql/impl/rel/BeamMinusRel.java | 10 +-
.../extensions/sql/impl/rel/BeamProjectRel.java | 22 +-
.../sql/impl/rel/BeamSetOperatorRelBase.java | 28 +-
.../sdk/extensions/sql/impl/rel/BeamSortRel.java | 40 +-
.../extensions/sql/impl/rel/BeamSqlRelUtils.java | 27 +-
.../sdk/extensions/sql/impl/rel/BeamUnionRel.java | 39 +-
.../sdk/extensions/sql/impl/rel/BeamValuesRel.java | 14 +-
.../sdk/extensions/sql/impl/rel/package-info.java | 5 +-
.../sql/impl/rule/AggregateWindowFactory.java | 52 ++-
.../sql/impl/rule/AggregateWindowField.java | 3 +
.../sql/impl/rule/BeamAggregationRule.java | 35 +-
.../sql/impl/rule/BeamEnumerableConverterRule.java | 12 +-
.../extensions/sql/impl/rule/BeamFilterRule.java | 8 +-
.../extensions/sql/impl/rule/BeamIOSinkRule.java | 7 +-
.../sql/impl/rule/BeamIntersectRule.java | 18 +-
.../extensions/sql/impl/rule/BeamMinusRule.java | 14 +-
.../sdk/extensions/sql/impl/rule/BeamSortRule.java | 14 +-
.../extensions/sql/impl/rule/BeamUnionRule.java | 14 +-
.../extensions/sql/impl/rule/BeamValuesRule.java | 14 +-
.../sdk/extensions/sql/impl/rule/package-info.java | 4 +-
.../extensions/sql/impl/schema/BaseBeamTable.java | 8 +-
.../sdk/extensions/sql/impl/schema/BeamIOType.java | 8 +-
.../sql/impl/schema/BeamPCollectionTable.java | 9 +-
.../extensions/sql/impl/schema/BeamTableUtils.java | 25 +-
.../extensions/sql/impl/schema/package-info.java | 5 +-
.../impl/transform/BeamAggregationTransforms.java | 157 ++++----
.../impl/transform/BeamBuiltinAggregations.java | 29 +-
.../sql/impl/transform/BeamJoinTransforms.java | 157 +++-----
.../impl/transform/BeamSetOperatorsTransforms.java | 31 +-
.../sql/impl/transform/BeamSqlFilterFn.java | 6 +-
.../impl/transform/BeamSqlOutputToConsoleFn.java | 6 +-
.../sql/impl/transform/BeamSqlProjectFn.java | 17 +-
.../impl/transform/agg/CovarianceAccumulator.java | 188 ++++-----
.../sql/impl/transform/agg/CovarianceFn.java | 114 +++---
.../impl/transform/agg/VarianceAccumulator.java | 26 +-
.../sql/impl/transform/agg/VarianceFn.java | 56 ++-
.../sql/impl/transform/agg/package-info.java | 4 +-
.../sql/impl/transform/package-info.java | 4 +-
.../sql/impl/utils/BigDecimalConverter.java | 27 +-
.../extensions/sql/impl/utils/CalciteUtils.java | 88 ++--
.../extensions/sql/impl/utils/SqlTypeUtils.java | 12 +-
.../extensions/sql/impl/utils/package-info.java | 4 +-
.../apache/beam/sdk/extensions/sql/meta/Table.java | 19 +-
.../beam/sdk/extensions/sql/meta/package-info.java | 4 +-
.../sql/meta/provider/BeamSqlTableProvider.java | 18 +-
.../meta/provider/InMemoryMetaTableProvider.java | 4 +-
.../sql/meta/provider/TableProvider.java | 16 +-
.../meta/provider/bigquery/BeamBigQueryTable.java | 14 +-
.../provider/bigquery/BigQueryTableProvider.java | 7 +-
.../sql/meta/provider/bigquery/package-info.java | 4 +-
.../sql/meta/provider/kafka/BeamKafkaCSVTable.java | 65 ++-
.../sql/meta/provider/kafka/BeamKafkaTable.java | 62 +--
.../meta/provider/kafka/KafkaTableProvider.java | 6 +-
.../sql/meta/provider/kafka/package-info.java | 4 +-
.../extensions/sql/meta/provider/package-info.java | 4 +-
.../meta/provider/pubsub/PubsubIOJsonTable.java | 68 ++--
.../provider/pubsub/PubsubJsonTableProvider.java | 28 +-
.../meta/provider/pubsub/PubsubMessageToRow.java | 46 +--
.../sql/meta/provider/pubsub/package-info.java | 4 +-
.../sql/meta/provider/text/BeamTextCSVTable.java | 19 +-
.../provider/text/BeamTextCSVTableIOReader.java | 26 +-
.../provider/text/BeamTextCSVTableIOWriter.java | 27 +-
.../sql/meta/provider/text/BeamTextTable.java | 4 +-
.../sql/meta/provider/text/TextTableProvider.java | 7 +-
.../sql/meta/provider/text/package-info.java | 4 +-
.../sql/meta/store/InMemoryMetaStore.java | 31 +-
.../sdk/extensions/sql/meta/store/MetaStore.java | 5 +-
.../extensions/sql/meta/store/package-info.java | 4 +-
.../beam/sdk/extensions/sql/package-info.java | 4 +-
.../beam/sdk/extensions/sql/BeamSqlArrayTest.java | 360 ++++++-----------
.../sdk/extensions/sql/BeamSqlCliPubsubTest.java | 26 +-
.../beam/sdk/extensions/sql/BeamSqlCliTest.java | 184 ++++-----
.../sql/BeamSqlDslAggregationCovarianceTest.java | 145 +++----
.../extensions/sql/BeamSqlDslAggregationTest.java | 409 +++++++++----------
.../sql/BeamSqlDslAggregationVarianceTest.java | 40 +-
.../beam/sdk/extensions/sql/BeamSqlDslBase.java | 96 +++--
.../sdk/extensions/sql/BeamSqlDslFilterTest.java | 36 +-
.../sdk/extensions/sql/BeamSqlDslJoinTest.java | 181 ++++-----
.../extensions/sql/BeamSqlDslNestedRowsTest.java | 215 ++++------
.../sdk/extensions/sql/BeamSqlDslProjectTest.java | 93 ++---
.../sdk/extensions/sql/BeamSqlDslUdfUdafTest.java | 120 ++----
.../beam/sdk/extensions/sql/BeamSqlMapTest.java | 158 +++++---
.../sdk/extensions/sql/BeamSqlNonAsciiTest.java | 28 +-
.../extensions/sql/InferredRowCoderSqlTest.java | 160 +++-----
.../beam/sdk/extensions/sql/JsonToRowSqlTest.java | 49 +--
.../sdk/extensions/sql/SqlSchemaFactoryTest.java | 34 +-
.../apache/beam/sdk/extensions/sql/TestUtils.java | 111 +++--
.../sdk/extensions/sql/impl/JdbcDriverTest.java | 26 +-
.../impl/interpreter/BeamSqlFnExecutorTest.java | 323 +++++++--------
.../operator/BeamNullExperssionTest.java | 22 +-
.../operator/BeamSqlAndOrExpressionTest.java | 6 +-
.../operator/BeamSqlCaseExpressionTest.java | 20 +-
.../operator/BeamSqlCastExpressionTest.java | 67 ++-
.../operator/BeamSqlCompareExpressionTest.java | 100 +++--
.../operator/BeamSqlDotExpressionTest.java | 28 +-
.../operator/BeamSqlInputRefExpressionTest.java | 5 +-
.../interpreter/operator/BeamSqlPrimitiveTest.java | 10 +-
.../operator/BeamSqlReinterpretExpressionTest.java | 39 +-
.../operator/BeamSqlUdfExpressionTest.java | 13 +-
.../BeamSqlArithmeticExpressionTest.java | 34 +-
.../operator/array/BeamSqlArrayExpressionTest.java | 7 +-
.../array/BeamSqlArrayItemExpressionTest.java | 15 +-
.../BeamSqlCardinalityExpressionTest.java | 14 +-
.../BeamSqlSingleElementExpressionTest.java | 17 +-
.../date/BeamSqlCurrentDateExpressionTest.java | 8 +-
.../date/BeamSqlCurrentTimeExpressionTest.java | 7 +-
.../BeamSqlCurrentTimestampExpressionTest.java | 7 +-
.../date/BeamSqlDateCeilExpressionTest.java | 22 +-
.../date/BeamSqlDateExpressionTestBase.java | 4 +-
.../date/BeamSqlDateFloorExpressionTest.java | 17 +-
.../date/BeamSqlDatetimeMinusExpressionTest.java | 46 ++-
.../date/BeamSqlDatetimePlusExpressionTest.java | 36 +-
.../date/BeamSqlExtractExpressionTest.java | 71 ++--
.../BeamSqlIntervalMultiplyExpressionTest.java | 21 +-
...eamSqlTimestampMinusIntervalExpressionTest.java | 45 ++-
...amSqlTimestampMinusTimestampExpressionTest.java | 117 +++---
.../operator/date/TimeUnitUtilsTest.java | 28 +-
.../operator/logical/BeamSqlNotExpressionTest.java | 7 +-
.../math/BeamSqlMathBinaryExpressionTest.java | 84 ++--
.../math/BeamSqlMathUnaryExpressionTest.java | 208 +++++-----
.../DatetimeReinterpretConversionsTest.java | 34 +-
.../IntegerReinterpretConversionsTest.java | 46 +--
.../reinterpret/ReinterpretConversionTest.java | 67 ++-
.../operator/reinterpret/ReinterpreterTest.java | 71 ++--
.../row/BeamSqlFieldAccessExpressionTest.java | 20 +-
.../string/BeamSqlCharLengthExpressionTest.java | 11 +-
.../string/BeamSqlConcatExpressionTest.java | 15 +-
.../string/BeamSqlInitCapExpressionTest.java | 20 +-
.../string/BeamSqlLowerExpressionTest.java | 11 +-
.../string/BeamSqlOverlayExpressionTest.java | 27 +-
.../string/BeamSqlPositionExpressionTest.java | 11 +-
.../string/BeamSqlStringUnaryExpressionTest.java | 8 +-
.../string/BeamSqlSubstringExpressionTest.java | 32 +-
.../operator/string/BeamSqlTrimExpressionTest.java | 46 +--
.../string/BeamSqlUpperExpressionTest.java | 11 +-
.../sql/impl/parser/BeamDDLNestedTypesTest.java | 25 +-
.../extensions/sql/impl/parser/BeamDDLTest.java | 111 +++--
.../sdk/extensions/sql/impl/rel/BaseRelTest.java | 8 +-
.../sql/impl/rel/BeamEnumerableConverterTest.java | 4 +-
.../sql/impl/rel/BeamIntersectRelTest.java | 97 ++---
.../impl/rel/BeamJoinRelBoundedVsBoundedTest.java | 154 +++----
.../rel/BeamJoinRelUnboundedVsBoundedTest.java | 281 ++++++-------
.../rel/BeamJoinRelUnboundedVsUnboundedTest.java | 221 +++++-----
.../extensions/sql/impl/rel/BeamMinusRelTest.java | 96 ++---
.../sql/impl/rel/BeamSetOperatorRelBaseTest.java | 70 ++--
.../extensions/sql/impl/rel/BeamSortRelTest.java | 329 ++++++++-------
.../extensions/sql/impl/rel/BeamUnionRelTest.java | 86 ++--
.../extensions/sql/impl/rel/BeamValuesRelTest.java | 74 ++--
.../sdk/extensions/sql/impl/rel/CheckSize.java | 8 +-
.../sql/impl/schema/BeamSqlRowCoderTest.java | 36 +-
.../transform/BeamAggregationTransformTest.java | 245 +++++------
.../schema/transform/BeamTransformBaseTest.java | 29 +-
.../transform/agg/VarianceAccumulatorTest.java | 23 +-
.../sql/impl/transform/agg/VarianceFnTest.java | 37 +-
.../sql/impl/utils/BigDecimalConverterTest.java | 4 +-
.../sql/impl/utils/SqlTypeUtilsTest.java | 16 +-
.../BeamSqlArithmeticOperatorsIntegrationTest.java | 186 +++++----
...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 90 ++---
.../BeamSqlComparisonOperatorsIntegrationTest.java | 448 ++++++++++-----------
...BeamSqlConditionalFunctionsIntegrationTest.java | 51 +--
.../BeamSqlDateFunctionsIntegrationTest.java | 308 ++++++++------
.../BeamSqlLogicalFunctionsIntegrationTest.java | 25 +-
.../BeamSqlMathFunctionsIntegrationTest.java | 411 ++++++++++---------
.../BeamSqlStringFunctionsIntegrationTest.java | 40 +-
.../bigquery/BigQueryTableProviderTest.java | 10 +-
.../meta/provider/kafka/BeamKafkaCSVTableTest.java | 51 +--
.../provider/kafka/KafkaTableProviderTest.java | 17 +-
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 135 +++----
.../pubsub/PubsubJsonTableProviderTest.java | 79 ++--
.../provider/pubsub/PubsubMessageToRowTest.java | 156 ++++---
.../meta/provider/text/BeamTextCSVTableTest.java | 77 ++--
.../meta/provider/text/TextTableProviderTest.java | 13 +-
.../sql/meta/store/InMemoryMetaStoreTest.java | 49 ++-
.../extensions/sql/mock/MockedBoundedTable.java | 44 +-
.../beam/sdk/extensions/sql/mock/MockedTable.java | 5 +-
.../extensions/sql/mock/MockedUnboundedTable.java | 26 +-
.../extensions/sql/utils/QuickCheckGenerators.java | 89 ++--
.../beam/sdk/extensions/sql/utils/RowAsserts.java | 12 +-
322 files changed, 6012 insertions(+), 7092 deletions(-)
--
To stop receiving notification emails like this one, please contact
[email protected].
