You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2022/06/07 10:40:32 UTC
[flink-table-store] branch master updated (3ec19cd5 -> 0954b945)

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


    from 3ec19cd5 [FLINK-27875] Introduce ResetRowKindRecordIterator to reset INSERT row kind
     add f904b889 [FLINK-27927] Add RowDataUtils to copy and get field from row data
     add 4471bff0 [FLINK-27927] Add timestampPrecision in TypeUtils
     add adf9aeb5 [FLINK-27927] Schema should be serializable
     add 679d3d0a [FLINK-27927] Introduce fromJavaObject in Literal
     add a5579a1a [FLINK-27927] Introduce serializer utils for Split
     add 844ee24a [FLINK-27927] Add name and rowtype and merge options to FileStoreTable
     add 0954b945 [hotfix] Fix unstable FileStoreITCase

No new revisions were added by this update.

Summary of changes:
 .../flink/table/store/utils/RowDataUtils.java      | 259 +++++++++++++++++++++
 .../apache/flink/table/store/utils/TypeUtils.java  |  13 +-
 .../utils/RowDataUtilsTest.java                    | 110 +++++++++
 .../table/store/connector/FileStoreITCase.java     |  29 +--
 .../flink/table/store/file/predicate/Literal.java  |  79 +++++++
 .../flink/table/store/file/schema/Schema.java      |  10 +-
 .../AbstractFileStoreTable.java}                   |  27 ++-
 .../store/table/AppendOnlyFileStoreTable.java      |  10 +-
 .../table/ChangelogValueCountFileStoreTable.java   |  12 +-
 .../table/ChangelogWithKeyFileStoreTable.java      |  11 +-
 .../flink/table/store/table/FileStoreTable.java    |   9 +-
 .../table/store/table/FileStoreTableFactory.java   |  20 +-
 .../flink/table/store/table/source/Split.java      |  63 +++++
 .../flink/table/store/table/source/TableRead.java  |   9 +
 .../flink/table/store/table/source/TableScan.java  |   7 +
 .../flink/table/store/table/source/SplitTest.java  |  56 +++++
 .../store/SearchArgumentToPredicateConverter.java  |  65 +-----
 .../flink/table/store/FileStoreTestHelper.java     |   9 +-
 18 files changed, 696 insertions(+), 102 deletions(-)
 create mode 100644 flink-table-store-common/src/main/java/org/apache/flink/table/store/utils/RowDataUtils.java
 create mode 100644 flink-table-store-common/src/test/java/org.apache.flink.table.store/utils/RowDataUtilsTest.java
 copy flink-table-store-core/src/main/java/org/apache/flink/table/store/{file/schema/AtomicDataType.java => table/AbstractFileStoreTable.java} (58%)
 create mode 100644 flink-table-store-core/src/test/java/org/apache/flink/table/store/table/source/SplitTest.java