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

Class QueueBarrier

java.lang.Object

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

public final class QueueBarrier
extends Object

Representing queue barrier information. It contains the consumer group information for queue entry that are enqueue after the given start row.

Method Summary

Methods

Modifier and Type	Method and Description
ConsumerGroupConfig	getGroupConfig()
byte[]	getStartRow()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getGroupConfig

public ConsumerGroupConfig getGroupConfig()

getStartRow

public byte[] getStartRow()

toString

public String toString()

Overrides:

toString in class Object