Package org.apache.hadoop.hbase.io.asyncfs

Class FanOutOneBlockAsyncDFSOutput.Callback

java.lang.Object

org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutput.Callback

Enclosing class:

FanOutOneBlockAsyncDFSOutput

private static final class FanOutOneBlockAsyncDFSOutput.Callback
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final long	ackedLength
private final long	flushTimestamp
private final CompletableFuture<Long>	future
private long	lastAckTimestamp
private final long	packetDataLen
private final Set<org.apache.hbase.thirdparty.io.netty.channel.ChannelId>	unfinishedReplicas

Constructor Summary

Constructors

Constructor	Description
Callback(CompletableFuture<Long> future, long ackedLength, Collection<org.apache.hbase.thirdparty.io.netty.channel.Channel> replicas, long packetDataLen)

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

future

private final CompletableFuture<Long> future

ackedLength

private final long ackedLength

unfinishedReplicas

private final Set<org.apache.hbase.thirdparty.io.netty.channel.ChannelId> unfinishedReplicas

packetDataLen

private final long packetDataLen

flushTimestamp

private final long flushTimestamp

lastAckTimestamp

private long lastAckTimestamp

Constructor Details

Callback

public Callback(CompletableFuture<Long> future,
 long ackedLength,
 Collection<org.apache.hbase.thirdparty.io.netty.channel.Channel> replicas,
 long packetDataLen)