Package | Description |
---|---|
org.apache.paimon.flink.lookup | |
org.apache.paimon.operation | |
org.apache.paimon.table.sink | |
org.apache.paimon.table.source |
Modifier and Type | Class and Description |
---|---|
class |
LookupDataTableScan
StreamTableScan implementation for lookup streaming
planning. |
Modifier and Type | Interface and Description |
---|---|
interface |
BundleFileStoreWriter
Whether the writer could write bundle.
|
interface |
FileStoreWrite<T>
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStoreWrite<T>
Base
FileStoreWrite implementation. |
class |
AppendOnlyFileStoreWrite
|
class |
AppendOnlyFixedBucketFileStoreWrite
|
class |
AppendOnlyUnawareBucketFileStoreWrite
|
class |
KeyValueFileStoreWrite
|
class |
MemoryFileStoreWrite<T>
Base
FileStoreWrite implementation which supports using shared memory and preempting
memory from other writers. |
Modifier and Type | Class and Description |
---|---|
class |
TableWriteImpl<T>
TableWrite implementation. |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamDataTableScan
Streaming
InnerTableScan with StreamTableScan . |
interface |
StreamTableScan
TableScan for streaming, supports StreamTableScan.checkpoint() and StreamTableScan.restore(java.lang.Long) . |
Modifier and Type | Class and Description |
---|---|
class |
DataTableStreamScan
StreamTableScan implementation for streaming planning. |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.