Package | Description |
---|---|
org.wikimedia.eventutilities.flink.formats.json | |
org.wikimedia.eventutilities.flink.stream |
Modifier and Type | Method and Description |
---|---|
JsonRowDeserializationSchema |
JsonRowDeserializationSchema.Builder.build() |
static JsonRowDeserializationSchema |
JsonSchemaFlinkConverter.toDeserializationSchemaRow(com.fasterxml.jackson.databind.node.ObjectNode jsonSchema)
Gets a JSON deserializer to Row in hybrid named position mode for the jsonSchema.
|
Modifier and Type | Method and Description |
---|---|
JsonRowDeserializationSchema |
EventDataStreamFactory.deserializer(String streamName)
Gets a JSON to Row DeserializationSchema by streamName and its latest
schema version.
|
JsonRowDeserializationSchema |
EventDataStreamFactory.deserializer(String streamName,
String version)
Gets a JSON to Row DeserializationSchema by streamName.
|
Copyright © 2024. All rights reserved.