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 02978da [FLINK-16645][network] Limit the maximum backlogs in
subpartitions
new 2296487 [FLINK-16996][table-common] Add necessary methods to internal
data structures
new 130967a [FLINK-16996][table-common] Add binary implementations of
internal data structures
new c69d67c [FLINK-16996][table-runtime-blink] Implement all the data
structures and serializers around RowData
new 264d685 [FLINK-16996][table-runtime-blink] Remove legacy data formats
(BaseRow)
new 4ff59a7 [FLINK-16996][table] Refactor planner and runtime to use new
data structures
new 1481f3d [FLINK-16996][python] Refactor pyflink to use new data
structures
new b2c4092 [FLINK-16996][parquet] Refactor parquet connector to use new
data structures
new b8fa6f6 [FLINK-16996][orc] Refactor ORC connector to use new data
structures
new f622530 [FLINK-16996][hive] Refactor Hive connector to use new data
structures
The 9 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/connectors/hive/HiveTableFactory.java | 6 +-
.../flink/connectors/hive/HiveTableSource.java | 24 +-
.../hive/read/HiveMapredSplitReader.java | 12 +-
.../connectors/hive/read/HiveTableInputFormat.java | 10 +-
.../hive/read/HiveVectorizedOrcSplitReader.java | 6 +-
.../read/HiveVectorizedParquetSplitReader.java | 6 +-
.../flink/connectors/hive/read/SplitReader.java | 4 +-
.../flink/connectors/hive/HiveTableSourceTest.java | 6 +-
.../flink/orc/nohive/OrcNoHiveSplitReaderUtil.java | 4 +-
.../orc/nohive/vector/AbstractOrcNoHiveVector.java | 6 +-
.../orc/nohive/vector/OrcNoHiveBytesVector.java | 2 +-
.../orc/nohive/vector/OrcNoHiveDecimalVector.java | 8 +-
.../orc/nohive/vector/OrcNoHiveDoubleVector.java | 4 +-
.../orc/nohive/vector/OrcNoHiveLongVector.java | 10 +-
.../nohive/vector/OrcNoHiveTimestampVector.java | 8 +-
.../flink/orc/OrcColumnarRowSplitReader.java | 16 +-
.../org/apache/flink/orc/OrcSplitReaderUtil.java | 4 +-
.../flink/orc/vector/AbstractOrcColumnVector.java | 6 +-
.../flink/orc/vector/OrcBytesColumnVector.java | 2 +-
.../flink/orc/vector/OrcDecimalColumnVector.java | 8 +-
.../flink/orc/vector/OrcDoubleColumnVector.java | 4 +-
.../flink/orc/vector/OrcLongColumnVector.java | 10 +-
.../flink/orc/vector/OrcTimestampColumnVector.java | 8 +-
.../flink/orc/OrcColumnarRowSplitReaderTest.java | 22 +-
.../parquet/ParquetFileSystemFormatFactory.java | 16 +-
.../formats/parquet/row/ParquetRowDataBuilder.java | 18 +-
.../formats/parquet/row/ParquetRowDataWriter.java | 46 +-
.../vector/ParquetColumnarRowSplitReader.java | 14 +-
.../parquet/vector/ParquetDecimalVector.java | 37 +-
.../formats/parquet/vector/ParquetDictionary.java | 6 +-
.../parquet/vector/ParquetSplitReaderUtil.java | 43 +-
.../vector/reader/AbstractColumnReader.java | 4 +-
.../parquet/vector/reader/BooleanColumnReader.java | 4 +-
.../parquet/vector/reader/ByteColumnReader.java | 4 +-
.../parquet/vector/reader/BytesColumnReader.java | 4 +-
.../parquet/vector/reader/ColumnReader.java | 2 +-
.../parquet/vector/reader/DoubleColumnReader.java | 4 +-
.../vector/reader/FixedLenBytesColumnReader.java | 18 +-
.../parquet/vector/reader/FloatColumnReader.java | 4 +-
.../parquet/vector/reader/IntColumnReader.java | 2 +-
.../parquet/vector/reader/LongColumnReader.java | 4 +-
.../parquet/vector/reader/RunLengthDecoder.java | 4 +-
.../parquet/vector/reader/ShortColumnReader.java | 4 +-
.../vector/reader/TimestampColumnReader.java | 14 +-
.../parquet/row/ParquetRowDataWriterTest.java | 10 +-
.../vector/ParquetColumnarRowSplitReaderTest.java | 18 +-
.../flink/table/runtime/arrow/ArrowUtils.java | 108 +-
.../arrow/vectors/ArrowArrayColumnVector.java | 12 +-
.../arrow/vectors/ArrowBigIntColumnVector.java | 2 +-
.../arrow/vectors/ArrowBooleanColumnVector.java | 2 +-
.../arrow/vectors/ArrowDateColumnVector.java | 2 +-
.../arrow/vectors/ArrowDecimalColumnVector.java | 12 +-
.../arrow/vectors/ArrowDoubleColumnVector.java | 2 +-
.../arrow/vectors/ArrowFloatColumnVector.java | 2 +-
.../arrow/vectors/ArrowIntColumnVector.java | 2 +-
.../arrow/vectors/ArrowRowColumnVector.java | 12 +-
.../arrow/vectors/ArrowSmallIntColumnVector.java | 2 +-
.../arrow/vectors/ArrowTimeColumnVector.java | 2 +-
.../arrow/vectors/ArrowTimestampColumnVector.java | 14 +-
.../arrow/vectors/ArrowTinyIntColumnVector.java | 2 +-
.../arrow/vectors/ArrowVarBinaryColumnVector.java | 2 +-
.../arrow/vectors/ArrowVarCharColumnVector.java | 2 +-
...RowArrowReader.java => RowDataArrowReader.java} | 20 +-
.../table/runtime/arrow/writers/ArrayWriter.java | 78 +-
.../table/runtime/arrow/writers/BigIntWriter.java | 69 +-
.../table/runtime/arrow/writers/BooleanWriter.java | 69 +-
.../table/runtime/arrow/writers/DateWriter.java | 69 +-
.../table/runtime/arrow/writers/DecimalWriter.java | 74 +-
.../table/runtime/arrow/writers/DoubleWriter.java | 69 +-
.../table/runtime/arrow/writers/FloatWriter.java | 69 +-
.../table/runtime/arrow/writers/IntWriter.java | 69 +-
.../table/runtime/arrow/writers/RowWriter.java | 79 +-
.../runtime/arrow/writers/SmallIntWriter.java | 71 +-
.../table/runtime/arrow/writers/TimeWriter.java | 75 +-
.../runtime/arrow/writers/TimestampWriter.java | 81 +-
.../table/runtime/arrow/writers/TinyIntWriter.java | 69 +-
.../runtime/arrow/writers/VarBinaryWriter.java | 69 +-
.../table/runtime/arrow/writers/VarCharWriter.java | 70 +-
.../python/AbstractStatelessFunctionOperator.java | 14 +-
...stractRowDataPythonScalarFunctionOperator.java} | 36 +-
...va => RowDataPythonScalarFunctionOperator.java} | 20 +-
... RowDataArrowPythonScalarFunctionOperator.java} | 22 +-
...ava => RowDataPythonTableFunctionOperator.java} | 62 +-
...java => RowDataPythonScalarFunctionRunner.java} | 14 +-
...=> RowDataArrowPythonScalarFunctionRunner.java} | 12 +-
....java => RowDataPythonTableFunctionRunner.java} | 14 +-
.../table/runtime/typeutils/PythonTypeUtils.java | 28 +-
...raySerializer.java => ArrayDataSerializer.java} | 63 +-
...lSerializer.java => DecimalDataSerializer.java} | 48 +-
...seMapSerializer.java => MapDataSerializer.java} | 86 +-
...seRowSerializer.java => RowDataSerializer.java} | 53 +-
.../flink/table/runtime/arrow/ArrowUtilsTest.java | 89 +-
.../arrow/BaseRowArrowReaderWriterTest.java | 188 ---
.../arrow/RowDataArrowReaderWriterTest.java | 188 +++
...> RowDataPythonScalarFunctionOperatorTest.java} | 38 +-
...DataArrowPythonScalarFunctionOperatorTest.java} | 42 +-
...=> RowDataPythonTableFunctionOperatorTest.java} | 38 +-
... => RowDataPythonScalarFunctionRunnerTest.java} | 24 +-
.../AbstractPythonTableFunctionRunnerTest.java | 2 +-
...a => RowDataPythonTableFunctionRunnerTest.java} | 18 +-
.../runtime/typeutils/PythonTypeUtilsTest.java | 4 +-
...lizerTest.java => ArrayDataSerializerTest.java} | 52 +-
...zerTest.java => DecimalDataSerializerTest.java} | 26 +-
...ializerTest.java => MapDataSerializerTest.java} | 38 +-
...ializerTest.java => RowDataSerializerTest.java} | 52 +-
.../org/apache/flink/table/data/ArrayData.java | 86 ++
.../org/apache/flink/table/data/DecimalData.java | 12 +-
.../apache/flink/table/data/GenericArrayData.java | 43 +
.../apache/flink/table/data/GenericMapData.java | 8 +
.../apache/flink/table/data/GenericRowData.java | 32 +
.../org/apache/flink/table/data/RawValueData.java | 4 +-
.../java/org/apache/flink/table/data/RowData.java | 68 ++
.../org/apache/flink/table/data/StringData.java | 10 +-
.../flink/table/data/binary/BinaryArrayData.java} | 343 +++---
.../flink/table/data/binary/BinaryFormat.java | 73 ++
.../flink/table/data/binary/BinaryMapData.java} | 67 +-
.../table/data/binary/BinaryRawValueData.java | 107 ++
.../flink/table/data/binary/BinaryRowData.java} | 150 +--
.../flink/table/data/binary}/BinarySection.java | 11 +-
.../table/data/binary/BinarySegmentUtils.java | 1198 ++++++++++++++++++++
.../flink/table/data/binary/BinaryStringData.java} | 414 +++----
.../flink/table/data/binary}/LazyBinaryFormat.java | 46 +-
.../flink/table/data/binary/MurmurHashUtils.java | 175 +++
.../flink/table/data/binary/NestedRowData.java} | 172 ++-
.../flink/table/data/binary/StringUtf8Utils.java | 306 +++++
.../flink/table/data/binary/TypedSetters.java | 67 ++
.../flink/table/functions/AsyncTableFunction.java | 3 +-
.../flink/table/types/logical/ArrayType.java | 3 +-
.../flink/table/types/logical/BinaryType.java | 3 +-
.../apache/flink/table/types/logical/CharType.java | 3 +-
.../flink/table/types/logical/DecimalType.java | 3 +-
.../types/logical/LocalZonedTimestampType.java | 3 +-
.../apache/flink/table/types/logical/MapType.java | 3 +-
.../flink/table/types/logical/MultisetType.java | 3 +-
.../apache/flink/table/types/logical/RawType.java | 3 +-
.../apache/flink/table/types/logical/RowType.java | 3 +-
.../flink/table/types/logical/StructuredType.java | 3 +-
.../flink/table/types/logical/TimestampType.java | 3 +-
.../types/logical/TypeInformationRawType.java | 3 +-
.../flink/table/types/logical/VarBinaryType.java | 3 +-
.../flink/table/types/logical/VarCharType.java | 3 +-
.../types/logical/utils/LogicalTypeUtils.java | 58 +
.../expressions/converter/ExpressionConverter.java | 8 +-
.../aggfunctions/FirstValueAggFunction.java | 68 +-
.../FirstValueWithRetractAggFunction.java | 103 +-
.../aggfunctions/LastValueAggFunction.java | 66 +-
.../LastValueWithRetractAggFunction.java | 103 +-
.../ListAggWithRetractAggFunction.java | 44 +-
.../ListAggWsWithRetractAggFunction.java | 46 +-
.../aggfunctions/MaxWithRetractAggFunction.java | 44 +-
.../aggfunctions/MinWithRetractAggFunction.java | 46 +-
.../table/planner/plan/utils/KeySelectorUtil.java | 20 +-
.../planner/calcite/PreValidateReWriter.scala | 6 +-
.../table/planner/codegen/CalcCodeGenerator.scala | 22 +-
.../flink/table/planner/codegen/CodeGenUtils.scala | 143 ++-
.../planner/codegen/CodeGeneratorContext.scala | 14 +-
.../planner/codegen/CorrelateCodeGenerator.scala | 35 +-
.../planner/codegen/EqualiserCodeGenerator.scala | 23 +-
.../planner/codegen/ExpandCodeGenerator.scala | 8 +-
.../table/planner/codegen/ExprCodeGenerator.scala | 19 +-
.../table/planner/codegen/ExpressionReducer.scala | 27 +-
.../planner/codegen/FunctionCodeGenerator.scala | 2 +-
.../table/planner/codegen/GenerateUtils.scala | 71 +-
.../planner/codegen/GeneratedExpression.scala | 2 +-
.../table/planner/codegen/HashCodeGenerator.scala | 9 +-
.../planner/codegen/InputFormatCodeGenerator.scala | 4 +-
.../planner/codegen/LongHashJoinGenerator.scala | 36 +-
.../planner/codegen/LookupJoinCodeGenerator.scala | 33 +-
.../table/planner/codegen/MatchCodeGenerator.scala | 16 +-
.../codegen/NestedLoopJoinCodeGenerator.scala | 22 +-
.../planner/codegen/ProjectionCodeGenerator.scala | 25 +-
.../table/planner/codegen/SinkCodeGenerator.scala | 16 +-
.../planner/codegen/ValuesCodeGenerator.scala | 10 +-
.../codegen/WatermarkGeneratorCodeGenerator.scala | 4 +-
.../codegen/agg/AggsHandlerCodeGenerator.scala | 149 ++-
.../codegen/agg/DeclarativeAggCodeGen.scala | 2 +-
.../planner/codegen/agg/DistinctAggCodeGen.scala | 12 +-
.../planner/codegen/agg/ImperativeAggCodeGen.scala | 30 +-
.../codegen/agg/batch/AggCodeGenHelper.scala | 13 +-
.../agg/batch/AggWithoutKeysCodeGenerator.scala | 6 +-
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 23 +-
.../codegen/agg/batch/HashAggCodeGenerator.scala | 13 +-
.../agg/batch/HashWindowCodeGenerator.scala | 19 +-
.../codegen/agg/batch/SortAggCodeGenerator.scala | 11 +-
.../agg/batch/SortWindowCodeGenerator.scala | 6 +-
.../codegen/agg/batch/WindowCodeGenerator.scala | 41 +-
.../codegen/calls/BridgingSqlFunctionCallGen.scala | 13 +-
.../planner/codegen/calls/BuiltInMethods.scala | 92 +-
.../table/planner/codegen/calls/DivCallGen.scala | 6 +-
.../planner/codegen/calls/FloorCeilCallGen.scala | 8 +-
.../planner/codegen/calls/MethodCallGen.scala | 4 +-
.../codegen/calls/ScalarFunctionCallGen.scala | 4 +-
.../planner/codegen/calls/ScalarOperatorGens.scala | 131 ++-
.../planner/codegen/calls/StringCallGen.scala | 42 +-
.../codegen/calls/TableFunctionCallGen.scala | 7 +-
.../codegen/calls/TimestampDiffCallGen.scala | 1 -
...ltiFieldRangeBoundComparatorCodeGenerator.scala | 6 +-
.../over/RangeBoundComparatorCodeGenerator.scala | 4 +-
.../codegen/sort/ComparatorCodeGenerator.scala | 4 +-
.../planner/codegen/sort/SortCodeGenerator.scala | 23 +-
.../table/planner/dataview/DataViewUtils.scala | 17 +-
.../planner/expressions/ReturnTypeInference.scala | 8 +-
.../functions/utils/UserDefinedFunctionUtils.scala | 79 +-
.../plan/nodes/common/CommonLookupJoin.scala | 38 +-
.../plan/nodes/common/CommonPythonCalc.scala | 24 +-
.../plan/nodes/common/CommonPythonCorrelate.scala | 22 +-
.../batch/BatchExecBoundedStreamScan.scala | 8 +-
.../plan/nodes/physical/batch/BatchExecCalc.scala | 10 +-
.../nodes/physical/batch/BatchExecCalcBase.scala | 15 +-
.../nodes/physical/batch/BatchExecCorrelate.scala | 6 +-
.../physical/batch/BatchExecCorrelateBase.scala | 4 +-
.../nodes/physical/batch/BatchExecExchange.scala | 22 +-
.../nodes/physical/batch/BatchExecExpand.scala | 15 +-
.../batch/BatchExecHashAggregateBase.scala | 18 +-
.../nodes/physical/batch/BatchExecHashJoin.scala | 18 +-
.../batch/BatchExecHashWindowAggregateBase.scala | 15 +-
.../nodes/physical/batch/BatchExecJoinBase.scala | 4 +-
.../plan/nodes/physical/batch/BatchExecLimit.scala | 8 +-
.../nodes/physical/batch/BatchExecLookupJoin.scala | 8 +-
.../physical/batch/BatchExecNestedLoopJoin.scala | 19 +-
.../physical/batch/BatchExecOverAggregate.scala | 27 +-
.../nodes/physical/batch/BatchExecPythonCalc.scala | 17 +-
.../physical/batch/BatchExecPythonCorrelate.scala | 7 +-
.../plan/nodes/physical/batch/BatchExecRank.scala | 12 +-
.../plan/nodes/physical/batch/BatchExecSink.scala | 10 +-
.../plan/nodes/physical/batch/BatchExecSort.scala | 14 +-
.../batch/BatchExecSortAggregateBase.scala | 14 +-
.../nodes/physical/batch/BatchExecSortLimit.scala | 12 +-
.../physical/batch/BatchExecSortMergeJoin.scala | 16 +-
.../batch/BatchExecSortWindowAggregateBase.scala | 14 +-
.../physical/batch/BatchExecTableSourceScan.scala | 9 +-
.../plan/nodes/physical/batch/BatchExecUnion.scala | 8 +-
.../nodes/physical/batch/BatchExecValues.scala | 6 +-
.../nodes/physical/stream/StreamExecCalc.scala | 12 +-
.../nodes/physical/stream/StreamExecCalcBase.scala | 4 +-
.../physical/stream/StreamExecCorrelate.scala | 6 +-
.../physical/stream/StreamExecCorrelateBase.scala | 4 +-
.../physical/stream/StreamExecDataStreamScan.scala | 12 +-
.../physical/stream/StreamExecDeduplicate.scala | 22 +-
.../nodes/physical/stream/StreamExecExchange.scala | 22 +-
.../nodes/physical/stream/StreamExecExpand.scala | 14 +-
.../stream/StreamExecGlobalGroupAggregate.scala | 16 +-
.../physical/stream/StreamExecGroupAggregate.scala | 18 +-
.../stream/StreamExecGroupTableAggregate.scala | 28 +-
.../StreamExecGroupWindowAggregateBase.scala | 36 +-
.../StreamExecIncrementalGroupAggregate.scala | 18 +-
.../nodes/physical/stream/StreamExecJoin.scala | 30 +-
.../nodes/physical/stream/StreamExecLimit.scala | 21 +-
.../stream/StreamExecLocalGroupAggregate.scala | 18 +-
.../physical/stream/StreamExecLookupJoin.scala | 8 +-
.../nodes/physical/stream/StreamExecMatch.scala | 54 +-
.../stream/StreamExecMiniBatchAssigner.scala | 14 +-
.../physical/stream/StreamExecOverAggregate.scala | 22 +-
.../physical/stream/StreamExecPythonCalc.scala | 13 +-
.../stream/StreamExecPythonCorrelate.scala | 13 +-
.../nodes/physical/stream/StreamExecRank.scala | 20 +-
.../nodes/physical/stream/StreamExecSink.scala | 16 +-
.../nodes/physical/stream/StreamExecSort.scala | 14 +-
.../physical/stream/StreamExecSortLimit.scala | 26 +-
.../stream/StreamExecTableSourceScan.scala | 25 +-
.../physical/stream/StreamExecTemporalJoin.scala | 40 +-
.../physical/stream/StreamExecTemporalSort.scala | 32 +-
.../nodes/physical/stream/StreamExecUnion.scala | 8 +-
.../nodes/physical/stream/StreamExecValues.scala | 6 +-
.../stream/StreamExecWatermarkAssigner.scala | 14 +-
.../physical/stream/StreamExecWindowJoin.scala | 98 +-
.../physical/batch/BatchExecAggRuleBase.scala | 4 +-
.../planner/plan/utils/AggFunctionFactory.scala | 14 +-
.../table/planner/plan/utils/AggregateUtil.scala | 18 +-
.../table/planner/plan/utils/FlinkRelMdUtil.scala | 14 +-
.../table/planner/plan/utils/PartitionPruner.scala | 26 +-
.../planner/plan/utils/RexNodeExtractor.scala | 2 +-
.../flink/table/planner/plan/utils/ScanUtil.scala | 16 +-
.../table/planner/plan/utils/WindowJoinUtil.scala | 8 +-
.../flink/table/planner/sinks/TableSinkUtils.scala | 12 +-
.../planner/typeutils/TypeInfoCheckUtils.scala | 6 +-
.../codegen/EqualiserCodeGeneratorTest.java | 46 +-
.../planner/codegen/LongHashJoinGeneratorTest.java | 4 +-
.../planner/codegen/SortCodeGeneratorTest.java | 143 +--
.../aggfunctions/AggFunctionTestBase.java | 22 +-
...FirstLastValueAggFunctionWithOrderTestBase.java | 32 +-
.../FirstValueAggFunctionWithOrderTest.java | 83 +-
.../FirstValueAggFunctionWithoutOrderTest.java | 87 +-
...stValueWithRetractAggFunctionWithOrderTest.java | 83 +-
...alueWithRetractAggFunctionWithoutOrderTest.java | 87 +-
.../LastValueAggFunctionWithOrderTest.java | 83 +-
.../LastValueAggFunctionWithoutOrderTest.java | 87 +-
...stValueWithRetractAggFunctionWithOrderTest.java | 90 +-
...alueWithRetractAggFunctionWithoutOrderTest.java | 87 +-
.../ListAggWithRetractAggFunctionTest.java | 32 +-
.../ListAggWsWithRetractAggFunctionTest.java | 86 +-
.../MaxWithRetractAggFunctionTest.java | 117 +-
.../MinWithRetractAggFunctionTest.java | 117 +-
.../utils/JavaUserDefinedScalarFunctions.java | 10 +-
.../utils/JavaUserDefinedTableFunctions.java | 4 +-
.../planner/runtime/utils/RangeInputFormat.java | 12 +-
.../{BaseRowTestUtil.java => RowDataTestUtil.java} | 49 +-
.../utils/TestCsvFileSystemFormatFactory.java | 22 +-
.../planner/utils/TestRowDataCsvInputFormat.java | 20 +-
.../planner/codegen/HashCodeGeneratorTest.scala | 4 +-
.../codegen/ProjectionCodeGeneratorTest.scala | 24 +-
.../codegen/WatermarkGeneratorCodeGenTest.scala | 24 +-
.../codegen/agg/AggsHandlerCodeGeneratorTest.scala | 26 +-
.../codegen/agg/batch/AggWithoutKeysTest.scala | 6 +-
.../codegen/agg/batch/BatchAggTestBase.scala | 34 +-
.../agg/batch/HashAggCodeGeneratorTest.scala | 6 +-
.../agg/batch/SortAggCodeGeneratorTest.scala | 6 +-
.../expressions/utils/ExpressionTestBase.scala | 19 +-
.../expressions/utils/RowTypeTestBase.scala | 8 +-
.../utils/ScalarOperatorsTestBase.scala | 12 +-
.../expressions/utils/ScalarTypesTestBase.scala | 26 +-
.../utils/userDefinedScalarFunctions.scala | 13 +-
.../planner/match/PatternTranslatorTestBase.scala | 8 +-
.../plan/batch/sql/agg/AggregateTestBase.scala | 4 +-
.../planner/plan/common/TableFactoryTest.scala | 9 +-
.../stream/sql/RelTimeIndicatorConverterTest.scala | 7 +-
.../plan/stream/sql/agg/AggregateTest.scala | 4 +-
.../plan/stream/sql/join/LookupJoinTest.scala | 78 +-
.../planner/runtime/batch/sql/CalcITCase.scala | 17 +-
.../runtime/batch/sql/CorrelateITCase.scala | 8 +-
.../planner/runtime/batch/sql/UnionITCase.scala | 8 +-
.../batch/sql/agg/AggregateITCaseBase.scala | 4 +-
.../planner/runtime/batch/table/CalcITCase.scala | 50 +-
...AbstractTwoInputStreamOperatorWithTTLTest.scala | 20 +-
.../harness/GroupAggregateHarnessTest.scala | 4 +-
.../planner/runtime/harness/HarnessTestBase.scala | 12 +-
.../runtime/harness/OverWindowHarnessTest.scala | 235 ++--
.../harness/TableAggregateHarnessTest.scala | 9 +-
.../runtime/stream/sql/AggregateITCase.scala | 2 +-
.../planner/runtime/stream/sql/CalcITCase.scala | 50 +-
.../runtime/stream/sql/SplitAggregateITCase.scala | 2 +-
.../planner/runtime/stream/sql/ValuesITCase.scala | 12 +-
.../planner/runtime/utils/BatchTestBase.scala | 36 +-
.../planner/runtime/utils/StreamTestSink.scala | 39 +-
.../runtime/utils/StreamingWithStateTestBase.scala | 21 +-
.../table/planner/runtime/utils/TestSinkUtil.scala | 8 +-
.../utils/UserDefinedFunctionTestUtils.scala | 8 +-
.../table/planner/utils/DateTimeTestUtil.scala | 6 +-
.../flink/table/planner/utils/TableTestBase.scala | 4 +-
.../utils/UserDefinedTableAggFunctions.scala | 30 +-
.../flink/table/calcite/PreValidateReWriter.scala | 6 +-
.../plan/nodes/dataset/BatchTableSourceScan.scala | 6 +-
.../nodes/datastream/StreamTableSourceScan.scala | 6 +-
.../logical/FlinkLogicalTableSourceScan.scala | 6 +-
.../flink/table/data/BoxedWrapperRowData.java | 263 +++++
.../apache/flink/table/data/ColumnarArrayData.java | 258 +++++
.../ColumnarRow.java => data/ColumnarRowData.java} | 103 +-
.../apache/flink/table/data/DecimalDataUtils.java | 308 +++++
.../org/apache/flink/table/data/JoinedRowData.java | 225 ++++
.../apache/flink/table/data/UpdatableRowData.java | 194 ++++
.../binary/BinaryRowDataUtil.java} | 11 +-
.../binary/BinaryStringDataUtil.java} | 188 +--
.../util}/DataFormatConverters.java | 475 ++++----
.../GenericMap.java => data/util/MapDataUtil.java} | 54 +-
.../util/RowDataUtil.java} | 39 +-
.../vector/ArrayColumnVector.java | 6 +-
.../vector/BooleanColumnVector.java | 2 +-
.../vector/ByteColumnVector.java | 2 +-
.../vector/BytesColumnVector.java | 2 +-
.../{dataformat => data}/vector/ColumnVector.java | 2 +-
.../vector/DecimalColumnVector.java | 6 +-
.../{dataformat => data}/vector/Dictionary.java | 6 +-
.../vector/DoubleColumnVector.java | 2 +-
.../vector/FloatColumnVector.java | 2 +-
.../vector/IntColumnVector.java | 2 +-
.../vector/LongColumnVector.java | 2 +-
.../vector/RowColumnVector.java | 6 +-
.../vector/ShortColumnVector.java | 2 +-
.../vector/TimestampColumnVector.java | 6 +-
.../vector/VectorizedColumnBatch.java | 20 +-
.../vector/heap/AbstractHeapVector.java | 4 +-
.../vector/heap/HeapBooleanVector.java | 4 +-
.../vector/heap/HeapByteVector.java | 4 +-
.../vector/heap/HeapBytesVector.java | 4 +-
.../vector/heap/HeapDoubleVector.java | 4 +-
.../vector/heap/HeapFloatVector.java | 4 +-
.../vector/heap/HeapIntVector.java | 4 +-
.../vector/heap/HeapLongVector.java | 4 +-
.../vector/heap/HeapShortVector.java | 4 +-
.../vector/heap/HeapTimestampVector.java | 16 +-
.../vector/writable/AbstractWritableVector.java | 6 +-
.../vector/writable/WritableBooleanVector.java | 4 +-
.../vector/writable/WritableByteVector.java | 4 +-
.../vector/writable/WritableBytesVector.java | 4 +-
.../vector/writable/WritableColumnVector.java | 6 +-
.../vector/writable/WritableDoubleVector.java | 4 +-
.../vector/writable/WritableFloatVector.java | 4 +-
.../vector/writable/WritableIntVector.java | 4 +-
.../vector/writable/WritableLongVector.java | 4 +-
.../vector/writable/WritableShortVector.java | 4 +-
.../vector/writable/WritableTimestampVector.java | 12 +-
.../writer}/AbstractBinaryWriter.java | 88 +-
.../writer}/BinaryArrayWriter.java | 19 +-
.../writer}/BinaryRowWriter.java | 22 +-
.../{dataformat => data/writer}/BinaryWriter.java | 55 +-
.../apache/flink/table/dataformat/BaseArray.java | 65 --
.../org/apache/flink/table/dataformat/BaseMap.java | 53 -
.../org/apache/flink/table/dataformat/BaseRow.java | 53 -
.../flink/table/dataformat/BinaryFormat.java | 122 --
.../flink/table/dataformat/BinaryGeneric.java | 91 --
.../flink/table/dataformat/BoxedWrapperRow.java | 145 ---
.../flink/table/dataformat/ColumnarArray.java | 297 -----
.../org/apache/flink/table/dataformat/Decimal.java | 489 --------
.../flink/table/dataformat/GenericArray.java | 305 -----
.../apache/flink/table/dataformat/GenericRow.java | 131 ---
.../apache/flink/table/dataformat/JoinedRow.java | 312 -----
.../flink/table/dataformat/ObjectArrayRow.java | 153 ---
.../flink/table/dataformat/SqlTimestamp.java | 240 ----
.../flink/table/dataformat/TypeGetterSetters.java | 228 ----
.../flink/table/dataformat/UpdatableRow.java | 191 ----
.../table/filesystem/FileSystemFormatFactory.java | 10 +-
.../table/filesystem/FileSystemTableFactory.java | 10 +-
.../table/filesystem/FileSystemTableSink.java | 78 +-
.../table/filesystem/FileSystemTableSource.java | 14 +-
.../table/filesystem/RowDataPartitionComputer.java | 21 +-
.../table/runtime/context/ExecutionContext.java | 6 +-
.../runtime/context/ExecutionContextImpl.java | 8 +-
.../table/runtime/functions/SqlDateTimeUtils.java | 60 +-
.../table/runtime/functions/SqlFunctionUtils.java | 185 +--
.../runtime/functions/SqlLikeChainChecker.java | 26 +-
.../runtime/generated/AggsHandleFunction.java | 4 +-
.../runtime/generated/AggsHandleFunctionBase.java | 14 +-
.../table/runtime/generated/HashFunction.java | 6 +-
.../table/runtime/generated/JoinCondition.java | 4 +-
.../generated/NamespaceAggsHandleFunction.java | 4 +-
.../generated/NamespaceAggsHandleFunctionBase.java | 14 +-
.../NamespaceTableAggsHandleFunction.java | 4 +-
.../runtime/generated/NormalizedKeyComputer.java | 4 +-
.../flink/table/runtime/generated/Projection.java | 6 +-
.../table/runtime/generated/RecordComparator.java | 6 +-
.../table/runtime/generated/RecordEqualiser.java | 12 +-
.../runtime/generated/TableAggsHandleFunction.java | 4 +-
.../runtime/generated/WatermarkGenerator.java | 4 +-
.../runtime/hashtable/BinaryHashBucketArea.java | 8 +-
.../runtime/hashtable/BinaryHashPartition.java | 22 +-
.../table/runtime/hashtable/BinaryHashTable.java | 70 +-
.../table/runtime/hashtable/BuildSideIterator.java | 32 +-
.../table/runtime/hashtable/LongHashPartition.java | 44 +-
.../runtime/hashtable/LongHybridHashTable.java | 36 +-
.../runtime/hashtable/LookupBucketIterator.java | 12 +-
.../table/runtime/hashtable/ProbeIterator.java | 24 +-
.../runtime/hashtable/WrappedRowIterator.java | 4 +-
.../io/BinaryRowChannelInputViewIterator.java | 18 +-
...Selector.java => BinaryRowDataKeySelector.java} | 20 +-
...ySelector.java => EmptyRowDataKeySelector.java} | 18 +-
...RowKeySelector.java => RowDataKeySelector.java} | 10 +-
.../runtime/operators/aggregate/BytesHashMap.java | 66 +-
.../operators/aggregate/GroupAggFunction.java | 42 +-
.../operators/aggregate/GroupTableAggFunction.java | 22 +-
.../aggregate/MiniBatchGlobalGroupAggFunction.java | 44 +-
.../aggregate/MiniBatchGroupAggFunction.java | 50 +-
.../MiniBatchIncrementalGroupAggFunction.java | 46 +-
.../aggregate/MiniBatchLocalGroupAggFunction.java | 24 +-
.../runtime/operators/aggregate/RecordCounter.java | 13 +-
.../deduplicate/DeduplicateFunctionHelper.java | 14 +-
.../DeduplicateKeepFirstRowFunction.java | 6 +-
.../DeduplicateKeepLastRowFunction.java | 16 +-
.../MiniBatchDeduplicateKeepFirstRowFunction.java | 18 +-
.../MiniBatchDeduplicateKeepLastRowFunction.java | 28 +-
.../runtime/operators/join/EmitAwareCollector.java | 12 +-
.../runtime/operators/join/HashJoinOperator.java | 72 +-
.../operators/join/NullAwareJoinHelper.java | 4 +-
.../operators/join/OuterJoinPaddingUtil.java | 26 +-
.../operators/join/ProcTimeBoundedStreamJoin.java | 14 +-
.../operators/join/RowTimeBoundedStreamJoin.java | 14 +-
.../join/SortMergeFullOuterJoinIterator.java | 42 +-
.../operators/join/SortMergeInnerJoinIterator.java | 14 +-
.../operators/join/SortMergeJoinIterator.java | 42 +-
.../operators/join/SortMergeJoinOperator.java | 86 +-
.../join/SortMergeOneSideOuterJoinIterator.java | 18 +-
.../operators/join/TimeBoundedStreamJoin.java | 86 +-
.../join/lookup/AsyncLookupJoinRunner.java | 92 +-
.../join/lookup/AsyncLookupJoinWithCalcRunner.java | 44 +-
.../operators/join/lookup/LookupJoinRunner.java | 32 +-
.../join/lookup/LookupJoinWithCalcRunner.java | 24 +-
.../join/stream/AbstractStreamingJoinOperator.java | 52 +-
.../join/stream/StreamingJoinOperator.java | 46 +-
.../join/stream/StreamingSemiAntiJoinOperator.java | 26 +-
.../join/stream/state/JoinInputSideSpec.java | 20 +-
.../join/stream/state/JoinRecordStateView.java | 8 +-
.../join/stream/state/JoinRecordStateViews.java | 69 +-
.../stream/state/OuterJoinRecordStateView.java | 8 +-
.../stream/state/OuterJoinRecordStateViews.java | 106 +-
...seTwoInputStreamOperatorWithStateRetention.java | 6 +-
.../temporal/TemporalProcessTimeJoinOperator.java | 32 +-
.../join/temporal/TemporalRowTimeJoinOperator.java | 78 +-
.../operators/match/IterativeConditionRunner.java | 12 +-
.../match/PatternProcessFunctionRunner.java | 12 +-
...Comparator.java => RowDataEventComparator.java} | 8 +-
.../operators/match/RowtimeProcessFunction.java | 16 +-
.../AbstractRowTimeUnboundedPrecedingOver.java | 50 +-
.../over/BufferDataOverWindowOperator.java | 38 +-
.../over/NonBufferOverWindowOperator.java | 34 +-
.../ProcTimeRangeBoundedPrecedingFunction.java | 56 +-
.../over/ProcTimeRowsBoundedPrecedingFunction.java | 50 +-
.../over/ProcTimeUnboundedPrecedingFunction.java | 34 +-
.../over/RowTimeRangeBoundedPrecedingFunction.java | 54 +-
.../RowTimeRangeUnboundedPrecedingFunction.java | 12 +-
.../over/RowTimeRowsBoundedPrecedingFunction.java | 50 +-
.../RowTimeRowsUnboundedPrecedingFunction.java | 8 +-
.../operators/over/frame/InsensitiveOverFrame.java | 4 +-
.../operators/over/frame/OffsetOverFrame.java | 6 +-
.../operators/over/frame/OverWindowFrame.java | 10 +-
.../over/frame/RangeSlidingOverFrame.java | 4 +-
.../frame/RangeUnboundedFollowingOverFrame.java | 8 +-
.../frame/RangeUnboundedPrecedingOverFrame.java | 4 +-
.../operators/over/frame/RowSlidingOverFrame.java | 4 +-
.../over/frame/RowUnboundedFollowingOverFrame.java | 8 +-
.../over/frame/RowUnboundedPrecedingOverFrame.java | 4 +-
.../operators/over/frame/SlidingOverFrame.java | 24 +-
.../over/frame/UnboundedFollowingOverFrame.java | 16 +-
.../over/frame/UnboundedOverWindowFrame.java | 12 +-
.../over/frame/UnboundedPrecedingOverFrame.java | 8 +-
.../operators/rank/AbstractTopNFunction.java | 64 +-
.../operators/rank/AppendOnlyTopNFunction.java | 74 +-
.../operators/rank/RetractableTopNFunction.java | 123 +-
.../table/runtime/operators/rank/TopNBuffer.java | 60 +-
.../operators/rank/UpdatableTopNFunction.java | 170 +--
.../operators/sort/BaseTemporalSortOperator.java | 8 +-
.../operators/sort/BinaryExternalMerger.java | 24 +-
.../operators/sort/BinaryExternalSorter.java | 50 +-
.../operators/sort/BinaryInMemorySortBuffer.java | 30 +-
.../operators/sort/BinaryIndexedSortable.java | 24 +-
.../operators/sort/BinaryKVExternalMerger.java | 26 +-
.../operators/sort/BinaryKVInMemorySortBuffer.java | 28 +-
.../operators/sort/BinaryMergeIterator.java | 2 +-
.../operators/sort/BufferedKVExternalSorter.java | 16 +-
.../runtime/operators/sort/LimitOperator.java | 10 +-
.../operators/sort/ProcTimeSortOperator.java | 26 +-
.../table/runtime/operators/sort/RankOperator.java | 34 +-
.../operators/sort/RowTimeSortOperator.java | 30 +-
.../runtime/operators/sort/SortLimitOperator.java | 26 +-
.../table/runtime/operators/sort/SortOperator.java | 26 +-
.../table/runtime/operators/sort/SortUtil.java | 22 +-
.../runtime/operators/sort/StreamSortOperator.java | 50 +-
.../operators/values/ValuesInputFormat.java | 22 +-
.../operators/window/AggregateWindowOperator.java | 30 +-
.../window/TableAggregateWindowOperator.java | 6 +-
.../runtime/operators/window/WindowOperator.java | 52 +-
.../assigners/CountSlidingWindowAssigner.java | 4 +-
.../assigners/CountTumblingWindowAssigner.java | 4 +-
.../window/assigners/SessionWindowAssigner.java | 5 +-
.../window/assigners/SlidingWindowAssigner.java | 4 +-
.../window/assigners/TumblingWindowAssigner.java | 4 +-
.../operators/window/assigners/WindowAssigner.java | 5 +-
.../window/grouping/HeapWindowsGrouping.java | 20 +-
.../operators/window/grouping/WindowsGrouping.java | 28 +-
.../internal/GeneralWindowProcessFunction.java | 8 +-
.../internal/InternalWindowProcessFunction.java | 11 +-
.../internal/MergingWindowProcessFunction.java | 12 +-
.../internal/PanedWindowProcessFunction.java | 10 +-
.../BoundedOutOfOrderWatermarkGenerator.java | 4 +-
.../ProcTimeMiniBatchAssignerOperator.java | 8 +-
.../RowTimeMiniBatchAssginerOperator.java | 8 +-
.../wmassigners/WatermarkAssignerOperator.java | 10 +-
.../WatermarkAssignerOperatorFactory.java | 6 +-
.../runtime/partitioner/BinaryHashPartitioner.java | 12 +-
.../runtime/types/ClassLogicalTypeConverter.java | 55 -
.../table/runtime/types/InternalSerializers.java | 42 +-
.../types/LogicalTypeDataTypeConverter.java | 22 +-
.../runtime/types/TypeInfoDataTypeConverter.java | 40 +-
...ializer.java => AbstractRowDataSerializer.java} | 18 +-
...raySerializer.java => ArrayDataSerializer.java} | 197 ++--
...erializer.java => BinaryRowDataSerializer.java} | 142 +--
.../typeutils/BinaryStringTypeInfoFactory.java | 39 -
...lSerializer.java => DecimalDataSerializer.java} | 58 +-
...cimalTypeInfo.java => DecimalDataTypeInfo.java} | 30 +-
.../runtime/typeutils/DecimalTypeInfoFactory.java | 37 -
...seMapSerializer.java => MapDataSerializer.java} | 142 ++-
...Serializer.java => RawValueDataSerializer.java} | 82 +-
...seRowSerializer.java => RowDataSerializer.java} | 180 +--
.../{BaseRowTypeInfo.java => RowDataTypeInfo.java} | 48 +-
...ngSerializer.java => StringDataSerializer.java} | 57 +-
...StringTypeInfo.java => StringDataTypeInfo.java} | 27 +-
...erializer.java => TimestampDataSerializer.java} | 68 +-
...ampTypeInfo.java => TimestampDataTypeInfo.java} | 24 +-
.../table/runtime/typeutils/TypeCheckUtils.java | 2 +-
.../runtime/util/ResettableExternalBuffer.java | 46 +-
.../table/runtime/util/ResettableRowBuffer.java | 12 +-
.../flink/table/runtime/util/RowIterator.java | 4 +-
.../BinaryArrayDataTest.java} | 190 ++--
.../BinaryRowDataTest.java} | 387 ++++---
.../BinaryStringDataTest.java} | 275 ++---
.../DataFormatConvertersTest.java | 35 +-
.../apache/flink/table/data/DecimalDataTest.java | 151 +++
.../NestedRowDataTest.java} | 83 +-
.../BaseRowTest.java => data/RowDataTest.java} | 166 +--
.../apache/flink/table/data/TimestampDataTest.java | 125 ++
.../binary/BinarySegmentUtilsTest.java} | 79 +-
.../util}/DataFormatTestUtil.java | 55 +-
.../vector/ColumnVectorTest.java | 54 +-
.../vector/VectorizedColumnBatchTest.java | 56 +-
.../apache/flink/table/dataformat/DecimalTest.java | 125 --
.../flink/table/dataformat/SqlTimestampTest.java | 125 --
.../runtime/hashtable/BinaryHashTableTest.java | 192 ++--
.../table/runtime/hashtable/LongHashTableTest.java | 140 +--
.../operators/aggregate/BytesHashMapTest.java | 110 +-
.../runtime/operators/aggregate/HashAggTest.java | 46 +-
.../aggregate/SumHashAggTestOperator.java | 62 +-
.../deduplicate/DeduplicateFunctionTestBase.java | 12 +-
.../DeduplicateKeepFirstRowFunctionTest.java | 10 +-
.../DeduplicateKeepLastRowFunctionTest.java | 14 +-
...niBatchDeduplicateKeepFirstRowFunctionTest.java | 10 +-
...iniBatchDeduplicateKeepLastRowFunctionTest.java | 14 +-
.../operators/join/AsyncLookupJoinHarnessTest.java | 60 +-
.../operators/join/Int2HashJoinOperatorTest.java | 94 +-
.../join/Int2SortMergeJoinOperatorTest.java | 30 +-
.../operators/join/LookupJoinHarnessTest.java | 66 +-
.../join/ProcTimeBoundedStreamJoinTest.java | 20 +-
.../join/RandomSortMergeInnerJoinTest.java | 38 +-
.../join/RowTimeBoundedStreamJoinTest.java | 26 +-
.../operators/join/SortMergeJoinIteratorTest.java | 118 +-
.../join/String2HashJoinOperatorTest.java | 34 +-
.../join/String2SortMergeJoinOperatorTest.java | 22 +-
.../join/TimeBoundedStreamJoinTestBase.java | 20 +-
.../over/BufferDataOverWindowOperatorTest.java | 120 +-
.../over/NonBufferOverWindowOperatorTest.java | 56 +-
.../operators/over/SumAggsHandleFunction.java | 22 +-
.../operators/rank/AppendOnlyTopNFunctionTest.java | 4 +-
.../rank/RetractableTopNFunctionTest.java | 20 +-
.../operators/rank/TopNFunctionTestBase.java | 46 +-
.../operators/rank/UpdatableTopNFunctionTest.java | 14 +-
.../operators/sort/BinaryExternalSorterTest.java | 76 +-
.../operators/sort/BinaryMergeIteratorTest.java | 46 +-
.../sort/BufferedKVExternalSorterTest.java | 34 +-
.../operators/sort/IntNormalizedKeyComputer.java | 4 +-
.../operators/sort/IntRecordComparator.java | 4 +-
.../operators/sort/ProcTimeSortOperatorTest.java | 18 +-
.../operators/sort/RowTimeSortOperatorTest.java | 26 +-
.../table/runtime/operators/sort/SortUtilTest.java | 17 +-
.../operators/sort/StreamSortOperatorTest.java | 14 +-
.../sort/StringNormalizedKeyComputer.java | 16 +-
.../operators/sort/StringRecordComparator.java | 4 +-
.../operators/window/MergingWindowSetTest.java | 4 +-
.../window/WindowOperatorContractTest.java | 40 +-
.../operators/window/WindowOperatorTest.java | 115 +-
.../assigners/SessionWindowAssignerTest.java | 6 +-
.../assigners/SlidingWindowAssignerTest.java | 6 +-
.../assigners/TumblingWindowAssignerTest.java | 6 +-
.../window/grouping/HeapWindowsGroupingTest.java | 22 +-
.../ProcTimeMiniBatchAssignerOperatorTest.java | 24 +-
.../RowTimeMiniBatchAssginerOperatorTest.java | 38 +-
.../wmassigners/WatermarkAssignerOperatorTest.java | 72 +-
.../WatermarkAssignerOperatorTestBase.java | 4 +-
...lizerTest.java => ArrayDataSerializerTest.java} | 79 +-
.../runtime/typeutils/BinaryRowSerializerTest.java | 28 +-
.../runtime/typeutils/DecimalSerializerTest.java | 26 +-
.../runtime/typeutils/InternalTypeInfoTest.java | 14 +-
...ializerTest.java => MapDataSerializerTest.java} | 83 +-
...erTest.java => RawValueDataSerializerTest.java} | 40 +-
...ializerTest.java => RowDataSerializerTest.java} | 138 +--
...wTypeInfoTest.java => RowDataTypeInfoTest.java} | 16 +-
...izerTest.java => StringDataSerializerTest.java} | 18 +-
...rTest.java => TimestampDataSerializerTest.java} | 28 +-
...Selector.java => BinaryRowDataKeySelector.java} | 29 +-
.../util/GenericRowRecordSortComparator.java | 14 +-
.../runtime/util/ResettableExternalBufferTest.java | 70 +-
...ssAssertor.java => RowDataHarnessAssertor.java} | 44 +-
...dEqualiser.java => RowDataRecordEqualiser.java} | 29 +-
.../table/runtime/util/StreamRecordUtils.java | 102 +-
.../runtime/util/UniformBinaryRowGenerator.java | 12 +-
...ericAsserter.java => RawValueDataAsserter.java} | 54 +-
662 files changed, 14558 insertions(+), 12904 deletions(-)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/{BaseRowArrowReader.java
=> RowDataArrowReader.java} (76%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/{AbstractBaseRowPythonScalarFunctionOperator.java
=> AbstractRowDataPythonScalarFunctionOperator.java} (76%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/{BaseRowPythonScalarFunctionOperator.java
=> RowDataPythonScalarFunctionOperator.java} (81%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/{BaseRowArrowPythonScalarFunctionOperator.java
=> RowDataArrowPythonScalarFunctionOperator.java} (85%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/{BaseRowPythonTableFunctionOperator.java
=> RowDataPythonTableFunctionOperator.java} (71%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/scalar/{BaseRowPythonScalarFunctionRunner.java
=> RowDataPythonScalarFunctionRunner.java} (81%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/scalar/arrow/{BaseRowArrowPythonScalarFunctionRunner.java
=> RowDataArrowPythonScalarFunctionRunner.java} (84%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/table/{BaseRowPythonTableFunctionRunner.java
=> RowDataPythonTableFunctionRunner.java} (81%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/{BaseArraySerializer.java
=> ArrayDataSerializer.java} (67%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/{DecimalSerializer.java
=> DecimalDataSerializer.java} (72%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/{BaseMapSerializer.java
=> MapDataSerializer.java} (69%)
rename
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/{BaseRowSerializer.java
=> RowDataSerializer.java} (76%)
delete mode 100644
flink-python/src/test/java/org/apache/flink/table/runtime/arrow/BaseRowArrowReaderWriterTest.java
create mode 100644
flink-python/src/test/java/org/apache/flink/table/runtime/arrow/RowDataArrowReaderWriterTest.java
rename
flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/scalar/{BaseRowPythonScalarFunctionOperatorTest.java
=> RowDataPythonScalarFunctionOperatorTest.java} (78%)
rename
flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/{BaseRowArrowPythonScalarFunctionOperatorTest.java
=> RowDataArrowPythonScalarFunctionOperatorTest.java} (75%)
rename
flink-python/src/test/java/org/apache/flink/table/runtime/operators/python/table/{BaseRowPythonTableFunctionOperatorTest.java
=> RowDataPythonTableFunctionOperatorTest.java} (73%)
rename
flink-python/src/test/java/org/apache/flink/table/runtime/runners/python/scalar/{BaseRowPythonScalarFunctionRunnerTest.java
=> RowDataPythonScalarFunctionRunnerTest.java} (79%)
rename
flink-python/src/test/java/org/apache/flink/table/runtime/runners/python/table/{BaseRowPythonTableFunctionRunnerTest.java
=> RowDataPythonTableFunctionRunnerTest.java} (82%)
rename
flink-python/src/test/java/org/apache/flink/table/runtime/typeutils/serializers/python/{BaseArraySerializerTest.java
=> ArrayDataSerializerTest.java} (55%)
rename
flink-python/src/test/java/org/apache/flink/table/runtime/typeutils/serializers/python/{DecimalSerializerTest.java
=> DecimalDataSerializerTest.java} (65%)
rename
flink-python/src/test/java/org/apache/flink/table/runtime/typeutils/serializers/python/{BaseMapSerializerTest.java
=> MapDataSerializerTest.java} (68%)
rename
flink-python/src/test/java/org/apache/flink/table/runtime/typeutils/serializers/python/{BaseRowSerializerTest.java
=> RowDataSerializerTest.java} (64%)
rename
flink-table/{flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BinaryArray.java
=>
flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryArrayData.java}
(50%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryFormat.java
rename
flink-table/{flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BinaryMap.java
=>
flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryMapData.java}
(60%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryRawValueData.java
rename
flink-table/{flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BinaryRow.java
=>
flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryRowData.java}
(68%)
rename
flink-table/{flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat
=>
flink-table-common/src/main/java/org/apache/flink/table/data/binary}/BinarySection.java
(83%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java
rename
flink-table/{flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BinaryString.java
=>
flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryStringData.java}
(72%)
rename
flink-table/{flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat
=>
flink-table-common/src/main/java/org/apache/flink/table/data/binary}/LazyBinaryFormat.java
(69%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/MurmurHashUtils.java
rename
flink-table/{flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/NestedRow.java
=>
flink-table-common/src/main/java/org/apache/flink/table/data/binary/NestedRowData.java}
(50%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/StringUtf8Utils.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/TypedSetters.java
rename
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/utils/{BaseRowTestUtil.java
=> RowDataTestUtil.java} (61%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/BoxedWrapperRowData.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/ColumnarArrayData.java
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat/ColumnarRow.java
=> data/ColumnarRowData.java} (54%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/DecimalDataUtils.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/JoinedRowData.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/UpdatableRowData.java
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat/util/BinaryRowUtil.java
=> data/binary/BinaryRowDataUtil.java} (86%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat/BinaryStringUtil.java
=> data/binary/BinaryStringDataUtil.java} (81%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data/util}/DataFormatConverters.java (74%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat/GenericMap.java
=> data/util/MapDataUtil.java} (52%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat/util/BaseRowUtil.java
=> data/util/RowDataUtil.java} (64%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/ArrayColumnVector.java (87%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/BooleanColumnVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/ByteColumnVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/BytesColumnVector.java (96%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/ColumnVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/DecimalColumnVector.java (85%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/Dictionary.java (88%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/DoubleColumnVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/FloatColumnVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/IntColumnVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/LongColumnVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/RowColumnVector.java (87%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/ShortColumnVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/TimestampColumnVector.java (85%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/VectorizedColumnBatch.java (85%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/AbstractHeapVector.java (96%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapBooleanVector.java (92%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapByteVector.java (92%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapBytesVector.java (96%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapDoubleVector.java (95%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapFloatVector.java (95%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapIntVector.java (95%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapLongVector.java (94%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapShortVector.java (92%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/heap/HeapTimestampVector.java (76%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/AbstractWritableVector.java (90%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableBooleanVector.java (89%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableByteVector.java (90%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableBytesVector.java (90%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableColumnVector.java (90%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableDoubleVector.java (92%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableFloatVector.java (92%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableIntVector.java (93%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableLongVector.java (92%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableShortVector.java (90%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data}/vector/writable/WritableTimestampVector.java (75%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data/writer}/AbstractBinaryWriter.java (74%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data/writer}/BinaryArrayWriter.java (89%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data/writer}/BinaryRowWriter.java (82%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/{dataformat
=> data/writer}/BinaryWriter.java (62%)
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BaseArray.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BaseMap.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BaseRow.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BinaryFormat.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BinaryGeneric.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/BoxedWrapperRow.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/ColumnarArray.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/Decimal.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/GenericArray.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/GenericRow.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/JoinedRow.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/ObjectArrayRow.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/SqlTimestamp.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/TypeGetterSetters.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/UpdatableRow.java
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/keyselector/{BinaryRowKeySelector.java
=> BinaryRowDataKeySelector.java} (70%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/keyselector/{NullBinaryRowKeySelector.java
=> EmptyRowDataKeySelector.java} (66%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/keyselector/{BaseRowKeySelector.java
=> RowDataKeySelector.java} (74%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/match/{BaseRowEventComparator.java
=> RowDataEventComparator.java} (86%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{AbstractRowSerializer.java
=> AbstractRowDataSerializer.java} (87%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BaseArraySerializer.java
=> ArrayDataSerializer.java} (51%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BinaryRowSerializer.java
=> BinaryRowDataSerializer.java} (69%)
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/BinaryStringTypeInfoFactory.java
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{DecimalSerializer.java
=> DecimalDataSerializer.java} (68%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{DecimalTypeInfo.java
=> DecimalDataTypeInfo.java} (72%)
delete mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalTypeInfoFactory.java
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BaseMapSerializer.java
=> MapDataSerializer.java} (63%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BinaryGenericSerializer.java
=> RawValueDataSerializer.java} (51%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BaseRowSerializer.java
=> RowDataSerializer.java} (60%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BaseRowTypeInfo.java
=> RowDataTypeInfo.java} (81%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BinaryStringSerializer.java
=> StringDataSerializer.java} (54%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{BinaryStringTypeInfo.java
=> StringDataTypeInfo.java} (69%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{SqlTimestampSerializer.java
=> TimestampDataSerializer.java} (60%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/{SqlTimestampTypeInfo.java
=> TimestampDataTypeInfo.java} (75%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat/BinaryArrayTest.java
=> data/BinaryArrayDataTest.java} (67%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat/BinaryRowTest.java
=> data/BinaryRowDataTest.java} (69%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat/BinaryStringTest.java
=> data/BinaryStringDataTest.java} (72%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat
=> data}/DataFormatConvertersTest.java (87%)
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/data/DecimalDataTest.java
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat/NestedRowTest.java
=> data/NestedRowDataTest.java} (61%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat/BaseRowTest.java
=> data/RowDataTest.java} (55%)
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/data/TimestampDataTest.java
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{runtime/util/SegmentsUtilTest.java
=> data/binary/BinarySegmentUtilsTest.java} (63%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat
=> data/util}/DataFormatTestUtil.java (67%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat
=> data}/vector/ColumnVectorTest.java (83%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/{dataformat
=> data}/vector/VectorizedColumnBatchTest.java (83%)
delete mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/dataformat/DecimalTest.java
delete mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/dataformat/SqlTimestampTest.java
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/{BaseArraySerializerTest.java
=> ArrayDataSerializerTest.java} (66%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/{BaseMapSerializerTest.java
=> MapDataSerializerTest.java} (64%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/{BinaryGenericSerializerTest.java
=> RawValueDataSerializerTest.java} (55%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/{BaseRowSerializerTest.java
=> RowDataSerializerTest.java} (59%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/{BinaryRowTypeInfoTest.java
=> RowDataTypeInfoTest.java} (84%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/{BinaryStringSerializerTest.java
=> StringDataSerializerTest.java} (71%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/{SqlTimestampSerializerTest.java
=> TimestampDataSerializerTest.java} (69%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/{BinaryRowKeySelector.java
=> BinaryRowDataKeySelector.java} (70%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/{BaseRowHarnessAssertor.java
=> RowDataHarnessAssertor.java} (76%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/{BaseRowRecordEqualiser.java
=> RowDataRecordEqualiser.java} (56%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/utils/{BinaryGenericAsserter.java
=> RawValueDataAsserter.java} (50%)
