Package | Description |
---|---|
org.apache.paimon.flink.sink | |
org.apache.paimon.memory | |
org.apache.paimon.operation | |
org.apache.paimon.operation.metrics | |
org.apache.paimon.table.sink |
Modifier and Type | Method and Description |
---|---|
StoreSinkWrite |
StoreSinkWrite.WithWriteBufferProvider.provide(FileStoreTable table,
String commitUser,
StoreSinkWriteState state,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
MemoryPoolFactory memoryPoolFactory,
org.apache.flink.metrics.MetricGroup metricGroup)
TODO: The argument list has become too complicated.
|
Constructor and Description |
---|
StoreSinkWriteImpl(FileStoreTable table,
String commitUser,
StoreSinkWriteState state,
org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
boolean ignorePreviousFiles,
boolean waitCompaction,
boolean isStreamingMode,
MemoryPoolFactory memoryPoolFactory,
org.apache.flink.metrics.MetricGroup metricGroup) |
Modifier and Type | Method and Description |
---|---|
MemoryPoolFactory |
MemoryPoolFactory.addOwners(Iterable<MemoryOwner> newOwners) |
Modifier and Type | Method and Description |
---|---|
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.withMemoryPoolFactory(MemoryPoolFactory memoryPoolFactory) |
Constructor and Description |
---|
WriterBufferMetric(java.util.function.Supplier<MemoryPoolFactory> memoryPoolFactorySupplier,
MetricRegistry metricRegistry,
String tableName) |
Modifier and Type | Method and Description |
---|---|
TableWriteImpl<T> |
TableWriteImpl.withMemoryPoolFactory(MemoryPoolFactory memoryPoolFactory) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.