Package io.hstream
Interface StreamShardReaderBuilder
-
public interface StreamShardReaderBuilder
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamShardReaderBuilderbatchReceiver(StreamShardReaderBatchReceiver streamShardReaderReceiver)StreamShardReaderbuild()StreamShardReaderBuilderfrom(StreamShardOffset shardOffset)StreamShardReaderBuildermaxReadBatches(long maxReadBatches)StreamShardReaderBuilderreceiver(StreamShardReaderReceiver streamShardReaderReceiver)StreamShardReaderBuildershardId(long shardId)StreamShardReaderBuilderstreamName(String streamName)StreamShardReaderBuilderuntil(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()
-
-