Package | Description |
---|---|
org.apache.flink.api.java.io.jdbc | |
org.apache.flink.api.java.typeutils | |
org.apache.flink.streaming.connectors.kafka |
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 |
---|---|
protected SerializationSchema<Row> |
KafkaTableSinkBase.createSerializationSchema(RowTypeInfo rowSchema)
Deprecated.
Use the constructor to pass a serialization schema instead.
|
protected SerializationSchema<Row> |
KafkaJsonTableSink.createSerializationSchema(RowTypeInfo rowSchema)
Deprecated.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.