Package | Description |
---|---|
org.apache.flink.api.java.io | |
org.apache.flink.api.java.summarize.aggregation | |
org.apache.flink.api.java.typeutils | |
org.apache.flink.table.data.util |
Constructor and Description |
---|
TupleCsvInputFormat(Path filePath,
String lineDelimiter,
String fieldDelimiter,
TupleTypeInfoBase<OUT> tupleTypeInfo) |
TupleCsvInputFormat(Path filePath,
String lineDelimiter,
String fieldDelimiter,
TupleTypeInfoBase<OUT> tupleTypeInfo,
boolean[] includedFieldsMask) |
TupleCsvInputFormat(Path filePath,
String lineDelimiter,
String fieldDelimiter,
TupleTypeInfoBase<OUT> tupleTypeInfo,
int[] includedFieldsMask) |
TupleCsvInputFormat(Path filePath,
TupleTypeInfoBase<OUT> tupleTypeInfo) |
TupleCsvInputFormat(Path filePath,
TupleTypeInfoBase<OUT> tupleTypeInfo,
boolean[] includedFieldsMask) |
TupleCsvInputFormat(Path filePath,
TupleTypeInfoBase<OUT> tupleTypeInfo,
int[] includedFieldsMask) |
Modifier and Type | Method and Description |
---|---|
static <R extends Tuple> |
SummaryAggregatorFactory.create(TupleTypeInfoBase<?> inType) |
Modifier and Type | Class and Description |
---|---|
class |
RowTypeInfo
TypeInformation for Row . |
class |
TupleTypeInfo<T extends Tuple>
A
TypeInformation for the tuple types of the Java API. |
Constructor and Description |
---|
CaseClassConverter(TupleTypeInfoBase t,
DataType[] fieldTypes) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.