Package | Description |
---|---|
org.apache.flink.table.store.connector.sink | |
org.apache.flink.table.store.file.operation | |
org.apache.flink.table.store.spark | |
org.apache.flink.table.store.table |
Modifier and Type | Method and Description |
---|---|
CompactorSinkBuilder |
CompactorSinkBuilder.withLockFactory(Lock.Factory lockFactory) |
FlinkSinkBuilder |
FlinkSinkBuilder.withLockFactory(Lock.Factory lockFactory) |
Constructor and Description |
---|
CompactorSink(FileStoreTable table,
Lock.Factory lockFactory) |
FileStoreSink(FileStoreTable table,
Lock.Factory lockFactory,
Map<String,String> overwritePartition,
LogSinkFunction logSinkFunction) |
Modifier and Type | Class and Description |
---|---|
static class |
Lock.CatalogLockFactory
A
Lock.Factory creating lock from catalog. |
static class |
Lock.EmptyFactory
A
Lock.Factory creating empty lock. |
Modifier and Type | Method and Description |
---|---|
static Lock.Factory |
Lock.emptyFactory() |
static Lock.Factory |
Lock.factory(CatalogLock.Factory lockFactory,
org.apache.flink.table.catalog.ObjectPath tablePath) |
Constructor and Description |
---|
SparkTable(Table table,
Lock.Factory lockFactory,
org.apache.flink.configuration.Configuration conf) |
SparkWrite(SupportsWrite table,
String queryId,
Lock.Factory lockFactory,
org.apache.flink.configuration.Configuration conf) |
SparkWriteBuilder(SupportsWrite table,
String queryId,
Lock.Factory lockFactory,
org.apache.flink.configuration.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
default void |
SupportsWrite.deleteWhere(String commitUser,
List<Predicate> filters,
Lock.Factory lockFactory) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.