Package | Description |
---|---|
org.apache.flink.table.api |
Modifier and Type | Method and Description |
---|---|
Schema.Builder |
Schema.Builder.column(String columnName,
AbstractDataType<?> dataType)
Declares a physical column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.column(String columnName,
String serializableTypeString)
Declares a physical column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.columnByExpression(String columnName,
Expression expression)
Declares a computed column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.columnByExpression(String columnName,
String sqlExpression)
Declares a computed column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.columnByMetadata(String columnName,
AbstractDataType<?> dataType)
Declares a metadata column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.columnByMetadata(String columnName,
AbstractDataType<?> dataType,
boolean isVirtual)
Declares a metadata column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.columnByMetadata(String columnName,
AbstractDataType<?> dataType,
String metadataKey)
Declares a metadata column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.columnByMetadata(String columnName,
AbstractDataType<?> dataType,
String metadataKey,
boolean isVirtual)
Declares a metadata column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.columnByMetadata(String columnName,
String serializableTypeString)
Declares a metadata column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.columnByMetadata(String columnName,
String serializableTypeString,
String metadataKey,
boolean isVirtual)
Declares a metadata column that is appended to this schema.
|
Schema.Builder |
Schema.Builder.fromColumns(List<Schema.UnresolvedColumn> unresolvedColumns)
Adopts all columns from the given list.
|
Schema.Builder |
Schema.Builder.fromFields(List<String> fieldNames,
List<? extends AbstractDataType<?>> fieldDataTypes)
Adopts the given field names and field data types as physical columns of the schema.
|
Schema.Builder |
Schema.Builder.fromFields(String[] fieldNames,
AbstractDataType<?>[] fieldDataTypes)
Adopts the given field names and field data types as physical columns of the schema.
|
Schema.Builder |
Schema.Builder.fromResolvedSchema(ResolvedSchema resolvedSchema)
Adopts all members from the given resolved schema.
|
Schema.Builder |
Schema.Builder.fromRowDataType(DataType dataType)
Adopts all fields of the given row as physical columns of the schema.
|
Schema.Builder |
Schema.Builder.fromSchema(Schema unresolvedSchema)
Adopts all members from the given unresolved schema.
|
static Schema.Builder |
Schema.newBuilder()
Builder for configuring and creating instances of
Schema . |
Schema.Builder |
Schema.Builder.primaryKey(List<String> columnNames)
Declares a primary key constraint for a set of given columns.
|
Schema.Builder |
Schema.Builder.primaryKey(String... columnNames)
Declares a primary key constraint for a set of given columns.
|
Schema.Builder |
Schema.Builder.primaryKeyNamed(String constraintName,
List<String> columnNames)
Declares a primary key constraint for a set of given columns.
|
Schema.Builder |
Schema.Builder.primaryKeyNamed(String constraintName,
String... columnNames)
Declares a primary key constraint for a set of given columns.
|
Schema.Builder |
Schema.Builder.watermark(String columnName,
Expression watermarkExpression)
Declares that the given column should serve as an event-time (i.e.
|
Schema.Builder |
Schema.Builder.watermark(String columnName,
String sqlExpression)
Declares that the given column should serve as an event-time (i.e.
|
Schema.Builder |
Schema.Builder.withComment(String comment)
Apply comment to the previous column.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.