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

Class DequeueScanAttributes

java.lang.Object

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

public class DequeueScanAttributes
extends Object

Deals with dequeue scan attributes.

Constructor Summary

Constructors

Constructor and Description
DequeueScanAttributes()

Method Summary

Methods

Modifier and Type	Method and Description
static Map<String,byte[]>	addAttribute(ConsumerConfig consumerConfig, Map<String,byte[]> attributes)
static Map<String,byte[]>	addAttribute(co.cask.tephra.Transaction transaction, Map<String,byte[]> attributes)
static ConsumerConfig	getConsumerConfig(org.apache.hadoop.hbase.client.Scan scan)
static co.cask.tephra.Transaction	getTx(org.apache.hadoop.hbase.client.Scan scan)
static ConsumerConfig	readConsumerConfig(DataInput dataInput)
static co.cask.tephra.Transaction	readTx(DataInput dataInput)
static void	write(DataOutput dataOutput, ConsumerConfig consumerConfig)
static void	write(DataOutput dataOutput, co.cask.tephra.Transaction tx)

Methods inherited from class java.lang.Object

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

Constructor Detail

DequeueScanAttributes

public DequeueScanAttributes()

Method Detail

addAttribute

public static Map<String,byte[]> addAttribute(ConsumerConfig consumerConfig,
                              Map<String,byte[]> attributes)

addAttribute

public static Map<String,byte[]> addAttribute(co.cask.tephra.Transaction transaction,
                              Map<String,byte[]> attributes)

getConsumerConfig

@Nullable
public static ConsumerConfig getConsumerConfig(org.apache.hadoop.hbase.client.Scan scan)

getTx

@Nullable
public static co.cask.tephra.Transaction getTx(org.apache.hadoop.hbase.client.Scan scan)

write

public static void write(DataOutput dataOutput,
         ConsumerConfig consumerConfig)
                  throws IOException

Throws:

IOException

readConsumerConfig

public static ConsumerConfig readConsumerConfig(DataInput dataInput)
                                         throws IOException

Throws:

IOException

write

public static void write(DataOutput dataOutput,
         co.cask.tephra.Transaction tx)
                  throws IOException

Throws:

IOException

readTx

public static co.cask.tephra.Transaction readTx(DataInput dataInput)
                                         throws IOException

Throws:

IOException