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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfaceEntryCopier.Batch
- Returns:
- the number of bytes copied.
-
fetchEntry
java.util.concurrent.CompletableFuture<io.netty.buffer.ByteBuf> fetchEntry(long entryId)
-
-