public abstract class PlanTranslator extends Object
Table
to an executable
Flink plan and also for creating a Table
from a DataSet or DataStream.Constructor and Description |
---|
PlanTranslator() |
Modifier and Type | Method and Description |
---|---|
<A> Table |
createTable(Object repr)
Creates a
Table from the given DataSet or DataStream. |
abstract <A> Table |
createTable(Object repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields)
Creates a
Table from a DataSet or a DataStream (the underlying representation). |
<A> Table |
createTable(Object repr,
Expression[] fields,
boolean checkDeterministicFields)
Creates a
Table from the given DataSet or DataStream while only taking those
fields mentioned in the fields parameter. |
<A> Table |
createTable(Object repr,
String expression)
Creates a
Table from the given DataSet or DataStream while only taking those
fields mentioned in the field expression. |
abstract <A> Object |
translate(PlanNode op,
TypeInformation<A> tpe)
Translates the given Table API
PlanNode back to the underlying representation, i.e,
a DataSet or a DataStream. |
public abstract <A> Object translate(PlanNode op, TypeInformation<A> tpe)
PlanNode
back to the underlying representation, i.e,
a DataSet or a DataStream.public abstract <A> Table createTable(Object repr, CompositeType<A> inputType, Expression[] expressions, scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields)
Table
from a DataSet or a DataStream (the underlying representation).public <A> Table createTable(Object repr)
Table
from the given DataSet or DataStream.public <A> Table createTable(Object repr, String expression)
Table
from the given DataSet or DataStream while only taking those
fields mentioned in the field expression.public <A> Table createTable(Object repr, Expression[] fields, boolean checkDeterministicFields)
Table
from the given DataSet or DataStream while only taking those
fields mentioned in the fields parameter.
When checkDeterministicFields is true check whether the fields of the underlying
TypeInformation
have a deterministic ordering. This is only the case for Tuples
and Case classes. For a POJO, the field order is not obvious, this can lead to problems
when a user renames fields and assumes a certain ordering.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.