public class AppendOnlyFileStoreWrite extends AbstractFileStoreWrite<org.apache.flink.table.data.RowData>
AbstractFileStoreWrite.WriterContainer<T>
ioManager, snapshotManager, writers
Constructor and Description |
---|
AppendOnlyFileStoreWrite(AppendOnlyFileStoreRead read,
long schemaId,
String commitUser,
org.apache.flink.table.types.logical.RowType rowType,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options) |
Modifier and Type | Method and Description |
---|---|
AbstractFileStoreWrite.WriterContainer<org.apache.flink.table.data.RowData> |
createEmptyWriterContainer(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
ExecutorService compactExecutor)
Create an empty
RecordWriter from partition and bucket. |
AbstractFileStoreWrite.WriterContainer<org.apache.flink.table.data.RowData> |
createWriterContainer(org.apache.flink.table.data.binary.BinaryRowData partition,
int bucket,
ExecutorService compactExecutor)
Create a
RecordWriter from partition and bucket. |
close, compact, notifyNewFiles, notifyNewWriter, prepareCommit, scanExistingFileMetas, withIOManager, withOverwrite, write
public AppendOnlyFileStoreWrite(AppendOnlyFileStoreRead read, long schemaId, String commitUser, org.apache.flink.table.types.logical.RowType rowType, FileStorePathFactory pathFactory, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options)
public AbstractFileStoreWrite.WriterContainer<org.apache.flink.table.data.RowData> createWriterContainer(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket, ExecutorService compactExecutor)
AbstractFileStoreWrite
RecordWriter
from partition and bucket.createWriterContainer
in class AbstractFileStoreWrite<org.apache.flink.table.data.RowData>
public AbstractFileStoreWrite.WriterContainer<org.apache.flink.table.data.RowData> createEmptyWriterContainer(org.apache.flink.table.data.binary.BinaryRowData partition, int bucket, ExecutorService compactExecutor)
AbstractFileStoreWrite
RecordWriter
from partition and bucket.createEmptyWriterContainer
in class AbstractFileStoreWrite<org.apache.flink.table.data.RowData>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.