Package | Description |
---|---|
org.apache.paimon | |
org.apache.paimon.operation | |
org.apache.paimon.privilege | |
org.apache.paimon.table.sink |
Modifier and Type | Method and Description |
---|---|
FileStoreWrite<T> |
FileStore.newWrite(String commitUser) |
FileStoreWrite<T> |
FileStore.newWrite(String commitUser,
ManifestCacheFilter manifestFilter) |
Modifier and Type | Interface and Description |
---|---|
interface |
BundleFileStoreWriter
Whether the writer could write bundle.
|
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(IOManager ioManager) |
FileStoreWrite<T> |
AbstractFileStoreWrite.withIOManager(IOManager ioManager) |
default FileStoreWrite<T> |
FileStoreWrite.withMemoryPool(MemorySegmentPool memoryPool)
With memory pool for the current file store write.
|
FileStoreWrite<T> |
MemoryFileStoreWrite.withMemoryPoolFactory(MemoryPoolFactory memoryPoolFactory) |
FileStoreWrite<T> |
FileStoreWrite.withMemoryPoolFactory(MemoryPoolFactory memoryPoolFactory)
With memory pool factory for the current file store write.
|
FileStoreWrite<T> |
AbstractFileStoreWrite.withMemoryPoolFactory(MemoryPoolFactory memoryPoolFactory) |
FileStoreWrite<T> |
MemoryFileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry) |
FileStoreWrite<T> |
FileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry)
With metrics to measure compaction.
|
FileStoreWrite<T> |
AbstractFileStoreWrite.withMetricRegistry(MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
FileStoreWrite<T> |
PrivilegedFileStore.newWrite(String commitUser) |
FileStoreWrite<T> |
PrivilegedFileStore.newWrite(String commitUser,
ManifestCacheFilter manifestFilter) |
Modifier and Type | Method and Description |
---|---|
FileStoreWrite<T> |
TableWriteImpl.getWrite() |
Constructor and Description |
---|
TableWriteImpl(RowType rowType,
FileStoreWrite<T> write,
KeyAndBucketExtractor<InternalRow> keyAndBucketExtractor,
TableWriteImpl.RecordExtractor<T> recordExtractor,
RowKindGenerator rowKindGenerator,
boolean ignoreDelete) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.