public class FullChangelogStoreSinkWrite extends StoreSinkWriteImpl
StoreSinkWrite
for CoreOptions.ChangelogProducer#FULL_COMPACTION
changelog
producer. This writer will perform full compaction once in a while.Modifier and Type | Class and Description |
---|---|
static interface |
StoreSinkWrite.Provider |
commitUser, table, write
Constructor and Description |
---|
FullChangelogStoreSinkWrite(FileStoreTable table,
org.apache.flink.runtime.state.StateInitializationContext context,
String initialCommitUser,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
boolean isOverwrite,
long fullCompactionThresholdMs) |
Modifier and Type | Method and Description |
---|---|
void |
compact(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
boolean fullCompaction) |
List<Committable> |
prepareCommit(boolean doCompaction,
long checkpointId) |
void |
snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context) |
SinkRecord |
write(org.apache.flink.table.data.RowData rowData) |
close, notifyNewFiles, toLogRecord
public FullChangelogStoreSinkWrite(FileStoreTable table, org.apache.flink.runtime.state.StateInitializationContext context, String initialCommitUser, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean isOverwrite, long fullCompactionThresholdMs) throws Exception
Exception
public SinkRecord write(org.apache.flink.table.data.RowData rowData) throws Exception
write
in class StoreSinkWriteImpl
Exception
public void compact(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket, boolean fullCompaction) throws Exception
compact
in class StoreSinkWriteImpl
Exception
public List<Committable> prepareCommit(boolean doCompaction, long checkpointId) throws IOException
prepareCommit
in class StoreSinkWriteImpl
IOException
public void snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context) throws Exception
snapshotState
in class StoreSinkWriteImpl
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.