This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b8d8e07 [hotfix][runtime] Makes use of static variable
new 9fa08be [hotfix][table-api-scala-bridge] Fix imports of
StreamTableEnvironmentImpl
new a924c67 [hotfix][table] Replace TableConfig constructor with
getDefault()
new 2eacc73 [FLINK-26688][table-planner] Remove usages of
TableConfig.nullCheck
new 7fba24a [FLINK-26689][table] Replace `TableConfig` with
`ReadableConfig`
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/connector/hbase1/HBaseTablePlanTest.java | 2 +-
.../flink/connector/hbase2/HBaseTablePlanTest.java | 2 +-
.../connector/jdbc/table/JdbcTablePlanTest.java | 2 +-
...ghPythonStreamGroupWindowAggregateOperator.java | 3 +-
...owPythonGroupAggregateFunctionOperatorTest.java | 7 +-
...onGroupWindowAggregateFunctionOperatorTest.java | 7 +-
...honOverWindowAggregateFunctionOperatorTest.java | 7 +-
...onGroupWindowAggregateFunctionOperatorTest.java | 3 +-
...rrowPythonProcTimeBoundedRangeOperatorTest.java | 3 +-
...ArrowPythonProcTimeBoundedRowsOperatorTest.java | 3 +-
...ArrowPythonRowTimeBoundedRangeOperatorTest.java | 3 +-
...mArrowPythonRowTimeBoundedRowsOperatorTest.java | 3 +-
.../scalar/PythonScalarFunctionOperatorTest.java | 5 +-
.../ArrowPythonScalarFunctionOperatorTest.java | 5 +-
.../table/PythonTableFunctionOperatorTest.java | 3 +-
.../internal/StreamTableEnvironmentImplTest.java | 2 +-
.../table/api/internal/TableEnvironmentImpl.java | 2 +-
.../apache/flink/table/api/TableConfigTest.java | 4 +-
.../resolver/ExpressionResolverTest.java | 2 +-
.../utils/ValuesOperationTreeBuilderTest.java | 2 +-
.../flink/table/utils/ExpressionResolverMocks.java | 4 +-
.../internal/StreamTableEnvironmentImpl.scala | 2 +-
.../internal/StreamTableEnvironmentImplTest.scala | 2 +-
.../abilities/source/WatermarkPushDownSpec.java | 2 +-
.../planner/plan/nodes/exec/ExecNodeConfig.java | 2 -
.../exec/batch/BatchExecBoundedStreamScan.java | 2 +-
.../plan/nodes/exec/batch/BatchExecExchange.java | 5 +-
.../nodes/exec/batch/BatchExecHashAggregate.java | 2 +-
.../plan/nodes/exec/batch/BatchExecHashJoin.java | 11 +-
.../exec/batch/BatchExecHashWindowAggregate.java | 2 +-
.../exec/batch/BatchExecLegacyTableSourceScan.java | 2 +-
.../nodes/exec/batch/BatchExecNestedLoopJoin.java | 2 +-
.../nodes/exec/batch/BatchExecOverAggregate.java | 12 +-
.../exec/batch/BatchExecPythonGroupAggregate.java | 6 +-
.../batch/BatchExecPythonGroupWindowAggregate.java | 6 +-
.../exec/batch/BatchExecPythonOverAggregate.java | 6 +-
.../plan/nodes/exec/batch/BatchExecRank.java | 4 +-
.../plan/nodes/exec/batch/BatchExecSort.java | 3 +-
.../nodes/exec/batch/BatchExecSortAggregate.java | 2 +-
.../plan/nodes/exec/batch/BatchExecSortLimit.java | 3 +-
.../nodes/exec/batch/BatchExecSortMergeJoin.java | 9 +-
.../exec/batch/BatchExecSortWindowAggregate.java | 2 +-
.../plan/nodes/exec/common/CommonExecCalc.java | 3 +-
.../nodes/exec/common/CommonExecCorrelate.java | 5 +-
.../plan/nodes/exec/common/CommonExecExpand.java | 2 +-
.../nodes/exec/common/CommonExecLegacySink.java | 2 +-
.../nodes/exec/common/CommonExecLookupJoin.java | 12 +-
.../nodes/exec/common/CommonExecPythonCalc.java | 6 +-
.../exec/common/CommonExecPythonCorrelate.java | 2 +-
.../plan/nodes/exec/common/CommonExecValues.java | 5 +-
.../exec/stream/StreamExecDataStreamScan.java | 2 +-
.../stream/StreamExecGlobalGroupAggregate.java | 2 +-
.../stream/StreamExecGlobalWindowAggregate.java | 2 +-
.../exec/stream/StreamExecGroupAggregate.java | 2 +-
.../exec/stream/StreamExecGroupTableAggregate.java | 2 +-
.../stream/StreamExecGroupWindowAggregate.java | 2 +-
.../StreamExecIncrementalGroupAggregate.java | 2 +-
.../nodes/exec/stream/StreamExecIntervalJoin.java | 2 +-
.../plan/nodes/exec/stream/StreamExecJoin.java | 3 +-
.../stream/StreamExecLegacyTableSourceScan.java | 2 +-
.../exec/stream/StreamExecLocalGroupAggregate.java | 2 +-
.../stream/StreamExecLocalWindowAggregate.java | 2 +-
.../plan/nodes/exec/stream/StreamExecMatch.java | 20 ++--
.../nodes/exec/stream/StreamExecOverAggregate.java | 2 +-
.../StreamExecPythonGroupWindowAggregate.java | 2 +-
.../exec/stream/StreamExecPythonOverAggregate.java | 2 +-
.../plan/nodes/exec/stream/StreamExecRank.java | 2 +-
.../plan/nodes/exec/stream/StreamExecSort.java | 2 +-
.../nodes/exec/stream/StreamExecTemporalJoin.java | 2 +-
.../nodes/exec/stream/StreamExecTemporalSort.java | 10 +-
.../exec/stream/StreamExecWatermarkAssigner.java | 2 +-
.../exec/stream/StreamExecWindowAggregate.java | 2 +-
.../nodes/exec/stream/StreamExecWindowJoin.java | 3 +-
.../nodes/exec/stream/StreamExecWindowRank.java | 2 +-
.../table/planner/plan/utils/KeySelectorUtil.java | 4 +-
.../table/planner/utils/TableConfigUtils.java | 33 ++++++
.../table/planner/codegen/CalcCodeGenerator.scala | 5 +-
.../flink/table/planner/codegen/CodeGenUtils.scala | 49 +++-----
.../planner/codegen/CodeGeneratorContext.scala | 37 ++----
.../planner/codegen/CollectorCodeGenerator.scala | 4 +-
.../planner/codegen/CorrelateCodeGenerator.scala | 9 +-
.../planner/codegen/EqualiserCodeGenerator.scala | 6 +-
.../table/planner/codegen/ExprCodeGenerator.scala | 52 ++++-----
.../table/planner/codegen/ExpressionReducer.scala | 7 +-
.../planner/codegen/FunctionCodeGenerator.scala | 4 +-
.../table/planner/codegen/GenerateUtils.scala | 42 ++-----
.../table/planner/codegen/HashCodeGenerator.scala | 2 +-
.../planner/codegen/InputFormatCodeGenerator.scala | 2 +-
.../planner/codegen/LongHashJoinGenerator.scala | 9 +-
.../planner/codegen/LookupJoinCodeGenerator.scala | 20 ++--
.../table/planner/codegen/MatchCodeGenerator.scala | 17 +--
.../planner/codegen/OperatorCodeGenerator.scala | 4 +-
.../planner/codegen/ProjectionCodeGenerator.scala | 2 +-
.../planner/codegen/ValuesCodeGenerator.scala | 4 +-
.../codegen/WatermarkGeneratorCodeGenerator.scala | 12 +-
.../codegen/agg/AggsHandlerCodeGenerator.scala | 8 +-
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 5 +-
.../codegen/calls/BridgingSqlFunctionCallGen.scala | 2 +-
.../planner/codegen/calls/FunctionGenerator.scala | 13 ++-
.../planner/codegen/calls/ScalarOperatorGens.scala | 126 +++++----------------
.../planner/codegen/calls/SearchOperatorGen.scala | 21 +---
...ltiFieldRangeBoundComparatorCodeGenerator.scala | 6 +-
.../over/RangeBoundComparatorCodeGenerator.scala | 6 +-
.../codegen/sort/ComparatorCodeGenerator.scala | 6 +-
.../planner/codegen/sort/SortCodeGenerator.scala | 6 +-
.../physical/batch/BatchPhysicalJoinBase.scala | 2 +-
...ushPartitionIntoLegacyTableSourceScanRule.scala | 8 +-
.../flink/table/planner/plan/utils/JoinUtil.scala | 13 ++-
.../table/planner/plan/utils/PartitionPruner.scala | 4 +-
.../planner/catalog/JavaCatalogTableTest.java | 4 +-
.../flink/table/planner/codegen/CodeSplitTest.java | 17 +--
.../planner/codegen/LongHashJoinGeneratorTest.java | 4 +-
.../planner/codegen/SortCodeGeneratorTest.java | 5 +-
.../table/planner/delegation/ParserImplTest.java | 2 +-
.../converter/ExpressionConverterTest.java | 2 +-
.../operations/SqlToOperationConverterTest.java | 2 +-
.../MultipleInputNodeCreationProcessorTest.java | 4 +-
.../serde/TemporalTableSourceSpecSerdeTest.java | 2 +-
.../ProjectWatermarkAssignerTransposeRuleTest.java | 2 +-
.../PushWatermarkIntoTableSourceScanRuleTest.java | 2 +-
.../PushLocalAggIntoTableSourceScanRuleTest.java | 2 +-
.../flink/table/planner/utils/PlannerMocks.java | 4 +-
.../planner/codegen/HashCodeGeneratorTest.scala | 6 +-
.../codegen/ProjectionCodeGeneratorTest.scala | 12 +-
.../codegen/WatermarkGeneratorCodeGenTest.scala | 26 ++---
.../table/planner/codegen/agg/AggTestBase.scala | 4 +-
.../expressions/utils/ExpressionTestBase.scala | 2 +-
.../planner/match/PatternTranslatorTestBase.scala | 6 +-
.../metadata/AggCallSelectivityEstimatorTest.scala | 2 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 2 +-
.../plan/nodes/calcite/RelNodeTestBase.scala | 2 +-
.../planner/plan/utils/PartitionPrunerTest.scala | 12 +-
.../planner/runtime/batch/table/JoinITCase.scala | 2 -
.../planner/runtime/utils/BatchTestBase.scala | 2 +-
.../flink/table/planner/utils/TableTestBase.scala | 8 +-
.../generated/GeneratedAggsHandleFunction.java | 3 +-
.../runtime/generated/GeneratedCollector.java | 3 +-
.../table/runtime/generated/GeneratedFunction.java | 3 +-
.../runtime/generated/GeneratedHashFunction.java | 4 +-
.../table/runtime/generated/GeneratedInput.java | 4 +-
.../runtime/generated/GeneratedJoinCondition.java | 3 +-
.../GeneratedNamespaceAggsHandleFunction.java | 3 +-
.../GeneratedNamespaceTableAggsHandleFunction.java | 3 +-
.../table/runtime/generated/GeneratedOperator.java | 4 +-
.../runtime/generated/GeneratedProjection.java | 3 +-
.../generated/GeneratedRecordComparator.java | 3 +-
.../generated/GeneratedRecordEqualiser.java | 3 +-
.../runtime/generated/GeneratedResultFuture.java | 3 +-
.../GeneratedTableAggsHandleFunction.java | 4 +-
.../generated/GeneratedWatermarkGenerator.java | 3 +-
150 files changed, 435 insertions(+), 576 deletions(-)
