Package | Description |
---|---|
org.apache.flink.api.table |
Table API
This package contains the generic part of the Table API. |
org.apache.flink.api.table.codegen | |
org.apache.flink.api.table.runtime |
Modifier and Type | Method and Description |
---|---|
TableConfig |
TableConfig$.DEFAULT() |
static TableConfig |
TableConfig.DEFAULT() |
Constructor and Description |
---|
ExpressionCodeGenerator(scala.collection.Seq<scala.Tuple2<String,CompositeType<?>>> inputs,
ClassLoader cl,
TableConfig config) |
GenerateFilter(CompositeType<T> inputType,
Expression predicate,
ClassLoader cl,
TableConfig config) |
GenerateJoin(CompositeType<L> leftTypeInfo,
CompositeType<R> rightTypeInfo,
CompositeType<O> resultTypeInfo,
Expression predicate,
scala.collection.Seq<Expression> outputFields,
ClassLoader cl,
TableConfig config) |
GenerateResultAssembler(scala.collection.Seq<scala.Tuple2<String,CompositeType<?>>> inputs,
ClassLoader cl,
TableConfig config) |
GenerateSelect(CompositeType<I> inputTypeInfo,
CompositeType<O> resultTypeInfo,
scala.collection.Seq<Expression> outputFields,
ClassLoader cl,
TableConfig config) |
Constructor and Description |
---|
ExpressionFilterFunction(Expression predicate,
CompositeType<T> inputType,
TableConfig config) |
ExpressionJoinFunction(Expression predicate,
CompositeType<L> leftType,
CompositeType<R> rightType,
CompositeType<O> resultType,
scala.collection.Seq<Expression> outputFields,
TableConfig config) |
ExpressionSelectFunction(CompositeType<I> inputType,
CompositeType<O> resultType,
scala.collection.Seq<Expression> outputFields,
TableConfig config) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.