Package | Description |
---|---|
org.wikimedia.eventutilities.flink.stream |
Modifier and Type | Method and Description |
---|---|
SSESourceFunction<org.apache.flink.types.Row> |
EventDataStreamFactory.sseSourceFunction(String streamName,
String uri)
Returns a SourceFunction that reads JSON event Rows from the SSE EventSource.
|
SSESourceFunction<org.apache.flink.types.Row> |
EventDataStreamFactory.sseSourceFunction(String streamName,
String schemaVersion,
String uri)
Returns a SourceFunction that reads JSON event Rows from the SSE EventSource.
|
Copyright © 2024. All rights reserved.