Modifier and Type | Method and Description |
---|---|
static RowTypeInfo |
Types.ROW_NAMED(String[] fieldNames,
TypeInformation<?>... types)
Generates a RowTypeInfo with fields of the given types and with given names.
|
static RowTypeInfo |
Types.ROW(TypeInformation<?>... types)
Generates a RowTypeInfo with fields of the given types.
|
Modifier and Type | Method and Description |
---|---|
RowTypeInfo |
JDBCInputFormat.getProducedType() |
Modifier and Type | Method and Description |
---|---|
JDBCInputFormat.JDBCInputFormatBuilder |
JDBCInputFormat.JDBCInputFormatBuilder.setRowTypeInfo(RowTypeInfo rowTypeInfo) |
Modifier and Type | Method and Description |
---|---|
static RowTypeInfo |
AggregateUtil.createAccumulatorRowType(AggregateFunction<?,?>[] aggregates) |
RowTypeInfo |
AggregateUtil$.createAccumulatorRowType(AggregateFunction<?,?>[] aggregates) |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple3<AggregateFunction<CRow,Row,Row>,RowTypeInfo,RowTypeInfo> |
AggregateUtil.createDataStreamAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupingKeys,
boolean needMerge) |
static scala.Tuple3<AggregateFunction<CRow,Row,Row>,RowTypeInfo,RowTypeInfo> |
AggregateUtil.createDataStreamAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupingKeys,
boolean needMerge) |
scala.Tuple3<AggregateFunction<CRow,Row,Row>,RowTypeInfo,RowTypeInfo> |
AggregateUtil$.createDataStreamAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupingKeys,
boolean needMerge) |
scala.Tuple3<AggregateFunction<CRow,Row,Row>,RowTypeInfo,RowTypeInfo> |
AggregateUtil$.createDataStreamAggregateFunction(CodeGenerator generator,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
scala.collection.Seq<TypeInformation<?>> inputFieldTypeInfo,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupingKeys,
boolean needMerge) |
Modifier and Type | Method and Description |
---|---|
RowTypeInfo |
CRowTypeInfo.rowType() |
Constructor and Description |
---|
CRowTypeInfo(RowTypeInfo rowType) |
Modifier and Type | Method and Description |
---|---|
RowTypeInfo |
CsvTableSource.getReturnType()
Returns the
RowTypeInfo for the return type of the CsvTableSource . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.