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 and Description
private long	ackedLength
private long	flushTimestamp
private CompletableFuture<Long>	future
private long	lastAckTimestamp
private long	packetDataLen
private Set<org.apache.hbase.thirdparty.io.netty.channel.ChannelId>	unfinishedReplicas

Constructor Summary

Constructors

Constructor and 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 Detail

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 Detail

Callback

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