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 |
---|---|
PartitionExpire |
AbstractFileStore.newPartitionExpire(String commitUser) |
PartitionExpire |
FileStore.newPartitionExpire(String commitUser) |
Modifier and Type | Method and Description |
---|---|
PartitionExpire |
PartitionExpire.withLock(Lock lock) |
Constructor and Description |
---|
TableCommit(FileStoreCommit commit,
FileStoreExpire expire,
PartitionExpire partitionExpire) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.