Package | Description |
---|---|
org.apache.flink.table.store.file | |
org.apache.flink.table.store.file.operation | |
org.apache.flink.table.store.table.sink |
Modifier and Type | Method and Description |
---|---|
FileStoreWrite<T> |
FileStore.newWrite(String commitUser) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStoreWrite<T>
Base
FileStoreWrite implementation. |
class |
AppendOnlyFileStoreWrite
|
class |
KeyValueFileStoreWrite
|
class |
MemoryFileStoreWrite<T>
Base
FileStoreWrite implementation which supports using shared memory and preempting
memory from other writers. |
Modifier and Type | Method and Description |
---|---|
FileStoreWrite<T> |
FileStoreWrite.withIOManager(org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager) |
FileStoreWrite<T> |
AbstractFileStoreWrite.withIOManager(org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager) |
Constructor and Description |
---|
TableWriteImpl(FileStoreWrite<T> write,
SinkRecordConverter recordConverter,
TableWriteImpl.RecordExtractor<T> recordExtractor) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.