Package | Description |
---|---|
org.wikimedia.eventutilities.flink.formats.json | |
org.wikimedia.eventutilities.flink.stream |
Modifier and Type | Method and Description |
---|---|
JsonRowSerializationSchema |
JsonRowSerializationSchema.Builder.build()
Finalizes the configuration and checks validity.
|
Modifier and Type | Method and Description |
---|---|
JsonRowSerializationSchema |
EventDataStreamFactory.serializer(String streamName,
String version)
Create a
SerializationSchema suited for
producing json to the stream identified by streamName using the provided schema version. |
Copyright © 2024. All rights reserved.