Package | Description |
---|---|
org.wikimedia.eventutilities.flink.stream |
Modifier and Type | Method and Description |
---|---|
static EventDataStreamFactory.Builder |
EventDataStreamFactory.builder() |
EventDataStreamFactory.Builder |
EventDataStreamFactory.Builder.eventStreamConfigUri(String eventStreamConfigUri) |
EventDataStreamFactory.Builder |
EventDataStreamFactory.Builder.eventStreamFactory(EventStreamFactory eventStreamFactory) |
EventDataStreamFactory.Builder |
EventDataStreamFactory.Builder.generator(JsonEventGenerator generator) |
EventDataStreamFactory.Builder |
EventDataStreamFactory.Builder.httpClientRoutes(Map<String,String> httpClientRoutes) |
EventDataStreamFactory.Builder |
EventDataStreamFactory.Builder.schemaBaseUris(List<String> schemaBaseUris) |
EventDataStreamFactory.Builder |
EventDataStreamFactory.Builder.topicFilter(Predicate<String> topicFilter)
The filter to apply when extracting the configured topics of a stream.
|
EventDataStreamFactory.Builder |
EventDataStreamFactory.Builder.topicPrefix(String topicPrefix)
Filter source topics with a particular prefix (generally the datacenter name).
|
Copyright © 2024. All rights reserved.