io.pravega.client.stream

Class ReaderGroupConfig.ReaderGroupConfigBuilder

java.lang.Object

io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder

All Implemented Interfaces:

io.pravega.common.ObjectBuilder<ReaderGroupConfig>

Enclosing class:

ReaderGroupConfig

public static class ReaderGroupConfig.ReaderGroupConfigBuilder
extends java.lang.Object
implements io.pravega.common.ObjectBuilder<ReaderGroupConfig>

Constructor Summary

Constructors

Constructor and Description
ReaderGroupConfigBuilder()

Method Summary

Modifier and Type	Method and Description
ReaderGroupConfig	build()
ReaderGroupConfig.ReaderGroupConfigBuilder	disableAutomaticCheckpoints() Disables automatic checkpointing.
ReaderGroupConfig.ReaderGroupConfigBuilder	startFromCheckpoint(Checkpoint checkpoint) Ensure the readers of the ReaderGroup start from the provided Checkpoint.
ReaderGroupConfig.ReaderGroupConfigBuilder	startFromStreamCuts(java.util.Map<Stream,StreamCut> streamCuts) Ensure the readers of the ReaderGroup start from this provided streamCuts.
ReaderGroupConfig.ReaderGroupConfigBuilder	stream(Stream stream) Add a stream that needs to be read by the readers of a ReaderGroup.
ReaderGroupConfig.ReaderGroupConfigBuilder	stream(Stream stream, StreamCut startStreamCut) Add a stream and its associated start StreamCut to be read by the readers of a ReaderGroup.
ReaderGroupConfig.ReaderGroupConfigBuilder	stream(Stream stream, StreamCut startStreamCut, StreamCut endStreamCut) Add a stream and its associated start StreamCut and end StreamCut to be read by the readers of a ReaderGroup.
ReaderGroupConfig.ReaderGroupConfigBuilder	stream(java.lang.String scopedStreamName) Add a stream that needs to be read by the readers of a ReaderGroup.
ReaderGroupConfig.ReaderGroupConfigBuilder	stream(java.lang.String scopedStreamName, StreamCut startStreamCut) Add a stream and its associated start StreamCut to be read by the readers of a ReaderGroup.
ReaderGroupConfig.ReaderGroupConfigBuilder	stream(java.lang.String scopedStreamName, StreamCut startStreamCut, StreamCut endStreamCut) Add a stream and its associated start StreamCut and end StreamCut to be read by the readers of a ReaderGroup.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReaderGroupConfigBuilder

public ReaderGroupConfigBuilder()

Method Detail

disableAutomaticCheckpoints

public ReaderGroupConfig.ReaderGroupConfigBuilder disableAutomaticCheckpoints()

Disables automatic checkpointing. Checkpoints need to be generated manually, see this method: ReaderGroup.initiateCheckpoint(String, ScheduledExecutorService).

Returns:

Reader group config builder.

stream

public ReaderGroupConfig.ReaderGroupConfigBuilder stream(java.lang.String scopedStreamName,
                                                         StreamCut startStreamCut,
                                                         StreamCut endStreamCut)

Add a stream and its associated start StreamCut and end StreamCut to be read by the readers of a ReaderGroup.

Parameters:

scopedStreamName - Scoped Name of the Stream.

startStreamCut - Start StreamCut

endStreamCut - End StreamCut

Returns:

Reader group config builder.

stream

public ReaderGroupConfig.ReaderGroupConfigBuilder stream(java.lang.String scopedStreamName,
                                                         StreamCut startStreamCut)

Add a stream and its associated start StreamCut to be read by the readers of a ReaderGroup.

Parameters:

scopedStreamName - Scoped Name of the Stream.

startStreamCut - Start StreamCut.

Returns:

Reader group config builder.

stream

public ReaderGroupConfig.ReaderGroupConfigBuilder stream(java.lang.String scopedStreamName)

Add a stream that needs to be read by the readers of a ReaderGroup. The current starting position of the stream will be used as the starting StreamCut.

Parameters:

scopedStreamName - Stream name.

Returns:

Reader group config builder.

stream

public ReaderGroupConfig.ReaderGroupConfigBuilder stream(Stream stream,
                                                         StreamCut startStreamCut,
                                                         StreamCut endStreamCut)

Add a stream and its associated start StreamCut and end StreamCut to be read by the readers of a ReaderGroup.

Parameters:

stream - Stream.

startStreamCut - Start StreamCut.

endStreamCut - End StreamCut.

Returns:

Reader group config builder.

stream

public ReaderGroupConfig.ReaderGroupConfigBuilder stream(Stream stream,
                                                         StreamCut startStreamCut)

Add a stream and its associated start StreamCut to be read by the readers of a ReaderGroup.

Parameters:

stream - Stream.

startStreamCut - Start StreamCut

Returns:

Reader group config builder.

stream

public ReaderGroupConfig.ReaderGroupConfigBuilder stream(Stream stream)

Add a stream that needs to be read by the readers of a ReaderGroup. The current starting position of the stream will be used as the starting StreamCut.

Parameters:

stream - Stream.

Returns:

Reader group config builder.

startFromStreamCuts

public ReaderGroupConfig.ReaderGroupConfigBuilder startFromStreamCuts(java.util.Map<Stream,StreamCut> streamCuts)

Ensure the readers of the ReaderGroup start from this provided streamCuts.

Parameters:

streamCuts - Map of Stream and its corresponding StreamCut.

Returns:

Reader group config builder.

startFromCheckpoint

public ReaderGroupConfig.ReaderGroupConfigBuilder startFromCheckpoint(Checkpoint checkpoint)

Ensure the readers of the ReaderGroup start from the provided Checkpoint.

Parameters:

checkpoint - Checkpoint.

Returns:

Reader group config builder.

build

public ReaderGroupConfig build()

Specified by:

build in interface io.pravega.common.ObjectBuilder<ReaderGroupConfig>