public class JavaStreamingTranslator extends PlanTranslator
PlanTranslator
for creating Table
s from Java DataStream
s and
translating them back to Java DataStream
s.
This is very limited right now. Only select and filter are implemented. Also, the expression operations must be extended to allow windowing operations.
Constructor and Description |
---|
JavaStreamingTranslator() |
Modifier and Type | Method and Description |
---|---|
<A> Table |
createTable(DataStream<A> repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields) |
<A> DataStream<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(DataStream<A> repr, CompositeType<A> inputType, Expression[] expressions, scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields)
public <A> DataStream<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.