T
- type of record to write.public abstract class MemoryFileStoreWrite<T> extends AbstractFileStoreWrite<T>
FileStoreWrite
implementation which supports using shared memory and preempting
memory from other writers.AbstractFileStoreWrite.WriterContainer<T>
ioManager, snapshotManager, writers
Constructor and Description |
---|
MemoryFileStoreWrite(String commitUser,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options) |
Modifier and Type | Method and Description |
---|---|
protected void |
notifyNewWriter(RecordWriter<T> writer) |
close, compact, createEmptyWriterContainer, createWriterContainer, notifyNewFiles, prepareCommit, scanExistingFileMetas, withIOManager, withOverwrite, write
public MemoryFileStoreWrite(String commitUser, SnapshotManager snapshotManager, FileStoreScan scan, CoreOptions options)
protected void notifyNewWriter(RecordWriter<T> writer)
notifyNewWriter
in class AbstractFileStoreWrite<T>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.