A B C D E F G H I L M O P R S T U

A

AbstractMessageTable - Class in co.cask.cdap.messaging.store

Contains common logic for implementation of MessageTable.

AbstractMessageTable() - Constructor for class co.cask.cdap.messaging.store.AbstractMessageTable

AbstractPayloadTable - Class in co.cask.cdap.messaging.store

Contains common logic for implementation of PayloadTable.

AbstractPayloadTable() - Constructor for class co.cask.cdap.messaging.store.AbstractPayloadTable

addPayloads(byte[]...) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Adds a list of byte arrays as the payloads of the request.

addPayloads(String...) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Adds a list of Strings as the payloads of the request.

addPayloads(Iterator<byte[]>) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Adds a list of byte arrays as the payloads of the request.

B

build() - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Creates a StoreRequest based on the settings in this builder.

C

ClientMessagingService - Class in co.cask.cdap.messaging.client

The client implementation of MessagingService.

ClientMessagingService(DiscoveryServiceClient) - Constructor for class co.cask.cdap.messaging.client.ClientMessagingService

close() - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

close() - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

co.cask.cdap.messaging - package co.cask.cdap.messaging

co.cask.cdap.messaging.client - package co.cask.cdap.messaging.client

co.cask.cdap.messaging.data - package co.cask.cdap.messaging.data

co.cask.cdap.messaging.distributed - package co.cask.cdap.messaging.distributed

co.cask.cdap.messaging.guice - package co.cask.cdap.messaging.guice

co.cask.cdap.messaging.server - package co.cask.cdap.messaging.server

co.cask.cdap.messaging.service - package co.cask.cdap.messaging.service

co.cask.cdap.messaging.store - package co.cask.cdap.messaging.store

co.cask.cdap.messaging.store.hbase - package co.cask.cdap.messaging.store.hbase

co.cask.cdap.messaging.store.leveldb - package co.cask.cdap.messaging.store.leveldb

COL - Static variable in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

COLUMN_FAMILY - Static variable in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

computeNext() - Method in class co.cask.cdap.messaging.StoreRequest

configure() - Method in class co.cask.cdap.messaging.guice.MessagingClientModule

CoreMessagingService - Class in co.cask.cdap.messaging.service

The core implementation of MessagingService.

createMessageTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

createMessageTable(String) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBTableFactory

createMessageTable(String) - Method in interface co.cask.cdap.messaging.store.TableFactory

createMetadataTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

createMetadataTable(String) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBTableFactory

createMetadataTable(String) - Method in interface co.cask.cdap.messaging.store.TableFactory

createPayloadTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

createPayloadTable(String) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBTableFactory

createPayloadTable(String) - Method in interface co.cask.cdap.messaging.store.TableFactory

createTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

createTopic(TopicMetadata) - Method in interface co.cask.cdap.messaging.MessagingService

Creates a topic with the given metadata.

