public class TableSchema extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static String |
KEY_FIELD_PREFIX
System field names.
|
static List<Class<? extends org.apache.flink.table.types.logical.LogicalType>> |
PRIMARY_KEY_UNSUPPORTED_LOGICAL_TYPES |
static String |
SEQUENCE_NUMBER |
static List<String> |
SYSTEM_FIELD_NAMES |
static String |
VALUE_COUNT |
static String |
VALUE_KIND |
Constructor and Description |
---|
TableSchema(long id,
List<DataField> fields,
int highestFieldId,
List<String> partitionKeys,
List<String> primaryKeys,
Map<String,String> options,
String comment) |
Modifier and Type | Method and Description |
---|---|
String |
comment() |
TableSchema |
copy(Map<String,String> newOptions) |
static int |
currentHighestFieldId(List<DataField> fields) |
boolean |
equals(Object o) |
List<String> |
fieldNames() |
List<DataField> |
fields() |
int |
hashCode() |
int |
highestFieldId() |
long |
id() |
org.apache.flink.table.types.logical.RowType |
logicalBucketKeyType() |
org.apache.flink.table.types.logical.RowType |
logicalPartitionType() |
org.apache.flink.table.types.logical.RowType |
logicalRowType() |
org.apache.flink.table.types.logical.RowType |
logicalTrimmedPrimaryKeysType() |
static List<DataField> |
newFields(org.apache.flink.table.types.logical.RowType rowType) |
Map<String,String> |
options() |
List<String> |
originalBucketKeys()
Original bucket keys, maybe empty.
|
List<String> |
partitionKeys() |
List<String> |
primaryKeys() |
int[] |
projection(List<String> projectedFieldNames) |
static DataType |
toDataType(org.apache.flink.table.types.logical.LogicalType type,
AtomicInteger currentHighestFieldId) |
String |
toString() |
UpdateSchema |
toUpdateSchema() |
List<String> |
trimmedPrimaryKeys() |
List<DataField> |
trimmedPrimaryKeysFields() |
public static final String KEY_FIELD_PREFIX
public static final String VALUE_COUNT
public static final String SEQUENCE_NUMBER
public static final String VALUE_KIND
public long id()
public int highestFieldId()
public String comment()
public org.apache.flink.table.types.logical.RowType logicalRowType()
public org.apache.flink.table.types.logical.RowType logicalPartitionType()
public org.apache.flink.table.types.logical.RowType logicalBucketKeyType()
public org.apache.flink.table.types.logical.RowType logicalTrimmedPrimaryKeysType()
public TableSchema copy(Map<String,String> newOptions)
public UpdateSchema toUpdateSchema()
public static List<DataField> newFields(org.apache.flink.table.types.logical.RowType rowType)
public static DataType toDataType(org.apache.flink.table.types.logical.LogicalType type, AtomicInteger currentHighestFieldId)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.