org.apache.flink.api.scala.table

Class ScalaBatchTranslator

java.lang.Object

org.apache.flink.api.table.plan.PlanTranslator

org.apache.flink.api.scala.table.ScalaBatchTranslator

public class ScalaBatchTranslator
extends PlanTranslator

PlanTranslator for creating Tables from Scala DataSets and translating them back to Scala DataSets.

Constructor Summary

Constructors

Constructor and Description
ScalaBatchTranslator()

Method Summary

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> Table	createTable(DataSet<A> repr, Expression[] fields)
<O> DataSet<O>	translate(PlanNode op, TypeInformation<O> tpe) Translates the given Table API PlanNode back to the underlying representation, i.e, a DataSet or a DataStream.

Methods inherited from class org.apache.flink.api.table.plan.PlanTranslator

createTable, createTable, createTable, createTable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScalaBatchTranslator

public ScalaBatchTranslator()

Method Detail

createTable

public <A> Table createTable(DataSet<A> repr,
                             Expression[] fields)

translate

public <O> DataSet<O> translate(PlanNode op,
                                TypeInformation<O> tpe)

Description copied from class: PlanTranslator

Translates the given Table API PlanNode back to the underlying representation, i.e, a DataSet or a DataStream.

Specified by:

translate in class PlanTranslator

createTable

public <A> Table createTable(DataSet<A> repr,
                             CompositeType<A> inputType,
                             Expression[] expressions,
                             scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields)