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 © 2024. All rights reserved.