| Package | Description |
|---|---|
| co.cask.cdap.data2.queue |
API definition for queue for the txds2 system.
|
| co.cask.cdap.data2.transaction.queue |
Transaction aware queue implementation.
|
| co.cask.cdap.data2.transaction.queue.hbase |
This package contains an HBase implementation of queues.
|
| co.cask.cdap.data2.transaction.queue.inmemory |
This package contains in memory implementation of queues.
|
| co.cask.cdap.data2.transaction.queue.leveldb |
This package contains levelDB implementation of queues.
|
| Modifier and Type | Method and Description |
|---|---|
void |
QueueProducer.enqueue(QueueEntry entry)
Enqueues a
QueueEntry. |
| Modifier and Type | Method and Description |
|---|---|
void |
QueueProducer.enqueue(Iterable<QueueEntry> entries)
Enqueues a list of
QueueEntry. |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractQueueProducer.enqueue(QueueEntry entry) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractQueueProducer.enqueue(Iterable<QueueEntry> entries) |
protected abstract int |
AbstractQueueProducer.persist(Iterable<QueueEntry> entries,
co.cask.tephra.Transaction transaction)
Persists queue entries.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SaltedHBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs,
QueueEntry queueEntry,
byte[] rowKeyPrefix,
long writePointer,
int counter,
Collection<byte[]> rowKeys) |
void |
ShardedHBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs,
QueueEntry queueEntry,
byte[] rowKeyPrefix,
long writePointer,
int counter,
Collection<byte[]> rowKeys) |
void |
HBaseQueueStrategy.getRowKeys(Iterable<ConsumerGroupConfig> consumerGroupConfigs,
QueueEntry queueEntry,
byte[] rowKeyPrefix,
long writePointer,
int counter,
Collection<byte[]> rowKeys)
Get all the row keys that the queue entries need to write to.
|
| Modifier and Type | Method and Description |
|---|---|
protected int |
HBaseQueueProducer.persist(Iterable<QueueEntry> entries,
co.cask.tephra.Transaction transaction)
Persist queue entries into HBase.
|
| Modifier and Type | Method and Description |
|---|---|
void |
InMemoryQueue.enqueue(long txId,
int seqId,
QueueEntry entry) |
| Modifier and Type | Method and Description |
|---|---|
protected int |
InMemoryQueueProducer.persist(Iterable<QueueEntry> entries,
co.cask.tephra.Transaction transaction) |
| Modifier and Type | Method and Description |
|---|---|
protected int |
LevelDBQueueProducer.persist(Iterable<QueueEntry> entries,
co.cask.tephra.Transaction transaction) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.