public class ScalaStreamingTranslator extends PlanTranslator
PlanTranslator
for creating Table
s from Scala DataStream
s and
translating them back to Scala 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 |
---|
ScalaStreamingTranslator() |
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) |
<O> DataStream<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. |
createTable, createTable, createTable, createTable
public <O> DataStream<O> translate(PlanNode op, TypeInformation<O> tpe)
PlanTranslator
PlanNode
back to the underlying representation, i.e,
a DataSet or a DataStream.translate
in class PlanTranslator
public <A> Table createTable(DataStream<A> repr, CompositeType<A> inputType, Expression[] expressions, scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.