createTopic(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

createTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

createTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

createTopic(TopicMetadata) - Method in interface co.cask.cdap.messaging.store.MetadataTable

Create a topic with properties.

createTopicIfNotExists(MessagingService, TopicId) - Static method in class co.cask.cdap.messaging.MessagingServices

createTopicIfNotExists(MessagingService, TopicMetadata) - Static method in class co.cask.cdap.messaging.MessagingServices

D

deleteTopic(TopicId) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

deleteTopic(TopicId) - Method in interface co.cask.cdap.messaging.MessagingService

Deletes a topic

deleteTopic(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

deleteTopic(TopicId) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

deleteTopic(TopicId) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

deleteTopic(TopicId) - Method in interface co.cask.cdap.messaging.store.MetadataTable

Delete a topic.

disableMessageTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

disablePayloadTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

doComputeNext() - Method in class co.cask.cdap.messaging.StoreRequest

Returns the next message payloads or return null to signal the end of payload messages.

E

equals(Object) - Method in class co.cask.cdap.messaging.data.MessageId

equals(Object) - Method in class co.cask.cdap.messaging.TopicMetadata

exists() - Method in class co.cask.cdap.messaging.TopicMetadata

Check whether the topic exists.

F

fetch() - Method in class co.cask.cdap.messaging.MessageFetcher

Returns a CloseableIterator that iterates over messages fetched from the messaging system.

fetch(TopicMetadata, long, int, Transaction) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

fetch(TopicMetadata, MessageId, boolean, int, Transaction) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

fetch(TopicMetadata, long, MessageId, boolean, int) - Method in class co.cask.cdap.messaging.store.AbstractPayloadTable

fetch(TopicMetadata, long, int, Transaction) - Method in interface co.cask.cdap.messaging.store.MessageTable

Fetches message table entries in the given topic that were publish on or after the given start time.

fetch(TopicMetadata, MessageId, boolean, int, Transaction) - Method in interface co.cask.cdap.messaging.store.MessageTable

Fetches message table entries in the given topic, starting from the given MessageId.

fetch(TopicMetadata, long, MessageId, boolean, int) - Method in interface co.cask.cdap.messaging.store.PayloadTable

Fetches entries from the payload table under the given topic, starting from the given MessageId.

FetchHandler - Class in co.cask.cdap.messaging.server

A netty http handler for handling message fetching REST API for the messaging system.

G

GENERATION_KEY - Static variable in class co.cask.cdap.messaging.TopicMetadata

getDescription() - Method in class co.cask.cdap.messaging.distributed.MessagingServiceManager

getDistributedModules() - Method in class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

getEndSequenceId() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the sequence id being used for the last payload published with the given transaction write pointer.

getEndTimestamp() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the timestamp being used for the last payload published with the given transaction write pointer.

getGeneration() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getGeneration() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getGeneration() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the generation id of the topic.

getGeneration() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the generation id of the topic.

getGeneration() - Method in class co.cask.cdap.messaging.TopicMetadata

Returns the generation id for the topic.

getId() - Method in class co.cask.cdap.messaging.data.RawMessage

Returns the unique id of this message.

getInMemoryModules() - Method in class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

getKey() - Method in class co.cask.cdap.messaging.store.RawMessageTableEntry

getKey() - Method in class co.cask.cdap.messaging.store.RawPayloadTableEntry

getLimit() - Method in class co.cask.cdap.messaging.MessageFetcher

getMaxInstances() - Method in class co.cask.cdap.messaging.distributed.MessagingServiceManager

getMetadata(TopicId) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

getMetadata(TopicId) - Method in interface co.cask.cdap.messaging.store.MetadataTable

Fetch the metadata of the TopicId.

getPayload() - Method in class co.cask.cdap.messaging.data.RawMessage

Returns the published content of this message.

getPayload() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getPayload() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getPayload() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the message payload if MessageTable.Entry.isPayloadReference() return false; otherwise null will be returned.

getPayload() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the message payload.

getPayload() - Method in class co.cask.cdap.messaging.store.RawMessageTableEntry

getPayloadSequenceId() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the sequence id generated when the message was written to the Payload Table.

getPayloadSequenceId() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getPayloadSequenceId() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the sequence id generated when the payload was written to the payload table.

getPayloadWriteTimestamp() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the timestamp when the message was written to the Payload Table.

getPayloadWriteTimestamp() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getPayloadWriteTimestamp() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the timestamp in milliseconds when the payload was written to the payload table.

getProperties() - Method in class co.cask.cdap.messaging.TopicMetadata

Returns the raw properties for the topic.

getPublishTimestamp() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the publish timestamp in milliseconds of the message.

getPublishTimestamp() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getPublishTimestamp() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the timestamp in milliseconds when this entry was written to the message table.

getRawId() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the raw bytes representation of the message id.

getSequenceId() - Method in class co.cask.cdap.messaging.data.MessageId

Returns the sequence id generated when the message was written.

getSequenceId() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getSequenceId() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the sequence id generated when this entry was written to the message table.

getStandaloneModules() - Method in class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

getStartOffset() - Method in class co.cask.cdap.messaging.MessageFetcher

getStartSequenceId() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the sequence id being used for the first payload published with the given transaction write pointer.

getStartTime() - Method in class co.cask.cdap.messaging.MessageFetcher

getStartTimestamp() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the timestamp being used for the first payload published with the given transaction write pointer.

getTopic(TopicId) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

getTopic(TopicId) - Method in interface co.cask.cdap.messaging.MessagingService

Returns the metadata of the given topic.

getTopic(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

getTopic(TopicId) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

getTopicId() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getTopicId() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getTopicId() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the topic id that the entry belongs to.

getTopicId() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the topic id that the entry belongs to.

getTopicId() - Method in class co.cask.cdap.messaging.StoreRequest

getTopicId() - Method in class co.cask.cdap.messaging.TopicMetadata

Returns the topic id that this metadata is associated with.

getTransaction() - Method in class co.cask.cdap.messaging.MessageFetcher

getTransactionWritePointer() - Method in interface co.cask.cdap.messaging.RollbackDetail

Returns the transaction write pointer used when the message was published.

getTransactionWritePointer() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

getTransactionWritePointer() - Method in class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

getTransactionWritePointer() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns the transaction write pointer stored in this entry.

getTransactionWritePointer() - Method in interface co.cask.cdap.messaging.store.PayloadTable.Entry

Returns the transaction write pointer for storing the payload.

getTransactionWritePointer() - Method in class co.cask.cdap.messaging.StoreRequest

Returns the transaction write pointer if the message is going to be published transactionally, that is when StoreRequest.isTransactional() returns true.

getTTL() - Method in class co.cask.cdap.messaging.TopicMetadata

Returns the time-to-live in seconds property of the topic.

getTxPtr() - Method in class co.cask.cdap.messaging.store.RawMessageTableEntry

getValue() - Method in class co.cask.cdap.messaging.store.RawPayloadTableEntry

H

hashCode() - Method in class co.cask.cdap.messaging.data.MessageId

hashCode() - Method in class co.cask.cdap.messaging.TopicMetadata

hasPayload() - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Returns true if there is some payload in this builder.

HBaseMetadataTable - Class in co.cask.cdap.messaging.store.hbase

HBase implementation of MetadataTable.

HBaseTableFactory - Class in co.cask.cdap.messaging.store.hbase

A TableFactory for creating messaging tables backed by HBase.

I

ImmutableMessageTableEntry - Class in co.cask.cdap.messaging.store

An immutable implementation of MessageTable.Entry.

ImmutableMessageTableEntry(byte[], byte[], byte[]) - Constructor for class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

ImmutablePayloadTableEntry - Class in co.cask.cdap.messaging.store

An immutable implementation of PayloadTable.Entry.

ImmutablePayloadTableEntry(byte[], byte[]) - Constructor for class co.cask.cdap.messaging.store.ImmutablePayloadTableEntry

isIncludeStart() - Method in class co.cask.cdap.messaging.MessageFetcher

isPayloadReference() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

isPayloadReference() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns true if the entry is a reference to messages stored in payload table.

isTransactional() - Method in class co.cask.cdap.messaging.store.ImmutableMessageTableEntry

isTransactional() - Method in interface co.cask.cdap.messaging.store.MessageTable.Entry

Returns true if the message is a transactional message

isTransactional() - Method in class co.cask.cdap.messaging.StoreRequest

Returns true if the message should be published transactionally.

L

LevelDBPayloadTable - Class in co.cask.cdap.messaging.store.leveldb

LevelDB implementation of PayloadTable.

LevelDBPayloadTable(DB) - Constructor for class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

LevelDBTableFactory - Class in co.cask.cdap.messaging.store.leveldb

A TableFactory for creating tables used by the messaging system using the LevelDB implementation.

listTopics(NamespaceId) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

listTopics(NamespaceId) - Method in interface co.cask.cdap.messaging.MessagingService

Returns the list of topics available under the given namespace.

listTopics(HttpRequest, HttpResponder, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

listTopics(NamespaceId) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

listTopics(NamespaceId) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

listTopics() - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

listTopics(NamespaceId) - Method in interface co.cask.cdap.messaging.store.MetadataTable

List all the topics in a namespace.

listTopics() - Method in interface co.cask.cdap.messaging.store.MetadataTable

List all topics in the messaging system.

M

MessageFetcher - Class in co.cask.cdap.messaging

A builder to setup parameters for fetching messages from the messaging system.

MessageFetcher() - Constructor for class co.cask.cdap.messaging.MessageFetcher

MessageId - Class in co.cask.cdap.messaging.data

Uniquely identifies a message in the Messaging System.

MessageId(byte[]) - Constructor for class co.cask.cdap.messaging.data.MessageId

Creates a instance based on the given raw id bytes.

MessageTable - Interface in co.cask.cdap.messaging.store

An interface defining the Message Table operations.

MessageTable.Entry - Interface in co.cask.cdap.messaging.store

Represents an entry (row) in the message table.

MessagingClientModule - Class in co.cask.cdap.messaging.guice

The Guice module to provide binding for messaging system client.

MessagingClientModule() - Constructor for class co.cask.cdap.messaging.guice.MessagingClientModule

MessagingHttpService - Class in co.cask.cdap.messaging.server

The http server for supporting messaging system REST API.

MessagingHttpService(CConfiguration, DiscoveryService, MetricsCollectionService, MessagingService, Set<HttpHandler>) - Constructor for class co.cask.cdap.messaging.server.MessagingHttpService

MessagingServerRuntimeModule - Class in co.cask.cdap.messaging.guice

Provides Guice modules for the messaging server.

MessagingServerRuntimeModule() - Constructor for class co.cask.cdap.messaging.guice.MessagingServerRuntimeModule

MessagingService - Interface in co.cask.cdap.messaging

Main interface to interact with the transactional messaging system.

MessagingServiceManager - Class in co.cask.cdap.messaging.distributed

A MasterServiceManager used in distributed mode.

MessagingServices - Class in co.cask.cdap.messaging

Utility class to help interact with messaging service.

MetadataHandler - Class in co.cask.cdap.messaging.server

A netty http handler for metadata REST API for the messaging system.

MetadataTable - Interface in co.cask.cdap.messaging.store

Table to store information about the topics and their properties.

O

of(TopicId) - Static method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Creates a new StoreRequestBuilder instance.

P

PayloadTable - Interface in co.cask.cdap.messaging.store

An interface defining the Payload Table operations.

PayloadTable.Entry - Interface in co.cask.cdap.messaging.store

Represents an entry (row) in the payload table.

persist(Iterator<RawMessageTableEntry>) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

Store the RawMessageTableEntrys persistently.

persist(Iterator<RawPayloadTableEntry>) - Method in class co.cask.cdap.messaging.store.AbstractPayloadTable

Store the RawPayloadTableEntrys persistently.

persist(Iterator<RawPayloadTableEntry>) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

poll(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.FetchHandler

prepareFetch(TopicId) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

prepareFetch(TopicId) - Method in interface co.cask.cdap.messaging.MessagingService

Prepares to fetch messages from the given topic.

prepareFetch(TopicId) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

pruneMessages(TopicMetadata, long) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

Delete messages of a TopicId that has exceeded the TTL or if it belongs to an older generation

publish(StoreRequest) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

publish(StoreRequest) - Method in interface co.cask.cdap.messaging.MessagingService

Publishes a list of messages to the messaging system.

publish(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.StoreHandler

publish(StoreRequest) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

publishWithRetry(MessagingService, TopicId, RetryStrategy, byte[]...) - Static method in class co.cask.cdap.messaging.MessagingServices

putRawId(long, short, long, short, byte[], int) - Static method in class co.cask.cdap.messaging.data.MessageId

Computes the message raw ID and store it in the given byte array.

R

RAW_ID_SIZE - Static variable in class co.cask.cdap.messaging.data.MessageId

RawMessage - Class in co.cask.cdap.messaging.data

Represents a unique message in the messaging system.

RawMessage(byte[], byte[]) - Constructor for class co.cask.cdap.messaging.data.RawMessage

RawMessageTableEntry - Class in co.cask.cdap.messaging.store

Container class that contains raw bytes corresponding to an entry in the Message Table.

RawMessageTableEntry() - Constructor for class co.cask.cdap.messaging.store.RawMessageTableEntry

RawPayloadTableEntry - Class in co.cask.cdap.messaging.store

Container class for raw bytes corresponding to key, value of the Payload Table.

RawPayloadTableEntry() - Constructor for class co.cask.cdap.messaging.store.RawPayloadTableEntry

read(byte[], byte[]) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

Read the RawMessageTableEntrys given a key range.

read(byte[], byte[], int) - Method in class co.cask.cdap.messaging.store.AbstractPayloadTable

Read the RawPayloadTableEntrys given a key range.

read(byte[], byte[], int) - Method in class co.cask.cdap.messaging.store.leveldb.LevelDBPayloadTable

rollback(TopicId, RollbackDetail) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

rollback(TopicId, RollbackDetail) - Method in interface co.cask.cdap.messaging.MessagingService

Rollbacks messages published to the given topic with the given transaction.

rollback(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.StoreHandler

rollback(TopicId, RollbackDetail) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

rollback(byte[], byte[], byte[]) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

Rollback the transactionally published messages in the Table in the given key range.

rollback(TopicMetadata, RollbackDetail) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

rollback(TopicMetadata, RollbackDetail) - Method in interface co.cask.cdap.messaging.store.MessageTable

Rollback entries stored earlier, as deleted, under the given topic based on the given information.

RollbackDetail - Interface in co.cask.cdap.messaging

This interface represents information needed to rollback message published transactionally.

S

SCHEMA - Static variable in class co.cask.cdap.messaging.Schemas.V1.ConsumeRequest

SCHEMA - Static variable in class co.cask.cdap.messaging.Schemas.V1.ConsumeResponse

SCHEMA - Static variable in class co.cask.cdap.messaging.Schemas.V1.PublishRequest

SCHEMA - Static variable in class co.cask.cdap.messaging.Schemas.V1.PublishResponse

Schemas - Class in co.cask.cdap.messaging

Helper class for getting various Schema used by the messaging system.

Schemas.V1 - Class in co.cask.cdap.messaging

Contains Schema for V1 protocol.

Schemas.V1() - Constructor for class co.cask.cdap.messaging.Schemas.V1

Schemas.V1.ConsumeRequest - Class in co.cask.cdap.messaging

Contains schema for consume request.

Schemas.V1.ConsumeRequest() - Constructor for class co.cask.cdap.messaging.Schemas.V1.ConsumeRequest

Schemas.V1.ConsumeResponse - Class in co.cask.cdap.messaging

Contains schema for consume response.

Schemas.V1.ConsumeResponse() - Constructor for class co.cask.cdap.messaging.Schemas.V1.ConsumeResponse

Schemas.V1.PublishRequest - Class in co.cask.cdap.messaging

Contains schema for publish request.

Schemas.V1.PublishRequest() - Constructor for class co.cask.cdap.messaging.Schemas.V1.PublishRequest

Schemas.V1.PublishResponse - Class in co.cask.cdap.messaging

Contains schema for publish response.

Schemas.V1.PublishResponse() - Constructor for class co.cask.cdap.messaging.Schemas.V1.PublishResponse

set(byte[], byte[], byte[]) - Method in class co.cask.cdap.messaging.store.RawMessageTableEntry

set(byte[], byte[]) - Method in class co.cask.cdap.messaging.store.RawPayloadTableEntry

setLimit(int) - Method in class co.cask.cdap.messaging.MessageFetcher

Sets the maximum limit on number of messages to be fetched.

setStartMessage(byte[], boolean) - Method in class co.cask.cdap.messaging.MessageFetcher

Setup the message fetching starting point based on the given message id.

setStartTime(long) - Method in class co.cask.cdap.messaging.MessageFetcher

Setup the message fetching start time (publish time).

setTransaction(Long) - Method in class co.cask.cdap.messaging.client.StoreRequestBuilder

Sets the transaction write pointer to be used for the request.

setTransaction(Transaction) - Method in class co.cask.cdap.messaging.MessageFetcher

Sets the transaction to use for fetching.

shutDown() - Method in class co.cask.cdap.messaging.server.MessagingHttpService

shutDown() - Method in class co.cask.cdap.messaging.service.CoreMessagingService

startUp() - Method in class co.cask.cdap.messaging.server.MessagingHttpService

startUp() - Method in class co.cask.cdap.messaging.service.CoreMessagingService

store(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.StoreHandler

store(Iterator<? extends MessageTable.Entry>) - Method in class co.cask.cdap.messaging.store.AbstractMessageTable

store(Iterator<? extends PayloadTable.Entry>) - Method in class co.cask.cdap.messaging.store.AbstractPayloadTable

store(Iterator<? extends MessageTable.Entry>) - Method in interface co.cask.cdap.messaging.store.MessageTable

Stores a list of entries to the message table under the given topic.

store(Iterator<? extends PayloadTable.Entry>) - Method in interface co.cask.cdap.messaging.store.PayloadTable

Stores a list of entries to the payload table under the given topic.

StoreHandler - Class in co.cask.cdap.messaging.server

A netty http handler for handling message storage REST API for the messaging system.

storePayload(StoreRequest) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

storePayload(StoreRequest) - Method in interface co.cask.cdap.messaging.MessagingService

Stores a list of messages to the messaging system.

storePayload(StoreRequest) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

StoreRequest - Class in co.cask.cdap.messaging

This class represents messages to be store to the messaging system.

StoreRequest(TopicId, boolean, long) - Constructor for class co.cask.cdap.messaging.StoreRequest

StoreRequestBuilder - Class in co.cask.cdap.messaging.client

A builder to create StoreRequest instances.

T

TableFactory - Interface in co.cask.cdap.messaging.store

A factory to create instances of MessageTable, PayloadTable and MetadataTable.

TopicMetadata - Class in co.cask.cdap.messaging

Represents metadata about a messaging topic.

TopicMetadata(TopicId, Map<String, String>) - Constructor for class co.cask.cdap.messaging.TopicMetadata

Creates a new instance for the given topic with the associated properties.

TopicMetadata(TopicId, Map<String, String>, boolean) - Constructor for class co.cask.cdap.messaging.TopicMetadata

Creates a new instance for the given topic with the associated properties.

TopicMetadata(TopicId, Object...) - Constructor for class co.cask.cdap.messaging.TopicMetadata

Creates a new instance for the given topic with the associated properties.

toString() - Method in class co.cask.cdap.messaging.TopicMetadata

TTL_KEY - Static variable in class co.cask.cdap.messaging.TopicMetadata

U

updateTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.client.ClientMessagingService

updateTopic(TopicMetadata) - Method in interface co.cask.cdap.messaging.MessagingService

Updates the metadata of a topic.

updateTopic(HttpRequest, HttpResponder, String, String) - Method in class co.cask.cdap.messaging.server.MetadataHandler

updateTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.service.CoreMessagingService

updateTopic(TopicMetadata) - Method in class co.cask.cdap.messaging.store.hbase.HBaseMetadataTable

updateTopic(TopicMetadata) - Method in interface co.cask.cdap.messaging.store.MetadataTable

Updates the topic properties.

upgradeMessageTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

upgradePayloadTable(String) - Method in class co.cask.cdap.messaging.store.hbase.HBaseTableFactory

A B C D E F G H I L M O P R S T U