org.wikimedia.eventutilities.flink.stream

Class EventDataStreamFactory.Builder

java.lang.Object

org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder

Enclosing class:

EventDataStreamFactory

public static class EventDataStreamFactory.Builder
extends Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
EventDataStreamFactory	build()
EventDataStreamFactory.Builder	eventStreamConfigUri(String eventStreamConfigUri)
EventDataStreamFactory.Builder	eventStreamFactory(EventStreamFactory eventStreamFactory)
EventDataStreamFactory.Builder	generator(JsonEventGenerator generator)
EventDataStreamFactory.Builder	httpClientRoutes(Map<String,String> httpClientRoutes)
EventDataStreamFactory.Builder	schemaBaseUris(List<String> schemaBaseUris)
EventDataStreamFactory.Builder	topicFilter(Predicate<String> topicFilter) The filter to apply when extracting the configured topics of a stream.
EventDataStreamFactory.Builder	topicPrefix(String topicPrefix) Filter source topics with a particular prefix (generally the datacenter name).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

topicPrefix

public EventDataStreamFactory.Builder topicPrefix(String topicPrefix)

Filter source topics with a particular prefix (generally the datacenter name). This is based on the naming convention that topics are prefixed with datacenter name they're populated from.

Parameters:

topicPrefix - the prefix to use (usually the name of a datacenter)

build

public EventDataStreamFactory build()

schemaBaseUris

public EventDataStreamFactory.Builder schemaBaseUris(List<String> schemaBaseUris)

Returns:

this.

eventStreamConfigUri

public EventDataStreamFactory.Builder eventStreamConfigUri(String eventStreamConfigUri)

Returns:

this.

eventStreamFactory

public EventDataStreamFactory.Builder eventStreamFactory(EventStreamFactory eventStreamFactory)

Returns:

this.

generator

public EventDataStreamFactory.Builder generator(JsonEventGenerator generator)

Returns:

this.

httpClientRoutes

public EventDataStreamFactory.Builder httpClientRoutes(Map<String,String> httpClientRoutes)

Returns:

this.

topicFilter

public EventDataStreamFactory.Builder topicFilter(@Nonnull
                                                  Predicate<String> topicFilter)

The filter to apply when extracting the configured topics of a stream. Accept all topics by default.

Returns:

this.