private static final class FanOutOneBlockAsyncDFSOutput.Callback extends Object
Modifier and Type | Field and Description |
---|---|
private long |
ackedLength |
private CompletableFuture<Long> |
future |
private Set<org.apache.hbase.thirdparty.io.netty.channel.ChannelId> |
unfinishedReplicas |
Constructor and Description |
---|
Callback(CompletableFuture<Long> future,
long ackedLength,
Collection<org.apache.hbase.thirdparty.io.netty.channel.Channel> replicas) |
private final CompletableFuture<Long> future
private final long ackedLength
private final Set<org.apache.hbase.thirdparty.io.netty.channel.ChannelId> unfinishedReplicas
public Callback(CompletableFuture<Long> future, long ackedLength, Collection<org.apache.hbase.thirdparty.io.netty.channel.Channel> replicas)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.