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 k...@apache.org.