Modifier and Type | Method and Description |
---|---|
static void |
CoreOptions.validateTableSchema(TableSchema schema)
Validate the
TableSchema and CoreOptions . |
Constructor and Description |
---|
BucketStreamPartitioner(TableSchema schema) |
Modifier and Type | Method and Description |
---|---|
TableSchema |
FileSystemCatalog.getTableSchema(org.apache.flink.table.catalog.ObjectPath tablePath) |
TableSchema |
Catalog.getTableSchema(org.apache.flink.table.catalog.ObjectPath tablePath)
Return a
TableSchema identified by the given ObjectPath . |
Modifier and Type | Method and Description |
---|---|
protected TableSchema |
AbstractFileStoreScan.scanTableSchema()
Note: Keep this thread-safe.
|
protected TableSchema |
AbstractFileStoreScan.scanTableSchema(long id)
Note: Keep this thread-safe.
|
Modifier and Type | Method and Description |
---|---|
TableSchema |
SchemaManager.commitChanges(List<SchemaChange> changes)
Create
SchemaChange s. |
TableSchema |
SchemaManager.commitNewVersion(UpdateSchema updateSchema)
Create a new schema from
UpdateSchema . |
TableSchema |
TableSchema.copy(Map<String,String> newOptions) |
TableSchema |
SchemaSerializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode node) |
TableSchema |
SchemaManager.schema(long id)
Read schema for schema id.
|
Modifier and Type | Method and Description |
---|---|
Optional<TableSchema> |
SchemaManager.latest() |
List<TableSchema> |
SchemaManager.listAll()
List all schema.
|
Modifier and Type | Method and Description |
---|---|
List<DataField> |
KeyValueFieldsExtractor.keyFields(TableSchema schema)
Extract key fields from table schema.
|
void |
SchemaSerializer.serialize(TableSchema tableSchema,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator generator) |
List<DataField> |
KeyValueFieldsExtractor.valueFields(TableSchema schema)
Extract value fields from table schema.
|
Modifier and Type | Method and Description |
---|---|
BulkFormatMapping |
BulkFormatMapping.BulkFormatMappingBuilder.build(TableSchema tableSchema,
TableSchema dataSchema) |
Modifier and Type | Method and Description |
---|---|
TableSchema |
HiveCatalog.getTableSchema(org.apache.flink.table.catalog.ObjectPath tablePath) |
Modifier and Type | Field and Description |
---|---|
protected TableSchema |
AbstractFileStoreTable.tableSchema |
Modifier and Type | Method and Description |
---|---|
TableSchema |
FileStoreTable.schema() |
TableSchema |
AbstractFileStoreTable.schema() |
Modifier and Type | Method and Description |
---|---|
protected FileStoreTable |
ChangelogValueCountFileStoreTable.copy(TableSchema newTableSchema) |
protected FileStoreTable |
AppendOnlyFileStoreTable.copy(TableSchema newTableSchema) |
protected FileStoreTable |
ChangelogWithKeyFileStoreTable.copy(TableSchema newTableSchema) |
protected abstract FileStoreTable |
AbstractFileStoreTable.copy(TableSchema newTableSchema) |
static FileStoreTable |
FileStoreTableFactory.create(org.apache.flink.core.fs.Path tablePath,
TableSchema tableSchema) |
static FileStoreTable |
FileStoreTableFactory.create(org.apache.flink.core.fs.Path tablePath,
TableSchema tableSchema,
org.apache.flink.configuration.Configuration dynamicOptions) |
Constructor and Description |
---|
AbstractFileStoreTable(org.apache.flink.core.fs.Path path,
TableSchema tableSchema) |
Constructor and Description |
---|
BucketComputer(TableSchema tableSchema) |
SinkRecordConverter(TableSchema tableSchema) |
Constructor and Description |
---|
AbstractDataTableScan(FileStoreScan scan,
TableSchema tableSchema,
FileStorePathFactory pathFactory,
CoreOptions options) |
Modifier and Type | Method and Description |
---|---|
static void |
ContinuousDataFileSnapshotEnumerator.validate(TableSchema schema) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.