| Package | Description |
|---|---|
| co.cask.cdap.messaging.client |
| Modifier and Type | Method and Description |
|---|---|
StoreRequestBuilder |
StoreRequestBuilder.addPayloads(byte[]... payloads)
Adds a list of byte arrays as the payloads of the request.
|
StoreRequestBuilder |
StoreRequestBuilder.addPayloads(Iterator<byte[]> payloads)
Adds a list of byte arrays as the payloads of the request.
|
StoreRequestBuilder |
StoreRequestBuilder.addPayloads(String... payloads)
Adds a list of Strings as the payloads of the request.
|
static StoreRequestBuilder |
StoreRequestBuilder.of(co.cask.cdap.proto.id.TopicId topicId)
Creates a new
StoreRequestBuilder instance. |
StoreRequestBuilder |
StoreRequestBuilder.setTransaction(Long txWritePointer)
Sets the transaction write pointer to be used for the request.
|
Copyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.