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.codegen | |
org.apache.flink.api.table.expressions | |
org.apache.flink.api.table.expressions.analysis | |
org.apache.flink.api.table.parser | |
org.apache.flink.api.table.plan | |
org.apache.flink.api.table.runtime | |
org.apache.flink.api.table.typeinfo |
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) |
Modifier and Type | Method and Description |
---|---|
Expression |
ImplicitExpressionConversions.boolean2Literal(boolean bool) |
Expression |
ImplicitExpressionConversions.double2Literal(double d) |
Expression |
ImplicitExpressionConversions.WithOperations.expr() |
Expression |
ImplicitExpressionOperations.expr() |
Expression |
ImplicitExpressionConversions.float2Literal(float d) |
Expression |
ImplicitExpressionConversions.int2Literal(int i) |
Expression |
ImplicitExpressionConversions.long2Literal(long l) |
Expression |
ImplicitExpressionConversions.string2Literal(String str) |
Expression |
ImplicitExpressionConversions.symbol2FieldExpression(scala.Symbol sym) |
Modifier and Type | Method and Description |
---|---|
<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) |
Substring |
ImplicitExpressionOperations.substring(Expression beginIndex,
Expression endIndex) |
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 . |
Constructor and Description |
---|
WithOperations(Expression e) |
Modifier and Type | Method and Description |
---|---|
Table |
Table.filter(Expression predicate)
Filters out elements that don't pass the filter predicate.
|
Table |
Table.where(Expression predicate)
Filters out elements that don't pass the filter predicate.
|
Modifier and Type | Method and Description |
---|---|
Table |
Table.as(scala.collection.Seq<Expression> fields)
Renames the fields of the expression result.
|
Table |
Table.groupBy(scala.collection.Seq<Expression> fields)
Groups the elements on some grouping keys.
|
Table |
Table.select(scala.collection.Seq<Expression> fields)
Performs a selection operation.
|
Modifier and Type | Method and Description |
---|---|
protected ExpressionCodeGenerator.GeneratedExpression |
ExpressionCodeGenerator.generateExpression(Expression expr) |
protected ExpressionCodeGenerator.GeneratedExpression |
ExpressionCodeGenerator.generateExpressionInternal(Expression expr) |
Modifier and Type | Method and Description |
---|---|
<T> String |
GenerateResultAssembler.createResult(CompositeType<T> resultTypeInfo,
scala.collection.Seq<Expression> outputFields,
scala.Function1<String,String> result) |
Constructor and Description |
---|
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) |
Constructor and Description |
---|
GenerateJoin(CompositeType<L> leftTypeInfo,
CompositeType<R> rightTypeInfo,
CompositeType<O> resultTypeInfo,
Expression predicate,
scala.collection.Seq<Expression> outputFields,
ClassLoader cl,
TableConfig config) |
GenerateSelect(CompositeType<I> inputTypeInfo,
CompositeType<O> resultTypeInfo,
scala.collection.Seq<Expression> outputFields,
ClassLoader cl,
TableConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
Abs |
class |
Aggregation |
class |
And |
class |
Avg |
class |
BinaryArithmetic |
class |
BinaryComparison |
class |
BinaryExpression |
class |
BinaryPredicate |
class |
BitwiseAnd |
class |
BitwiseBinaryArithmetic |
class |
BitwiseNot |
class |
BitwiseOr |
class |
BitwiseXor |
class |
Cast |
class |
Count |
class |
Div |
class |
EqualTo |
class |
GreaterThan |
class |
GreaterThanOrEqual |
class |
IsNotNull |
class |
IsNull |
class |
LeafExpression |
class |
LessThan |
class |
LessThanOrEqual |
class |
Literal |
class |
Max |
class |
Min |
class |
Minus |
class |
Mod |
class |
Mul |
class |
Naming |
class |
NopExpression |
class |
Not |
class |
NotEqualTo |
class |
Or |
class |
Plus |
class |
ResolvedFieldReference |
class |
Substring |
class |
Sum |
class |
UnaryExpression |
class |
UnaryMinus |
class |
UnresolvedFieldReference |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<Expression> |
UnaryExpression.children() |
scala.collection.Seq<Expression> |
BinaryExpression.children() |
scala.collection.Seq<Expression> |
Substring.children() |
scala.collection.Seq<Expression> |
Min.getIntermediateFields() |
scala.collection.Seq<Expression> |
Sum.getIntermediateFields() |
scala.collection.Seq<Expression> |
Avg.getIntermediateFields() |
scala.collection.Seq<Expression> |
Count.getIntermediateFields() |
abstract scala.collection.Seq<Expression> |
Aggregation.getIntermediateFields() |
scala.collection.Seq<Expression> |
Max.getIntermediateFields() |
Modifier and Type | Method and Description |
---|---|
Expression |
Min.getFinalField(scala.collection.Seq<Expression> inputs) |
Expression |
Sum.getFinalField(scala.collection.Seq<Expression> inputs) |
Expression |
Avg.getFinalField(scala.collection.Seq<Expression> inputs) |
Expression |
Count.getFinalField(scala.collection.Seq<Expression> inputs) |
abstract Expression |
Aggregation.getFinalField(scala.collection.Seq<Expression> inputs) |
Expression |
Max.getFinalField(scala.collection.Seq<Expression> inputs) |
Modifier and Type | Method and Description |
---|---|
Expression |
TypeCheck.apply(Expression expr) |
Expression |
VerifyNoNestedAggregates.apply(Expression expr) |
Expression |
ResolveFieldReferences.apply(Expression expr) |
Expression |
InsertAutoCasts.apply(Expression expr) |
Expression |
VerifyNoAggregates.apply(Expression expr) |
Expression |
GroupByAnalyzer.CheckGroupExpression.apply(Expression expr) |
Expression |
VerifyBoolean.apply(Expression expr) |
Modifier and Type | Method and Description |
---|---|
scala.Tuple3<Expression,int[],int[]> |
ExtractEquiJoinFields$.apply(CompositeType<?> leftType,
CompositeType<?> rightType,
Expression predicate) |
static scala.Tuple3<Expression,int[],int[]> |
ExtractEquiJoinFields.apply(CompositeType<?> leftType,
CompositeType<?> rightType,
Expression predicate) |
scala.collection.Seq<Rule<Expression>> |
SelectionAnalyzer.rules() |
scala.collection.Seq<Rule<Expression>> |
PredicateAnalyzer.rules() |
scala.collection.Seq<Rule<Expression>> |
GroupByAnalyzer.rules() |
Modifier and Type | Method and Description |
---|---|
scala.Tuple3<Expression,int[],int[]> |
ExtractEquiJoinFields$.apply(CompositeType<?> leftType,
CompositeType<?> rightType,
Expression predicate) |
static scala.Tuple3<Expression,int[],int[]> |
ExtractEquiJoinFields.apply(CompositeType<?> leftType,
CompositeType<?> rightType,
Expression predicate) |
Expression |
TypeCheck.apply(Expression expr) |
Expression |
VerifyNoNestedAggregates.apply(Expression expr) |
Expression |
ResolveFieldReferences.apply(Expression expr) |
Expression |
InsertAutoCasts.apply(Expression expr) |
Expression |
VerifyNoAggregates.apply(Expression expr) |
Expression |
GroupByAnalyzer.CheckGroupExpression.apply(Expression expr) |
Expression |
VerifyBoolean.apply(Expression expr) |
Modifier and Type | Method and Description |
---|---|
static Expression |
ExpressionParser.parseExpression(String exprString) |
Expression |
ExpressionParser$.parseExpression(String exprString) |
Modifier and Type | Method and Description |
---|---|
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.abs() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.abs() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.alias() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.alias() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.as() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.as() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.atom() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.atom() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.avg() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.avg() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.binaryBitwise() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.binaryBitwise() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.boolLiteral() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.boolLiteral() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.cast() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.cast() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.comparison() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.comparison() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.count() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.count() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.equalTo() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.equalTo() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.expression() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.expression() |
static scala.util.parsing.combinator.Parsers.Parser<scala.collection.immutable.List<Expression>> |
ExpressionParser.expressionList() |
scala.util.parsing.combinator.Parsers.Parser<scala.collection.immutable.List<Expression>> |
ExpressionParser$.expressionList() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.fieldReference() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.fieldReference() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.greaterThan() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.greaterThan() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.greaterThanOrEqual() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.greaterThanOrEqual() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.isNotNull() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.isNotNull() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.isNull() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.isNull() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.lessThan() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.lessThan() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.lessThanOrEqual() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.lessThanOrEqual() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.literalExpr() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.literalExpr() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.logic() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.logic() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.max() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.max() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.min() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.min() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.notEqualTo() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.notEqualTo() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.numberLiteral() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.numberLiteral() |
static scala.collection.immutable.List<Expression> |
ExpressionParser.parseExpressionList(String expression) |
scala.collection.immutable.List<Expression> |
ExpressionParser$.parseExpressionList(String expression) |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.product() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.product() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.singleQuoteStringLiteral() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.singleQuoteStringLiteral() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.stringLiteralFlink() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.stringLiteralFlink() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.substring() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.substring() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.substringWithoutEnd() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.substringWithoutEnd() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.suffix() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.suffix() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.sum() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.sum() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.term() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.term() |
static scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser.unary() |
scala.util.parsing.combinator.Parsers.Parser<Expression> |
ExpressionParser$.unary() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryBitwiseNot() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryBitwiseNot() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryMinus() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryMinus() |
static scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser.unaryNot() |
scala.util.parsing.combinator.PackratParsers.PackratParser<Expression> |
ExpressionParser$.unaryNot() |
Modifier and Type | Method and Description |
---|---|
Expression |
Filter.predicate() |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<Expression> |
GroupBy.fields() |
scala.collection.Seq<Expression> |
Select.selection() |
Modifier and Type | Method and Description |
---|---|
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. |
Constructor and Description |
---|
Filter(PlanNode input,
Expression predicate) |
Constructor and Description |
---|
GroupBy(PlanNode input,
scala.collection.Seq<Expression> fields) |
Select(PlanNode input,
scala.collection.Seq<Expression> selection) |
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) |
Constructor and Description |
---|
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) |
Constructor and Description |
---|
RowTypeInfo(scala.collection.Seq<Expression> fields) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.