| Package | Description |
|---|---|
| org.wikimedia.eventutilities.flink.stream |
| Class and Description |
|---|
| EventDataStreamFactory
Wraps EventStreamFactory with Flink DataStream API to provide
helper methods to instantiate DataStream of Row using
EventStream JSONSchemas and other metadata.
|
| EventDataStreamFactory.Builder |
| FileSinkJsonRowEncoder
A
FileSink Encoder
that encodes event Rows to JSON strings. |
| SSESourceFunction
Server Sent Events (AKA EventSource) Flink SourceFunction.
|
Copyright © 2025. All rights reserved.