Package | Description |
---|---|
org.apache.paimon.flink.sink | |
org.apache.paimon.privilege | |
org.apache.paimon.table | |
org.apache.paimon.table.sink |
Modifier and Type | Field and Description |
---|---|
protected TableWriteImpl<?> |
StoreSinkWriteImpl.write |
Modifier and Type | Method and Description |
---|---|
TableWriteImpl<?> |
StoreSinkWriteImpl.getWrite() |
Modifier and Type | Method and Description |
---|---|
TableWriteImpl<?> |
PrivilegedFileStoreTable.newWrite(String commitUser) |
TableWriteImpl<?> |
PrivilegedFileStoreTable.newWrite(String commitUser,
ManifestCacheFilter manifestFilter) |
Modifier and Type | Method and Description |
---|---|
TableWriteImpl<?> |
FileStoreTable.newWrite(String commitUser) |
TableWriteImpl<?> |
DelegatedFileStoreTable.newWrite(String commitUser) |
TableWriteImpl<?> |
FileStoreTable.newWrite(String commitUser,
ManifestCacheFilter manifestFilter) |
TableWriteImpl<?> |
DelegatedFileStoreTable.newWrite(String commitUser,
ManifestCacheFilter manifestFilter) |
Modifier and Type | Method and Description |
---|---|
TableWriteImpl<T> |
TableWriteImpl.withBucketMode(BucketMode bucketMode) |
TableWriteImpl<T> |
TableWriteImpl.withCompactExecutor(ExecutorService compactExecutor) |
TableWriteImpl<T> |
TableWriteImpl.withExecutionMode(boolean isStreamingMode) |
TableWriteImpl<T> |
TableWriteImpl.withIgnorePreviousFiles(boolean ignorePreviousFiles) |
TableWriteImpl<T> |
TableWriteImpl.withIOManager(IOManager ioManager) |
TableWriteImpl<T> |
TableWriteImpl.withMemoryPool(MemorySegmentPool memoryPool) |
TableWriteImpl<T> |
TableWriteImpl.withMemoryPoolFactory(MemoryPoolFactory memoryPoolFactory) |
TableWriteImpl<T> |
TableWriteImpl.withMetricRegistry(MetricRegistry metricRegistry) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.