Package org.wikimedia.eventutilities.flink.stream

Class Summary

Class	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
EventTimeAssigner	Creates a flink TimestampAssigner that extracts the event time.
FileSinkJsonRowEncoder	A FileSink Encoder that encodes event Rows to JSON strings.
LineStreamFormat<T>	A reader format that reads text lines from a file, and uses the provided DeserializationSchema to deserialize them.
SSESourceFunction<T>	Server Sent Events (AKA EventSource) Flink SourceFunction.