Java 类org.apache.hadoop.hbase.replication.ReplicationLoadSink 实例源码

ServerMetricsImpl(ServerName serverName, long requestCountPerSecond, long requestCount,
  Size usedHeapSize, Size maxHeapSize, int infoServerPort, List<ReplicationLoadSource> sources,
  ReplicationLoadSink sink, Map<byte[], RegionMetrics> regionStatus,
  Set<String> coprocessorNames, long reportTimestamp, long lastReportTimestamp) {
  this.serverName = Preconditions.checkNotNull(serverName);
  this.requestCountPerSecond = requestCountPerSecond;
  this.requestCount = requestCount;
  this.usedHeapSize = Preconditions.checkNotNull(usedHeapSize);
  this.maxHeapSize = Preconditions.checkNotNull(maxHeapSize);
  this.infoServerPort = infoServerPort;
  this.sources = Preconditions.checkNotNull(sources);
  this.sink = sink;
  this.regionStatus = Preconditions.checkNotNull(regionStatus);
  this.coprocessorNames =Preconditions.checkNotNull(coprocessorNames);
  this.reportTimestamp = reportTimestamp;
  this.lastReportTimestamp = lastReportTimestamp;
}

/**
 * Call directly from client such as hbase shell
 * @return ReplicationLoadSink
 */
public ReplicationLoadSink getReplicationLoadSink() {
  if (serverLoad.hasReplLoadSink()) {
    return ProtobufUtil.toReplicationLoadSink(serverLoad.getReplLoadSink());
  } else {
    return null;
  }
}

/**
 * Call directly from client such as hbase shell
 * @return ReplicationLoadSink
 */
public ReplicationLoadSink getReplicationLoadSink() {
  if (serverLoad.hasReplLoadSink()) {
    return ProtobufUtil.toReplicationLoadSink(serverLoad.getReplLoadSink());
  } else {
    return null;
  }
}

public static ClusterStatusProtos.ReplicationLoadSink toReplicationLoadSink(
    ReplicationLoadSink rls) {
  return ClusterStatusProtos.ReplicationLoadSink.newBuilder()
      .setAgeOfLastAppliedOp(rls.getAgeOfLastAppliedOp())
      .setTimeStampsOfLastAppliedOp(rls.getTimeStampsOfLastAppliedOp())
      .build();
}

public static ReplicationLoadSink toReplicationLoadSink(
    ClusterStatusProtos.ReplicationLoadSink cls) {
  return new ReplicationLoadSink(cls.getAgeOfLastAppliedOp(), cls.getTimeStampsOfLastAppliedOp());
}

public static ReplicationLoadSink toReplicationLoadSink(
    ClusterStatusProtos.ReplicationLoadSink cls) {
  return new ReplicationLoadSink(cls.getAgeOfLastAppliedOp(), cls.getTimeStampsOfLastAppliedOp());
}

/**
 * Call directly from client such as hbase shell
 * @return ReplicationLoadSink
 */
@Override
public ReplicationLoadSink getReplicationLoadSink() {
  return metrics.getReplicationLoadSink();
}

public ServerMetricsBuilder setReplicationLoadSink(ReplicationLoadSink value) {
  this.sink = value;
  return this;
}

@Override
public ReplicationLoadSink getReplicationLoadSink() {
  return sink;
}

public static ReplicationLoadSink toReplicationLoadSink(
    ClusterStatusProtos.ReplicationLoadSink rls) {
  return new ReplicationLoadSink(rls.getAgeOfLastAppliedOp(), rls.getTimeStampsOfLastAppliedOp());
}

/**
 * Call directly from client such as hbase shell
 * @return ReplicationLoadSink
 */
@Nullable
ReplicationLoadSink getReplicationLoadSink();