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 |
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 abstract SerializationSchema<Row> |
KafkaTableSink.createSerializationSchema(RowTypeInfo rowSchema)
Create serialization schema for converting table rows into bytes.
|
protected SerializationSchema<Row> |
KafkaJsonTableSink.createSerializationSchema(RowTypeInfo rowSchema) |
Constructor and Description |
---|
JsonRowSerializationSchema(RowTypeInfo rowSchema)
Creates a JSON serialization schema for the given fields and types.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.