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 |
RowTypeInfo.projectFields(RowTypeInfo rowType,
int[] fieldMapping)
Creates a
RowTypeInfo with projected fields. |
Modifier and Type | Method and Description |
---|---|
static RowTypeInfo |
RowTypeInfo.projectFields(RowTypeInfo rowType,
int[] fieldMapping)
Creates a
RowTypeInfo with projected fields. |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema |
CsvRowSchemaConverter.convert(RowTypeInfo rowType)
Convert
RowTypeInfo to CsvSchema . |
Constructor and Description |
---|
ChangelogCollectStreamResult(RowTypeInfo outputType,
TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort) |
CollectStreamResult(RowTypeInfo outputType,
TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort) |
MaterializedCollectBatchResult(TableSchema tableSchema,
RowTypeInfo outputType,
ExecutionConfig config) |
MaterializedCollectStreamResult(RowTypeInfo outputType,
TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort,
int maxRowCount) |
MaterializedCollectStreamResult(RowTypeInfo outputType,
TableSchema tableSchema,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort,
int maxRowCount,
int overcommitThreshold) |
Modifier and Type | Method and Description |
---|---|
RowTypeInfo |
TemporalTableFunctionImpl.getResultType() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.