Package org.apache.hadoop.hbase.replication

Class ReplicationLoadSource.ReplicationLoadSourceBuilder

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationLoadSource.ReplicationLoadSourceBuilder

Enclosing class:

ReplicationLoadSource

public static final class ReplicationLoadSource.ReplicationLoadSourceBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private long	ageOfLastShippedOp
private long	editsRead
private boolean	editsSinceRestart
private long	oPsShipped
private String	peerID
private String	queueId
private boolean	recovered
private long	replicationLag
private boolean	running
private int	sizeOfLogQueue
private long	timestampOfLastShippedOp
private long	timeStampOfNextToReplicate

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReplicationLoadSourceBuilder()

Method Summary

Modifier and Type	Method	Description
ReplicationLoadSource	build()
ReplicationLoadSource.ReplicationLoadSourceBuilder	setAgeOfLastShippedOp(long ageOfLastShippedOp)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setEditsRead(long editsRead)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setEditsSinceRestart(boolean editsSinceRestart)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setoPsShipped(long oPsShipped)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setPeerID(String peerID)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setQueueId(String queueId)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setRecovered(boolean recovered)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setReplicationLag(long replicationLag)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setRunning(boolean running)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setSizeOfLogQueue(int sizeOfLogQueue)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setTimestampOfLastShippedOp(long timestampOfLastShippedOp)
ReplicationLoadSource.ReplicationLoadSourceBuilder	setTimeStampOfNextToReplicate(long timeStampOfNextToReplicate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

peerID

private String peerID

ageOfLastShippedOp

private long ageOfLastShippedOp

sizeOfLogQueue

private int sizeOfLogQueue

timestampOfLastShippedOp

private long timestampOfLastShippedOp

replicationLag

private long replicationLag

timeStampOfNextToReplicate

private long timeStampOfNextToReplicate

queueId

private String queueId

recovered

private boolean recovered

running

private boolean running

editsSinceRestart

private boolean editsSinceRestart

editsRead

private long editsRead

oPsShipped

private long oPsShipped

Constructor Details

ReplicationLoadSourceBuilder

private ReplicationLoadSourceBuilder()

Method Details

setTimeStampOfNextToReplicate

public ReplicationLoadSource.ReplicationLoadSourceBuilder setTimeStampOfNextToReplicate(long timeStampOfNextToReplicate)

setPeerID

public ReplicationLoadSource.ReplicationLoadSourceBuilder setPeerID(String peerID)

setAgeOfLastShippedOp

public ReplicationLoadSource.ReplicationLoadSourceBuilder setAgeOfLastShippedOp(long ageOfLastShippedOp)

setSizeOfLogQueue

public ReplicationLoadSource.ReplicationLoadSourceBuilder setSizeOfLogQueue(int sizeOfLogQueue)

setTimestampOfLastShippedOp

public ReplicationLoadSource.ReplicationLoadSourceBuilder setTimestampOfLastShippedOp(long timestampOfLastShippedOp)

setReplicationLag

public ReplicationLoadSource.ReplicationLoadSourceBuilder setReplicationLag(long replicationLag)

setQueueId

public ReplicationLoadSource.ReplicationLoadSourceBuilder setQueueId(String queueId)

setRecovered

public ReplicationLoadSource.ReplicationLoadSourceBuilder setRecovered(boolean recovered)

setRunning

public ReplicationLoadSource.ReplicationLoadSourceBuilder setRunning(boolean running)

setEditsSinceRestart

public ReplicationLoadSource.ReplicationLoadSourceBuilder setEditsSinceRestart(boolean editsSinceRestart)

setEditsRead

public ReplicationLoadSource.ReplicationLoadSourceBuilder setEditsRead(long editsRead)

setoPsShipped

public ReplicationLoadSource.ReplicationLoadSourceBuilder setoPsShipped(long oPsShipped)

build

public ReplicationLoadSource build()