Package org.apache.bookkeeper.bookie.datainteg

Class EntryCopierImpl.BatchImpl

java.lang.Object

org.apache.bookkeeper.bookie.datainteg.EntryCopierImpl.BatchImpl

All Implemented Interfaces:

EntryCopier.Batch

Enclosing class:

EntryCopierImpl

class EntryCopierImpl.BatchImpl
extends Object
implements EntryCopier.Batch

Constructor Summary

Constructors

Constructor	Description
BatchImpl(BookieId bookieId, long ledgerId, LedgerMetadata metadata, EntryCopierImpl.SinBin sinBin)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Long>	copyFromAvailable(long entryId)	Copy an entry from a remote bookie and store it locally.
(package private) CompletableFuture<io.netty.buffer.ByteBuf>	fetchEntry(long entryId)
(package private) void	notifyBookieError(BookieId bookie)

Methods inherited from class java.lang.Object

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

Constructor Details

BatchImpl

BatchImpl(BookieId bookieId,
 long ledgerId,
 LedgerMetadata metadata,
 EntryCopierImpl.SinBin sinBin)

Method Details

notifyBookieError

void notifyBookieError(BookieId bookie)

copyFromAvailable

public CompletableFuture<Long> copyFromAvailable(long entryId)

Description copied from interface: EntryCopier.Batch

Copy an entry from a remote bookie and store it locally.

Specified by:

copyFromAvailable in interface EntryCopier.Batch

Returns:

the number of bytes copied.

fetchEntry

CompletableFuture<io.netty.buffer.ByteBuf> fetchEntry(long entryId)