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/paimon.git
from 72e57d2e9 [core][spark] Support format table create, and implement
format table for SparkCatalog (#4223)
add 236e38ac8 [feature][flink] introduce RecordAttributes processing logic
for write operators (#3791)
No new revisions were added by this update.
Summary of changes:
.../runtime/streamrecord/RecordAttributes.java | 6 ++--
.../paimon/flink/ProcessRecordAttributesUtil.java} | 20 +++++---------
.../runtime/streamrecord/RecordAttributes.java | 6 ++--
.../paimon/flink/ProcessRecordAttributesUtil.java} | 20 +++++---------
.../runtime/streamrecord/RecordAttributes.java | 6 ++--
.../paimon/flink/ProcessRecordAttributesUtil.java} | 20 +++++---------
.../runtime/streamrecord/RecordAttributes.java | 6 ++--
.../paimon/flink/ProcessRecordAttributesUtil.java} | 20 +++++---------
paimon-flink/paimon-flink-1.19/pom.xml | 7 +++++
paimon-flink/paimon-flink-cdc/pom.xml | 5 ++++
.../runtime/streamrecord/RecordAttributes.java | 6 ++--
.../paimon/flink/ProcessRecordAttributesUtil.java} | 20 +++++---------
...oader.java => ProcessRecordAttributesUtil.java} | 20 ++++++--------
.../apache/paimon/flink/sink/FlinkSinkBuilder.java | 18 ++++++++----
.../flink/sink/HashBucketAssignerOperator.java | 7 +++++
.../StreamMapWithForwardingRecordAttributes.java} | 32 +++++++++-------------
.../paimon/flink/sink/TableWriteOperator.java | 8 ++++++
17 files changed, 110 insertions(+), 117 deletions(-)
copy
paimon-codegen/src/main/scala/org/apache/paimon/codegen/CodeGenException.scala
=>
paimon-flink/paimon-flink-1.15/src/main/java/org/apache/flink/streaming/runtime/streamrecord/RecordAttributes.java
(79%)
copy
paimon-flink/{paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIOLoader.java
=>
paimon-flink-1.15/src/main/java/org/apache/paimon/flink/ProcessRecordAttributesUtil.java}
(62%)
copy
paimon-codegen/src/main/scala/org/apache/paimon/codegen/CodeGenException.scala
=>
paimon-flink/paimon-flink-1.16/src/main/java/org/apache/flink/streaming/runtime/streamrecord/RecordAttributes.java
(79%)
copy
paimon-flink/{paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIOLoader.java
=>
paimon-flink-1.16/src/main/java/org/apache/paimon/flink/ProcessRecordAttributesUtil.java}
(62%)
copy
paimon-codegen/src/main/scala/org/apache/paimon/codegen/CodeGenException.scala
=>
paimon-flink/paimon-flink-1.17/src/main/java/org/apache/flink/streaming/runtime/streamrecord/RecordAttributes.java
(79%)
copy
paimon-flink/{paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIOLoader.java
=>
paimon-flink-1.17/src/main/java/org/apache/paimon/flink/ProcessRecordAttributesUtil.java}
(62%)
copy
paimon-codegen/src/main/scala/org/apache/paimon/codegen/CodeGenException.scala
=>
paimon-flink/paimon-flink-1.18/src/main/java/org/apache/flink/streaming/runtime/streamrecord/RecordAttributes.java
(79%)
copy
paimon-flink/{paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIOLoader.java
=>
paimon-flink-1.18/src/main/java/org/apache/paimon/flink/ProcessRecordAttributesUtil.java}
(62%)
copy
paimon-codegen/src/main/scala/org/apache/paimon/codegen/CodeGenException.scala
=>
paimon-flink/paimon-flink-cdc/src/main/java/org/apache/flink/streaming/runtime/streamrecord/RecordAttributes.java
(79%)
copy
paimon-flink/{paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkFileIOLoader.java
=>
paimon-flink-cdc/src/main/java/org/apache/paimon/flink/ProcessRecordAttributesUtil.java}
(62%)
copy
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/{FlinkFileIOLoader.java
=> ProcessRecordAttributesUtil.java} (62%)
copy
paimon-flink/{paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableAction.java
=>
paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StreamMapWithForwardingRecordAttributes.java}
(55%)
