Package io.hstream
Interface StreamShardReaderBuilder
-
public interface StreamShardReaderBuilder
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamShardReaderBuilder
batchReceiver(StreamShardReaderBatchReceiver streamShardReaderReceiver)
StreamShardReader
build()
StreamShardReaderBuilder
from(StreamShardOffset shardOffset)
StreamShardReaderBuilder
maxReadBatches(long maxReadBatches)
StreamShardReaderBuilder
receiver(StreamShardReaderReceiver streamShardReaderReceiver)
StreamShardReaderBuilder
shardId(long shardId)
StreamShardReaderBuilder
streamName(String streamName)
StreamShardReaderBuilder
until(StreamShardOffset until)
-
-
-
Method Detail
-
streamName
StreamShardReaderBuilder streamName(String streamName)
-
shardId
StreamShardReaderBuilder shardId(long shardId)
-
from
StreamShardReaderBuilder from(StreamShardOffset shardOffset)
-
maxReadBatches
StreamShardReaderBuilder maxReadBatches(long maxReadBatches)
-
until
StreamShardReaderBuilder until(StreamShardOffset until)
-
receiver
StreamShardReaderBuilder receiver(StreamShardReaderReceiver streamShardReaderReceiver)
-
batchReceiver
StreamShardReaderBuilder batchReceiver(StreamShardReaderBatchReceiver streamShardReaderReceiver)
-
build
StreamShardReader build()
-
-