This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 26af121 [hotfix][docs] link tags in zh docs require .zh.md links
new 91f4a3c [FLINK-17169][core] Add shortString() method to RowKind to
get short string representation
new 7662e0b [FLINK-17169][table-planner-blink] Rename
StreamRecordUtils#record() to insertRecord()
new 670ef41 [FLINK-17169][table-blink] Fix allowLateness shouldn't affect
producing updates of emit strategy
new bf39d75 [FLINK-17169][table-blink] Refactor BaseRow to use RowKind
instead of byte header
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:
.../main/java/org/apache/flink/types/RowKind.java | 67 +++-
...bstractBaseRowPythonScalarFunctionOperator.java | 2 +-
.../BaseRowPythonScalarFunctionOperator.java | 2 +-
.../BaseRowArrowPythonScalarFunctionOperator.java | 2 +-
.../table/BaseRowPythonTableFunctionOperator.java | 4 +-
.../BaseRowPythonScalarFunctionOperatorTest.java | 6 +-
...seRowArrowPythonScalarFunctionOperatorTest.java | 6 +-
.../BaseRowPythonTableFunctionOperatorTest.java | 8 +-
.../table/planner/codegen/CalcCodeGenerator.scala | 2 +-
.../flink/table/planner/codegen/CodeGenUtils.scala | 6 +-
.../planner/codegen/CorrelateCodeGenerator.scala | 12 +-
.../planner/codegen/EqualiserCodeGenerator.scala | 2 +-
.../planner/codegen/ExpandCodeGenerator.scala | 2 +-
.../planner/codegen/LookupJoinCodeGenerator.scala | 2 +-
.../codegen/agg/AggsHandlerCodeGenerator.scala | 4 +-
.../physical/stream/StreamExecDeduplicate.scala | 25 +-
.../StreamExecGroupWindowAggregateBase.scala | 2 +-
.../planner/plan/utils/WindowEmitStrategy.scala | 2 +-
.../flink/table/planner/utils/BaseRowTestUtil.java | 6 +-
.../plan/stream/sql/agg/WindowAggregateTest.xml | 272 ++++++++------
.../plan/stream/sql/agg/WindowAggregateTest.scala | 28 ++
...AbstractTwoInputStreamOperatorWithTTLTest.scala | 6 +-
.../harness/GroupAggregateHarnessTest.scala | 68 ++--
.../harness/TableAggregateHarnessTest.scala | 90 ++---
.../planner/runtime/stream/sql/CalcITCase.scala | 4 +-
.../planner/runtime/stream/sql/RankITCase.scala | 8 +-
.../planner/runtime/stream/sql/ValuesITCase.scala | 2 +-
.../table/planner/runtime/utils/TestSinkUtil.scala | 3 +-
.../org/apache/flink/table/dataformat/BaseRow.java | 15 +-
.../apache/flink/table/dataformat/BinaryRow.java | 19 +-
.../flink/table/dataformat/BinaryRowWriter.java | 6 +-
.../apache/flink/table/dataformat/ColumnarRow.java | 11 +-
.../apache/flink/table/dataformat/GenericRow.java | 2 +-
.../apache/flink/table/dataformat/JoinedRow.java | 12 +-
.../apache/flink/table/dataformat/NestedRow.java | 11 +-
.../flink/table/dataformat/ObjectArrayRow.java | 24 +-
.../flink/table/dataformat/UpdatableRow.java | 10 +-
.../flink/table/dataformat/util/BaseRowUtil.java | 33 +-
.../operators/aggregate/GroupAggFunction.java | 18 +-
.../aggregate/MiniBatchGlobalGroupAggFunction.java | 27 +-
.../aggregate/MiniBatchGroupAggFunction.java | 22 +-
.../deduplicate/DeduplicateFunctionHelper.java | 48 ++-
.../DeduplicateKeepLastRowFunction.java | 20 +-
.../MiniBatchDeduplicateKeepLastRowFunction.java | 5 +-
.../join/lookup/AsyncLookupJoinRunner.java | 4 +-
.../operators/join/lookup/LookupJoinRunner.java | 2 +-
.../join/stream/StreamingJoinOperator.java | 72 ++--
.../join/stream/StreamingSemiAntiJoinOperator.java | 53 +--
.../temporal/TemporalProcessTimeJoinOperator.java | 2 +-
.../join/temporal/TemporalRowTimeJoinOperator.java | 5 +-
.../operators/rank/AbstractTopNFunction.java | 54 +--
.../operators/rank/AppendOnlyTopNFunction.java | 33 +-
.../operators/rank/RetractableTopNFunction.java | 77 ++--
.../operators/rank/UpdatableTopNFunction.java | 95 ++---
.../runtime/operators/sort/StreamSortOperator.java | 3 +-
.../operators/window/AggregateWindowOperator.java | 39 +-
.../window/TableAggregateWindowOperator.java | 4 +-
.../runtime/operators/window/WindowOperator.java | 12 +-
.../operators/window/WindowOperatorBuilder.java | 18 +-
.../table/runtime/typeutils/BaseRowSerializer.java | 4 +-
.../apache/flink/table/dataformat/BaseRowTest.java | 7 +-
.../flink/table/dataformat/BinaryRowTest.java | 13 +-
.../DeduplicateKeepFirstRowFunctionTest.java | 32 +-
.../DeduplicateKeepLastRowFunctionTest.java | 95 +++--
...niBatchDeduplicateKeepFirstRowFunctionTest.java | 32 +-
...iniBatchDeduplicateKeepLastRowFunctionTest.java | 123 ++++---
.../operators/join/AsyncLookupJoinHarnessTest.java | 78 ++--
.../operators/join/LookupJoinHarnessTest.java | 78 ++--
.../join/ProcTimeBoundedStreamJoinTest.java | 48 +--
.../join/RowTimeBoundedStreamJoinTest.java | 190 +++++-----
.../operators/rank/AppendOnlyTopNFunctionTest.java | 32 +-
.../rank/RetractableTopNFunctionTest.java | 351 ++++++++++--------
.../operators/rank/TopNFunctionTestBase.java | 211 +++++------
.../operators/rank/UpdatableTopNFunctionTest.java | 223 ++++++------
.../operators/sort/ProcTimeSortOperatorTest.java | 54 +--
.../operators/sort/RowTimeSortOperatorTest.java | 98 ++---
.../operators/sort/StreamSortOperatorTest.java | 34 +-
.../window/WindowOperatorContractTest.java | 14 +-
.../operators/window/WindowOperatorTest.java | 397 ++++++++++-----------
.../table/runtime/util/BaseRowHarnessAssertor.java | 1 -
.../util/GenericRowRecordSortComparator.java | 9 +-
.../table/runtime/util/StreamRecordUtils.java | 58 ++-
82 files changed, 1997 insertions(+), 1584 deletions(-)
