Package | Description |
---|---|
org.wikimedia.eventutilities.flink.stream |
Modifier and Type | Method and Description |
---|---|
FileSinkJsonRowEncoder |
EventDataStreamFactory.fileSinkEncoder(String streamName,
String schemaVersion)
A Row to JSON string Encoder for use with FileSinks.
|
Copyright © 2024. All rights reserved.