public class JavaBatchTranslator extends PlanTranslator
Constructor and Description |
---|
JavaBatchTranslator() |
Modifier and Type | Method and Description |
---|---|
<A> Table |
createTable(DataSet<A> repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields) |
<A> DataSet<A> |
translate(PlanNode op,
TypeInformation<A> tpe)
Translates the given Table API
PlanNode back to the underlying representation, i.e,
a DataSet or a DataStream. |
createTable, createTable, createTable, createTable
public <A> Table createTable(DataSet<A> repr, CompositeType<A> inputType, Expression[] expressions, scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields)
public <A> DataSet<A> translate(PlanNode op, TypeInformation<A> tpe)
PlanTranslator
PlanNode
back to the underlying representation, i.e,
a DataSet or a DataStream.translate
in class PlanTranslator
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.