ReplicationThrottler (Apache HBase 1.2.12 API)

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- org.apache.hadoop.hbase.replication.regionserver.ReplicationThrottler

```
@InterfaceAudience.Private
public class ReplicationThrottler
extends Object
```
Per-peer per-node throttling controller for replication: enabled if bandwidth > 0, a cycle = 100ms, by throttling we guarantee data pushed to peer within each cycle won't exceed 'bandwidth' bytes

Field Summary

Fields
Modifier and Type Field and Description

private double bandwidth

private long cyclePushSize

private long cycleStartTick

private boolean enabled

Constructor Summary

Constructors
Constructor and Description

ReplicationThrottler(double bandwidth)
ReplicationThrottler constructor If bandwidth less than 1, throttling is disabled

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`addPushSize(int size)` Add current size to the current cycle's total push size
`long`	`getNextSleepInterval(int size)` Get how long the caller should sleep according to the current size and current cycle's total push size and start tick, return the sleep interval for throttling control.
`boolean`	`isEnabled()` If throttling is enabled
`void`	`resetStartTick()` Reset the cycle start tick to NOW

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - enabled
```
private final boolean enabled
```
  - bandwidth
```
private final double bandwidth
```
  - cyclePushSize
```
private long cyclePushSize
```
  - cycleStartTick
```
private long cycleStartTick
```
- Constructor Detail
  - ReplicationThrottler
```
public ReplicationThrottler(double bandwidth)
```
    ReplicationThrottler constructor If bandwidth less than 1, throttling is disabled
    
    Parameters:
    bandwidth - per cycle(100ms)
- Method Detail
  - isEnabled
```
public boolean isEnabled()
```
    If throttling is enabled
    
    Returns:
    true if throttling is enabled
  - getNextSleepInterval
```
public long getNextSleepInterval(int size)
```
    Get how long the caller should sleep according to the current size and current cycle's total push size and start tick, return the sleep interval for throttling control.
    
    Parameters:
    size - is the size of edits to be pushed
    
    Returns:
    sleep interval for throttling control
  - addPushSize
```
public void addPushSize(int size)
```
    Add current size to the current cycle's total push size
    
    Parameters:
    size - is the current size added to the current cycle's total push size
  - resetStartTick
```
public void resetStartTick()
```
    Reset the cycle start tick to NOW

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.