co.cask.cdap.data2.transaction.queue.hbase

Class HBaseConsumerState

java.lang.Object

co.cask.cdap.data2.transaction.queue.hbase.HBaseConsumerState

public final class HBaseConsumerState
extends Object

Represents state of a queue consumer.

Method Summary

Methods

Modifier and Type	Method and Description
ConsumerConfig	getConsumerConfig()
byte[]	getNextBarrier()
byte[]	getPreviousBarrier()
byte[]	getStartRow()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getConsumerConfig

public ConsumerConfig getConsumerConfig()

getStartRow

public byte[] getStartRow()

getPreviousBarrier

@Nullable
public byte[] getPreviousBarrier()

getNextBarrier

@Nullable
public byte[] getNextBarrier()

toString

public String toString()

Overrides:

toString in class Object