Uses of Class
org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder

Packages that use EventDataStreamFactory.Builder

Package	Description
org.wikimedia.eventutilities.flink.stream

Uses of EventDataStreamFactory.Builder in org.wikimedia.eventutilities.flink.stream

Methods in org.wikimedia.eventutilities.flink.stream that return EventDataStreamFactory.Builder

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.ingestionTimeClock(SerializableClock ingestionTimeClock) SerializableClock to use for setting ingestion time on serialized events.
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).