Uses of Class
org.wikimedia.eventutilities.flink.EventRowTypeInfo

Packages that use EventRowTypeInfo

Package	Description
org.wikimedia.eventutilities.flink
org.wikimedia.eventutilities.flink.formats.json
org.wikimedia.eventutilities.flink.stream

Uses of EventRowTypeInfo in org.wikimedia.eventutilities.flink

Methods in org.wikimedia.eventutilities.flink that return EventRowTypeInfo

Modifier and Type	Method and Description
static EventRowTypeInfo	EventRowTypeInfo.create(Map<String,String> aliasedRowKey, String[] fieldNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>... types)
static EventRowTypeInfo	EventRowTypeInfo.create(org.apache.flink.api.java.typeutils.RowTypeInfo info)
static EventRowTypeInfo	EventRowTypeInfo.create(org.apache.flink.api.java.typeutils.RowTypeInfo info, Map<String,String> aliasedRowKey)
static EventRowTypeInfo	EventRowTypeInfo.create(String[] fieldNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>... types)
EventRowTypeInfo	EventRowTypeInfo.keyTypeInfo() Return a TypeInfo representing the schema of Row keys.

Uses of EventRowTypeInfo in org.wikimedia.eventutilities.flink.formats.json

Methods in org.wikimedia.eventutilities.flink.formats.json that return EventRowTypeInfo

Modifier and Type	Method and Description
static EventRowTypeInfo	JsonSchemaFlinkConverter.toRowTypeInfo(com.fasterxml.jackson.databind.node.ObjectNode jsonSchema) Converts this JSONSchema to a Flink DataStream API EventRowTypeInfo, which is an instance of TypeInformation<Row>.
static EventRowTypeInfo	JsonSchemaFlinkConverter.toRowTypeInfo(com.fasterxml.jackson.databind.node.ObjectNode jsonSchema, com.fasterxml.jackson.databind.node.ObjectNode messageKeyFields) Converts this JSONSchema to a Flink DataStream API EventRowTypeInfo, with stream partitions keys extracted from messageKeyFields mappings.

Uses of EventRowTypeInfo in org.wikimedia.eventutilities.flink.stream

Methods in org.wikimedia.eventutilities.flink.stream that return EventRowTypeInfo

Modifier and Type	Method and Description
EventRowTypeInfo	EventDataStreamFactory.rowTypeInfo(String streamName) Gets the EventRowTypeInfo (which is a TypeInformation of Row) for the streamName.
EventRowTypeInfo	EventDataStreamFactory.rowTypeInfo(String streamName, String version) Gets the EventRowTypeInfo (which is a TypeInformation of Row) for the streamName and a particular schema version.