Modifier and Type | Method and Description |
---|---|
protected abstract AbstractDataType<?> |
DataTypes.AbstractField.getAbstractDataType() |
protected AbstractDataType<?> |
DataTypes.Field.getAbstractDataType() |
protected AbstractDataType<?> |
DataTypes.UnresolvedField.getAbstractDataType() |
AbstractDataType<?> |
Schema.UnresolvedPhysicalColumn.getDataType() |
AbstractDataType<?> |
Schema.UnresolvedMetadataColumn.getDataType() |
Modifier and Type | Method and Description |
---|---|
static UnresolvedDataType |
DataTypes.ARRAY(AbstractDataType<?> elementDataType)
Unresolved data type of an array of elements with same subtype.
|
Schema.Builder |
Schema.Builder.column(String columnName,
AbstractDataType<?> dataType)
Declares a physical 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.
|
static DataTypes.UnresolvedField |
DataTypes.FIELD(String name,
AbstractDataType<?> fieldDataType)
Unresolved field definition with field name and data type.
|
static DataTypes.UnresolvedField |
DataTypes.FIELD(String name,
AbstractDataType<?> fieldDataType,
String description)
Unresolved field definition with field name, unresolved data type, and a description.
|
Schema.Builder |
Schema.Builder.fromFields(String[] fieldNames,
AbstractDataType<?>[] fieldDataTypes)
Adopts the given field names and field data types as physical columns of the schema.
|
Table |
TableEnvironment.fromValues(AbstractDataType<?> rowType,
Expression... values)
Creates a Table from given collection of objects with a given row type.
|
Table |
TableEnvironment.fromValues(AbstractDataType<?> rowType,
Iterable<?> values)
Creates a Table from given collection of objects with a given row type.
|
default Table |
TableEnvironment.fromValues(AbstractDataType<?> rowType,
Object... values)
Creates a Table from given collection of objects with a given row type.
|
static UnresolvedDataType |
DataTypes.MAP(AbstractDataType<?> keyDataType,
AbstractDataType<?> valueDataType)
Unresolved data type of an associative array that maps keys (including
NULL ) to
values (including NULL ). |
static UnresolvedDataType |
DataTypes.MAP(AbstractDataType<?> keyDataType,
AbstractDataType<?> valueDataType)
Unresolved data type of an associative array that maps keys (including
NULL ) to
values (including NULL ). |
static UnresolvedDataType |
DataTypes.MULTISET(AbstractDataType<?> elementDataType)
Unresolved data type of a multiset (=bag).
|
static UnresolvedDataType |
DataTypes.ROW(AbstractDataType<?>... fieldDataTypes)
Data type of a sequence of fields.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
AbstractDataType<?> targetDataType)
|
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamTableEnvironmentImpl.toDataStream(Table table,
AbstractDataType<?> targetDataType) |
Modifier and Type | Method and Description |
---|---|
Table |
TableEnvironmentImpl.fromValues(AbstractDataType<?> rowType,
Expression... values) |
Table |
TableEnvironmentImpl.fromValues(AbstractDataType<?> rowType,
Iterable<?> values) |
Table |
TableEnvironmentImpl.fromValues(AbstractDataType<?> rowType,
Object... values) |
Modifier and Type | Method and Description |
---|---|
DataType |
DataTypeFactory.createDataType(AbstractDataType<?> abstractDataType)
Creates a type out of an
AbstractDataType . |
static SchemaTranslator.ProducingResult |
SchemaTranslator.createProducingResult(DataTypeFactory dataTypeFactory,
ResolvedSchema inputSchema,
AbstractDataType<?> targetDataType)
Converts the given
DataType into the final SchemaTranslator.ProducingResult . |
Modifier and Type | Interface and Description |
---|---|
interface |
AbstractDataType<T extends AbstractDataType<T>>
Highest abstraction that describes the data type of a value in the table ecosystem.
|
Modifier and Type | Class and Description |
---|---|
class |
AtomicDataType
A data type that does not contain further data types (e.g.
|
class |
CollectionDataType
A data type that contains an element type (e.g.
|
class |
DataType
Describes the data type of a value in the table ecosystem.
|
class |
FieldsDataType
A data type that contains field data types (i.e.
|
class |
KeyValueDataType
A data type that contains a key and value data type (e.g.
|
class |
UnresolvedDataType
Partially resolved data type that requires a lookup in a catalog or configuration before creating
the corresponding
LogicalType . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.