public class TableConversions extends Object
Table
into a DataSet
or a DataStream
.
param: table The table to convert.
Constructor and Description |
---|
TableConversions(Table table) |
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
toAppendStream(StreamQueryConfig queryConfig,
TypeInformation<T> evidence$5)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<T> |
toAppendStream(TypeInformation<T> evidence$4)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataSet<T> |
toDataSet(TypeInformation<T> evidence$1)
Converts the given
Table into a DataSet of a specified type. |
<T> DataStream<T> |
toDataStream(StreamQueryConfig queryConfig,
TypeInformation<T> evidence$3)
Deprecated.
This method only supports conversion of append-only tables. In order to make this more explicit in the future, please use toAppendStream() instead. Since .
|
<T> DataStream<T> |
toDataStream(TypeInformation<T> evidence$2)
Deprecated.
This method only supports conversion of append-only tables. In order to make this more explicit in the future, please use toAppendStream() instead. Since .
|
<T> DataStream<scala.Tuple2<Object,T>> |
toRetractStream(StreamQueryConfig queryConfig,
TypeInformation<T> evidence$7)
Converts the
Table to a DataStream of add and retract messages. |
<T> DataStream<scala.Tuple2<Object,T>> |
toRetractStream(TypeInformation<T> evidence$6)
Converts the
Table to a DataStream of add and retract messages. |
public TableConversions(Table table)
public <T> DataSet<T> toDataSet(TypeInformation<T> evidence$1)
Table
into a DataSet
of a specified type.
The fields of the Table
are mapped to DataSet
fields as follows:
- Row
and Tuple
types: Fields are mapped by position, field types must match.
- POJO DataSet
types: Fields are mapped by field name, field types must match.
evidence$1
- (undocumented)DataSet
.public <T> DataStream<T> toDataStream(TypeInformation<T> evidence$2)
Table
into an append DataStream
of a specified type.
The Table
must only have insert (append) changes. If the Table
is also modified
by update or delete changes, the conversion will fail.
The fields of the Table
are mapped to DataStream
fields as follows:
- Row
and Scala Tuple types: Fields are mapped by position, field
types must match.
- POJO DataStream
types: Fields are mapped by field name, field types must match.
NOTE: This method only supports conversion of append-only tables. In order to make this
more explicit in the future, please use toAppendStream()
instead.
If add and retract messages are required, use toRetractStream()
.
evidence$2
- (undocumented)DataStream
.public <T> DataStream<T> toDataStream(StreamQueryConfig queryConfig, TypeInformation<T> evidence$3)
Table
into an append DataStream
of a specified type.
The Table
must only have insert (append) changes. If the Table
is also modified
by update or delete changes, the conversion will fail.
The fields of the Table
are mapped to DataStream
fields as follows:
- Row
and Scala Tuple types: Fields are mapped by position, field
types must match.
- POJO DataStream
types: Fields are mapped by field name, field types must match.
NOTE: This method only supports conversion of append-only tables. In order to make this
more explicit in the future, please use toAppendStream()
instead.
If add and retract messages are required, use toRetractStream()
.
queryConfig
- The configuration of the query to generate.evidence$3
- (undocumented)DataStream
.public <T> DataStream<T> toAppendStream(TypeInformation<T> evidence$4)
Table
into an append DataStream
of a specified type.
The Table
must only have insert (append) changes. If the Table
is also modified
by update or delete changes, the conversion will fail.
The fields of the Table
are mapped to DataStream
fields as follows:
- Row
and Scala Tuple types: Fields are mapped by position, field
types must match.
- POJO DataStream
types: Fields are mapped by field name, field types must match.
evidence$4
- (undocumented)DataStream
.public <T> DataStream<T> toAppendStream(StreamQueryConfig queryConfig, TypeInformation<T> evidence$5)
Table
into an append DataStream
of a specified type.
The Table
must only have insert (append) changes. If the Table
is also modified
by update or delete changes, the conversion will fail.
The fields of the Table
are mapped to DataStream
fields as follows:
- Row
and Scala Tuple types: Fields are mapped by position, field
types must match.
- POJO DataStream
types: Fields are mapped by field name, field types must match.
queryConfig
- The configuration of the query to generate.evidence$5
- (undocumented)DataStream
.public <T> DataStream<scala.Tuple2<Object,T>> toRetractStream(TypeInformation<T> evidence$6)
Table
to a DataStream
of add and retract messages.
The message will be encoded as Tuple2
. The first field is a Boolean
flag,
the second field holds the record of the specified type T
.
A true Boolean
flag indicates an add message, a false flag indicates a retract message.
evidence$6
- (undocumented)public <T> DataStream<scala.Tuple2<Object,T>> toRetractStream(StreamQueryConfig queryConfig, TypeInformation<T> evidence$7)
Table
to a DataStream
of add and retract messages.
The message will be encoded as Tuple2
. The first field is a Boolean
flag,
the second field holds the record of the specified type T
.
A true Boolean
flag indicates an add message, a false flag indicates a retract message.
queryConfig
- The configuration for the generated query.
evidence$7
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.