@InterfaceStability.Uncommitted @InterfaceAudience.Public public class GenericAnalyticsRequest extends AbstractCouchbaseRequest implements AnalyticsRequest, PrelocatedRequest
Modifier and Type | Field and Description |
---|---|
static int |
NO_PRIORITY |
Modifier | Constructor and Description |
---|---|
protected |
GenericAnalyticsRequest(String query,
boolean jsonFormat,
String bucket,
String username,
String password,
String targetNode,
int priority) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterSpanSet(io.opentracing.Span span)
Use this method to add custom span values on insert.
|
boolean |
isJsonFormat() |
static GenericAnalyticsRequest |
jsonQuery(String jsonQuery,
String bucket,
String username,
String password)
Create a
GenericAnalyticsRequest and mark it as containing a full Analytics query in Json form
(including additional query parameters). |
static GenericAnalyticsRequest |
jsonQuery(String jsonQuery,
String bucket,
String username,
String password,
int priority)
Create a
GenericAnalyticsRequest and mark it as containing a full Analytics query in Json form
(including additional query parameters). |
static GenericAnalyticsRequest |
jsonQuery(String jsonQuery,
String bucket,
String username,
String password,
String targetNode)
Create a
GenericAnalyticsRequest and mark it as containing a full Analytics query in Json form
(including additional query parameters). |
String |
path()
Get path to construct the uri
|
int |
priority() |
String |
query() |
String |
sendTo()
The hostname to send this request to, or null to use
default
node location process . |
static GenericAnalyticsRequest |
simpleStatement(String statement,
String bucket,
String password)
Creates a
GenericAnalyticsRequest and mark it as containing a single simple statement
(e.g. |
static GenericAnalyticsRequest |
simpleStatement(String statement,
String bucket,
String username,
String password)
Creates a
GenericAnalyticsRequest and mark it as containing a single simple statement
(e.g. |
bucket, complete, creationTime, dispatchHostname, dispatchHostname, emit, fail, incrementRetryCount, isActive, lastLocalId, lastLocalId, lastLocalSocket, lastLocalSocket, lastRemoteSocket, lastRemoteSocket, maxRetryDuration, maxRetryDuration, observable, operationId, password, retryAfter, retryAfter, retryCount, retryDelay, retryDelay, span, span, subscriber, succeed, toString, username
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bucket, complete, dispatchHostname, dispatchHostname, emit, fail, incrementRetryCount, isActive, lastLocalId, lastLocalId, lastLocalSocket, lastLocalSocket, lastRemoteSocket, lastRemoteSocket, maxRetryDuration, maxRetryDuration, observable, operationId, password, retryAfter, retryAfter, retryCount, retryDelay, retryDelay, span, span, subscriber, succeed, username
creationTime
public static final int NO_PRIORITY
protected void afterSpanSet(io.opentracing.Span span)
AbstractCouchbaseRequest
afterSpanSet
in class AbstractCouchbaseRequest
public String query()
public int priority()
public boolean isJsonFormat()
public String sendTo()
PrelocatedRequest
node location process
.sendTo
in interface PrelocatedRequest
public static GenericAnalyticsRequest simpleStatement(String statement, String bucket, String password)
GenericAnalyticsRequest
and mark it as containing a single simple statement
(e.g. "SELECT * FROM default").statement
- the Analytics query statement to perform.bucket
- the bucket on which to search.password
- the password for the target bucket.GenericAnalyticsRequest
for this simple statement.public static GenericAnalyticsRequest simpleStatement(String statement, String bucket, String username, String password)
GenericAnalyticsRequest
and mark it as containing a single simple statement
(e.g. "SELECT * FROM default").statement
- the Analytics query statement to perform.bucket
- the bucket on which to search.username
- the user authorized for bucket access.password
- the password for the user.GenericAnalyticsRequest
for this simple statement.public static GenericAnalyticsRequest jsonQuery(String jsonQuery, String bucket, String username, String password, int priority)
GenericAnalyticsRequest
and mark it as containing a full Analytics query in Json form
(including additional query parameters).
The simplest form of such a query is a single statement encapsulated in a json query object:
{"statement":"SELECT * FROM default"}.
jsonQuery
- the Analytics query in json form.bucket
- the bucket on which to perform the query.password
- the password for the target bucket.GenericAnalyticsRequest
for this full query.public static GenericAnalyticsRequest jsonQuery(String jsonQuery, String bucket, String username, String password)
GenericAnalyticsRequest
and mark it as containing a full Analytics query in Json form
(including additional query parameters).
The simplest form of such a query is a single statement encapsulated in a json query object:
{"statement":"SELECT * FROM default"}.
jsonQuery
- the Analytics query in json form.bucket
- the bucket on which to perform the query.password
- the password for the target bucket.GenericAnalyticsRequest
for this full query.public static GenericAnalyticsRequest jsonQuery(String jsonQuery, String bucket, String username, String password, String targetNode)
GenericAnalyticsRequest
and mark it as containing a full Analytics query in Json form
(including additional query parameters).
The simplest form of such a query is a single statement encapsulated in a json query object:
{"statement":"SELECT * FROM default"}.
jsonQuery
- the Analytics query in json form.bucket
- the bucket on which to perform the query.username
- the username authorized for bucket access.password
- the password for the user.targetNode
- the node on which to execute this request (or null to let the core locate and choose one).GenericAnalyticsRequest
for this full query.public String path()
AnalyticsRequest
path
in interface AnalyticsRequest
Copyright © 2021 Couchbase, Inc.. All rights reserved.