Package | Description |
---|---|
org.apache.flink.table.descriptors |
Modifier and Type | Method and Description |
---|---|
Schema |
Schema.field(String fieldName,
String fieldType)
Adds a field with the field name and the type string.
|
Schema |
Schema.field(String fieldName,
TypeInformation<?> fieldType)
Adds a field with the field name and the type information.
|
Schema |
Schema.from(String originFieldName)
Specifies the origin of the previously defined field.
|
Schema |
Schema.proctime()
Specifies the previously defined field as a processing-time attribute.
|
Schema |
Schema.rowtime(Rowtime rowtime)
Specifies the previously defined field as an event-time attribute.
|
Schema |
Schema.schema(TableSchema schema)
Sets the schema with field names and the types.
|
Modifier and Type | Method and Description |
---|---|
BatchTableDescriptor |
BatchTableDescriptor.withSchema(Schema schema) |
ConnectTableDescriptor |
ConnectTableDescriptor.withSchema(Schema schema)
Specifies the resulting table schema.
|
StreamTableDescriptor |
StreamTableDescriptor.withSchema(Schema schema) |
D |
SchematicDescriptor.withSchema(Schema schema)
Deprecated.
Specifies the resulting table schema.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.