public class SinkRecordConverter extends Object
RowData
to SinkRecord
.Constructor and Description |
---|
SinkRecordConverter(TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
int |
bucket(org.apache.flink.table.data.RowData row) |
SinkRecord |
convert(org.apache.flink.table.data.RowData row) |
SinkRecord |
convertToLogSinkRecord(SinkRecord record) |
public SinkRecordConverter(TableSchema tableSchema)
public SinkRecord convert(org.apache.flink.table.data.RowData row)
public SinkRecord convertToLogSinkRecord(SinkRecord record)
public int bucket(org.apache.flink.table.data.RowData row)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.