public class SinkRecord extends Object
Constructor and Description |
---|
SinkRecord(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
org.apache.flink.table.data.binary.BinaryRowData primaryKey,
org.apache.flink.table.data.RowData row) |
Modifier and Type | Method and Description |
---|---|
int |
bucket() |
org.apache.flink.table.data.binary.BinaryRowData |
partition() |
org.apache.flink.table.data.binary.BinaryRowData |
primaryKey() |
org.apache.flink.table.data.RowData |
row() |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.