Package | Description |
---|---|
org.apache.flink.api.scala.table | |
org.apache.flink.api.table |
Modifier and Type | Method and Description |
---|---|
Table |
DataStreamConversions.toTable(StreamTableEnvironment tableEnv,
scala.collection.Seq<Expression> fields)
Converts the
DataStream into a Table . |
Modifier and Type | Method and Description |
---|---|
StreamTableEnvironment |
TableEnvironment$.getTableEnvironment(StreamExecutionEnvironment executionEnvironment)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
static StreamTableEnvironment |
TableEnvironment.getTableEnvironment(StreamExecutionEnvironment executionEnvironment)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
StreamTableEnvironment |
TableEnvironment$.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
static StreamTableEnvironment |
TableEnvironment.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.