Modifier and Type | Method and Description |
---|---|
static SingleInputSemanticProperties |
SemanticPropUtil.createProjectionPropertiesSingle(int[] fields,
CompositeType<?> inType) |
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 | Class and Description |
---|---|
class |
AvroTypeInfo<T extends org.apache.avro.specific.SpecificRecordBase>
Special type information to generate a special AvroTypeInfo for Avro POJOs (implementing SpecificRecordBase, the typed Avro POJOs)
Proceeding: It uses a regular pojo type analysis and replaces all
GenericType<CharSequence>
with a GenericType<avro.Utf8> . |
class |
PojoTypeInfo<T>
TypeInformation for "Java Beans"-style types.
|
class |
TupleTypeInfo<T extends Tuple>
A
TypeInformation for the tuple types of the Java API. |
class |
TupleTypeInfoBase<T> |
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 |
ScalaStreamingTranslator.createTable(DataStream<A> repr,
CompositeType<A> inputType,
Expression[] expressions,
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> resultFields) |
Constructor and Description |
---|
DataSetConversions(DataSet<T> set,
CompositeType<T> inputType) |
DataStreamConversions(DataStream<T> stream,
CompositeType<T> inputType) |
Modifier and Type | Class and Description |
---|---|
class |
CaseClassTypeInfo<T extends scala.Product>
TypeInformation for Case Classes.
|
Modifier and Type | Method and Description |
---|---|
<T> String |
GenerateResultAssembler.createResult(CompositeType<T> resultTypeInfo,
scala.collection.Seq<Expression> outputFields,
scala.Function1<String,String> result) |
org.apache.flink.api.table.codegen.ExpressionCodeGenerator.FieldAccessor |
ExpressionCodeGenerator.fieldAccessorFor(CompositeType<?> elementType,
String fieldName) |
protected String |
ExpressionCodeGenerator.getField(scala.reflect.runtime.universe inputTerm,
CompositeType<?> inputType,
String fieldName,
TypeInformation<?> fieldType) |
<A> String |
GenerateResultAssembler.reuseCode(CompositeType<A> resultTypeInfo) |
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) |
GenerateJoin(CompositeType<L> leftTypeInfo,
CompositeType<R> rightTypeInfo,
CompositeType<O> resultTypeInfo,
Expression predicate,
scala.collection.Seq<Expression> outputFields,
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) |
GenerateSelect(CompositeType<I> inputTypeInfo,
CompositeType<O> resultTypeInfo,
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) |
Constructor and Description |
---|
ExpressionCodeGenerator(scala.collection.Seq<scala.Tuple2<String,CompositeType<?>>> inputs,
ClassLoader cl,
TableConfig config) |
GenerateResultAssembler(scala.collection.Seq<scala.Tuple2<String,CompositeType<?>>> inputs,
ClassLoader cl,
TableConfig config) |
Modifier and Type | Method and Description |
---|---|
scala.Tuple3<Expression,int[],int[]> |
ExtractEquiJoinFields$.apply(CompositeType<?> leftType,
CompositeType<?> rightType,
Expression predicate) |
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) |
static scala.Tuple3<Expression,int[],int[]> |
ExtractEquiJoinFields.apply(CompositeType<?> leftType,
CompositeType<?> rightType,
Expression predicate) |
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). |
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) |
ExpressionJoinFunction(Expression predicate,
CompositeType<L> leftType,
CompositeType<R> rightType,
CompositeType<O> resultType,
scala.collection.Seq<Expression> outputFields,
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) |
ExpressionSelectFunction(CompositeType<I> inputType,
CompositeType<O> resultType,
scala.collection.Seq<Expression> outputFields,
TableConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
RenamingProxyTypeInfo<T>
A TypeInformation that is used to rename fields of an underlying CompositeType.
|
class |
RowTypeInfo
TypeInformation for
Row . |
Modifier and Type | Method and Description |
---|---|
CompositeType<T> |
RenamingProxyTypeInfo.getUnderlyingType() |
CompositeType<T> |
RenamingProxyTypeInfo.tpe() |
Constructor and Description |
---|
RenamingProxyTypeInfo(CompositeType<T> tpe,
String[] fieldNames) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.