Package | Description |
---|---|
org.apache.flink.table.api |
Modifier and Type | Method and Description |
---|---|
static TableSchema.Builder |
TableSchema.builder() |
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.