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; } }
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()); }
/** * 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();