com.hazelcast.connector.map

Class Reader<F extends CompletableFuture,B,R>

java.lang.Object

com.hazelcast.connector.map.Reader<F,B,R>

Type Parameters:

F - type of the result future

B - type of the batch object

R - type of the record

public abstract class Reader<F extends CompletableFuture,B,R>
extends Object

Stateless interface to read a map/cache.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	objectName

Constructor Summary

Constructors

Constructor and Description
Reader(String objectName, Function<B,Integer> toNextIndexFn, Function<B,List<R>> toRecordSetFn) Creates a reader for a map/cache

Method Summary

Modifier and Type	Method and Description
abstract F	readBatch(int partitionId, int offset) Read a batch from a partition with given offset
B	toBatchResult(F future) Transform the future returned from readBatch(int, int) to a batch
int	toNextIndex(B result) Return the index that follows current batch
abstract Object	toObject(R record) Transform a record to an object
List<R>	toRecordSet(B result) Transforms batch result to a list of records

Methods inherited from class java.lang.Object

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

Field Detail

objectName

protected final String objectName

Constructor Detail

Reader

public Reader(@Nonnull
              String objectName,
              @Nonnull
              Function<B,Integer> toNextIndexFn,
              @Nonnull
              Function<B,List<R>> toRecordSetFn)

Creates a reader for a map/cache

Method Detail

readBatch

@Nonnull
public abstract F readBatch(int partitionId,
                                     int offset)

Read a batch from a partition with given offset

Parameters:

partitionId - id of the partition

offset - offset to read

Returns:

a future

toBatchResult

@Nonnull
public B toBatchResult(@Nonnull
                                F future)
                         throws ExecutionException,
                                InterruptedException

Transform the future returned from readBatch(int, int) to a batch

Throws:

ExecutionException

InterruptedException

toNextIndex

public final int toNextIndex(@Nonnull
                             B result)

Return the index that follows current batch

toRecordSet

@Nonnull
public final List<R> toRecordSet(@Nonnull
                                          B result)

Transforms batch result to a list of records

toObject

@Nullable
public abstract Object toObject(@Nonnull
                                          R record)

Transform a record to an object