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 java.lang.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
java.util.concurrent.CompletableFuture<java.lang.Long>	copyFromAvailable(long entryId)	Copy an entry from a remote bookie and store it locally.
(package private) java.util.concurrent.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 Detail

BatchImpl

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

Method Detail

notifyBookieError

void notifyBookieError(BookieId bookie)

copyFromAvailable

public java.util.concurrent.CompletableFuture<java.lang.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

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