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 |
---|---|
FileStoreCommit |
FileStore.newCommit(String commitUser) |
Modifier and Type | Class and Description |
---|---|
class |
FileStoreCommitImpl
Default implementation of
FileStoreCommit . |
Modifier and Type | Method and Description |
---|---|
FileStoreCommit |
FileStoreCommit.withCreateEmptyCommit(boolean createEmptyCommit) |
FileStoreCommit |
FileStoreCommitImpl.withCreateEmptyCommit(boolean createEmptyCommit) |
FileStoreCommit |
FileStoreCommit.withLock(Lock lock)
With global lock.
|
FileStoreCommit |
FileStoreCommitImpl.withLock(Lock lock) |
Constructor and Description |
---|
PartitionExpire(org.apache.flink.table.types.logical.RowType partitionType,
java.time.Duration expirationTime,
java.time.Duration checkInterval,
String timePattern,
String timeFormatter,
FileStoreScan scan,
FileStoreCommit commit) |
Constructor and Description |
---|
TableCommit(FileStoreCommit commit,
FileStoreExpire expire,
PartitionExpire partitionExpire) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.