Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.utils |
Modifier and Type | Method and Description |
---|---|
TableSchema.Builder |
TableSchema.Builder.add(TableColumn column)
Adds a
TableColumn to this builder. |
static TableSchema.Builder |
TableSchema.builder()
Deprecated.
|
TableSchema.Builder |
TableSchema.Builder.field(String name,
DataType dataType)
Add a field with name and data type.
|
TableSchema.Builder |
TableSchema.Builder.field(String name,
DataType dataType,
String expression)
Add a computed field which is generated by the given expression.
|
TableSchema.Builder |
TableSchema.Builder.field(String name,
TypeInformation<?> typeInfo)
Deprecated.
This method will be removed in future versions as it uses the old type
system. It is recommended to use
field(String, DataType) instead which uses
the new type system based on DataTypes . Please make sure to use either the
old or the new type system consistently to avoid unintended behavior. See the website
documentation for more information. |
TableSchema.Builder |
TableSchema.Builder.fields(String[] names,
DataType[] dataTypes)
Add an array of fields with names and data types.
|
TableSchema.Builder |
TableSchema.Builder.primaryKey(String... columns)
Creates a primary key constraint for a set of given columns.
|
TableSchema.Builder |
TableSchema.Builder.primaryKey(String name,
String[] columns)
Creates a primary key constraint for a set of given columns.
|
TableSchema.Builder |
TableSchema.Builder.watermark(String rowtimeAttribute,
String watermarkExpressionString,
DataType watermarkExprOutputType)
Specifies the previously defined field as an event-time attribute and specifies the
watermark strategy.
|
TableSchema.Builder |
TableSchema.Builder.watermark(WatermarkSpec watermarkSpec)
Adds the given
WatermarkSpec to this builder. |
Modifier and Type | Method and Description |
---|---|
static TableSchema.Builder |
TableSchemaUtils.builderWithGivenSchema(TableSchema oriSchema)
Creates a builder with given table schema.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.