Package | Description |
---|---|
org.apache.paimon.table.sink |
Modifier and Type | Interface and Description |
---|---|
interface |
BatchTableWrite
A
TableWrite for batch processing. |
interface |
InnerTableWrite
Inner
TableWrite contains overwrite setter. |
interface |
StreamTableWrite
A
TableWrite for stream processing. |
Modifier and Type | Class and Description |
---|---|
class |
TableWriteImpl<T>
TableWrite implementation. |
Modifier and Type | Method and Description |
---|---|
TableWrite |
WriteBuilder.newWrite()
Create a
TableWrite to write InternalRow s. |
TableWrite |
TableWrite.withIOManager(IOManager ioManager)
With
IOManager , this is needed if 'write-buffer-spillable' is set to true. |
TableWrite |
TableWrite.withMemoryPool(MemorySegmentPool memoryPool)
With
MemorySegmentPool for the current table write. |
TableWrite |
TableWrite.withMetricRegistry(MetricRegistry registry)
With metrics to measure compaction.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.