Package | Description |
---|---|
org.apache.flink.table.store.spark | |
org.apache.flink.table.store.table |
Constructor and Description |
---|
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 | Interface and Description |
---|---|
interface |
FileStoreTable
An abstraction layer above
FileStore to provide reading
and writing of RowData . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStoreTable
Abstract
FileStoreTable . |
class |
AppendOnlyFileStoreTable
FileStoreTable for WriteMode.APPEND_ONLY write mode. |
class |
ChangelogValueCountFileStoreTable
FileStoreTable for WriteMode.CHANGE_LOG write mode without primary keys. |
class |
ChangelogWithKeyFileStoreTable
FileStoreTable for WriteMode.CHANGE_LOG write mode with primary keys. |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.