HBASE-22562 Remove dead code: skipControl
Signed-off-by: Reid Chan <reidchan@apache.org>
This commit is contained in:
parent
b7f60bc87f
commit
3d64cf1203
|
@ -143,13 +143,4 @@ public class PressureAwareCompactionThroughputController extends PressureAwareTh
|
||||||
+ throughputDesc(getMaxThroughput()) + ", activeCompactions=" + activeOperations.size()
|
+ throughputDesc(getMaxThroughput()) + ", activeCompactions=" + activeOperations.size()
|
||||||
+ "]";
|
+ "]";
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean skipControl(long deltaSize, long controlSize) {
|
|
||||||
if (deltaSize < controlSize) {
|
|
||||||
return true;
|
|
||||||
} else {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -128,10 +128,4 @@ public class PressureAwareFlushThroughputController extends PressureAwareThrough
|
||||||
return "DefaultFlushController [maxThroughput=" + throughputDesc(getMaxThroughput())
|
return "DefaultFlushController [maxThroughput=" + throughputDesc(getMaxThroughput())
|
||||||
+ ", activeFlushNumber=" + activeOperations.size() + "]";
|
+ ", activeFlushNumber=" + activeOperations.size() + "]";
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean skipControl(long deltaSize, long controlSize) {
|
|
||||||
// for flush, we control the flow no matter whether the flush size is small
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -137,14 +137,6 @@ public abstract class PressureAwareThroughputController extends Configured imple
|
||||||
return sleepTime;
|
return sleepTime;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Check whether to skip control given delta size and control size
|
|
||||||
* @param deltaSize Delta size since last control
|
|
||||||
* @param controlSize Size limit to perform control
|
|
||||||
* @return a boolean indicates whether to skip this control
|
|
||||||
*/
|
|
||||||
protected abstract boolean skipControl(long deltaSize, long controlSize);
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void finish(String opName) {
|
public void finish(String opName) {
|
||||||
ActiveOperation operation = activeOperations.remove(opName);
|
ActiveOperation operation = activeOperations.remove(opName);
|
||||||
|
|
Loading…
Reference in New Issue