Package | Description |
---|---|
org.apache.flink.table.store.file | |
org.apache.flink.table.store.file.operation | |
org.apache.flink.table.store.table.sink |
Modifier and Type | Method and Description |
---|---|
FileStoreExpire |
FileStore.newExpire() |
Modifier and Type | Class and Description |
---|---|
class |
FileStoreExpireImpl
Default implementation of
FileStoreExpire . |
Modifier and Type | Method and Description |
---|---|
FileStoreExpire |
FileStoreExpireImpl.withLock(Lock lock) |
FileStoreExpire |
FileStoreExpire.withLock(Lock lock)
With global lock.
|
Constructor and Description |
---|
TableCommit(FileStoreCommit commit,
FileStoreExpire expire,
PartitionExpire partitionExpire) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.