Package | Description |
---|---|
org.apache.flink.api.java.table | |
org.apache.flink.api.scala.table | |
org.apache.flink.api.table |
Table API
This package contains the generic part of the Table API. |
org.apache.flink.api.table.plan |
Modifier and Type | Method and Description |
---|---|
<A> Table |
JavaBatchTranslator.createTable(DataSet<A> repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields) |
<A> Table |
JavaStreamingTranslator.createTable(DataStream<A> repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields) |
<T> Table |
TableEnvironment.fromDataSet(DataSet<T> set)
Transforms the given DataSet to a
Table . |
<T> Table |
TableEnvironment.fromDataSet(DataSet<T> set,
String fields)
Transforms the given DataSet to a
Table . |
<T> Table |
TableEnvironment.fromDataStream(DataStream<T> set)
Transforms the given DataStream to a
Table . |
<T> Table |
TableEnvironment.fromDataStream(DataStream<T> set,
String fields)
Transforms the given DataStream to a
Table . |
Modifier and Type | Method and Description |
---|---|
<T> DataSet<T> |
TableEnvironment.toDataSet(Table table,
Class<T> clazz)
Converts the given
Table to
a DataSet. |
<T> DataStream<T> |
TableEnvironment.toDataStream(Table table,
Class<T> clazz)
Converts the given
Table to
a DataStream. |
Modifier and Type | Method and Description |
---|---|
Table |
DataSetConversions.as(scala.collection.Seq<Expression> fields)
Converts the
DataSet to a Table . |
Table |
DataStreamConversions.as(scala.collection.Seq<Expression> fields)
Converts the
DataStream to a Table . |
<A> Table |
ScalaBatchTranslator.createTable(DataSet<A> repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields) |
<A> Table |
ScalaBatchTranslator.createTable(DataSet<A> repr,
Expression[] fields) |
<A> Table |
ScalaStreamingTranslator.createTable(DataStream<A> repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields) |
Table |
DataSetConversions.toTable()
Converts the
DataSet to a Table . |
Table |
DataStreamConversions.toTable()
Converts the
DataStream to a Table . |
Constructor and Description |
---|
TableConversions(Table table) |
Modifier and Type | Method and Description |
---|---|
Table |
Table.as(scala.collection.Seq<Expression> fields)
Renames the fields of the expression result.
|
Table |
Table.as(String fields)
Renames the fields of the expression result.
|
Table |
Table.filter(Expression predicate)
Filters out elements that don't pass the filter predicate.
|
Table |
Table.filter(String predicate)
Filters out elements that don't pass the filter predicate.
|
Table |
Table.groupBy(scala.collection.Seq<Expression> fields)
Groups the elements on some grouping keys.
|
Table |
Table.groupBy(String fields)
Groups the elements on some grouping keys.
|
Table |
Table.join(Table right)
Joins two
Table s. |
Table |
Table.select(scala.collection.Seq<Expression> fields)
Performs a selection operation.
|
Table |
Table.select(String fields)
Performs a selection operation.
|
Table |
Table.unionAll(Table right)
Union two
Table s. |
Table |
Table.where(Expression predicate)
Filters out elements that don't pass the filter predicate.
|
Table |
Table.where(String predicate)
Filters out elements that don't pass the filter predicate.
|
Modifier and Type | Method and Description |
---|---|
Table |
Table.join(Table right)
Joins two
Table s. |
Table |
Table.unionAll(Table right)
Union two
Table s. |
Modifier and Type | Method and Description |
---|---|
<A> Table |
PlanTranslator.createTable(Object repr)
Creates a
Table from the given DataSet or DataStream. |
abstract <A> Table |
PlanTranslator.createTable(Object repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields)
Creates a
Table from a DataSet or a DataStream (the underlying representation). |
<A> Table |
PlanTranslator.createTable(Object repr,
Expression[] fields,
boolean checkDeterministicFields)
Creates a
Table from the given DataSet or DataStream while only taking those
fields mentioned in the fields parameter. |
<A> Table |
PlanTranslator.createTable(Object repr,
String expression)
Creates a
Table from the given DataSet or DataStream while only taking those
fields mentioned in the field expression. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.