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(-)