@InterfaceStability.Uncommitted @InterfaceAudience.Public public class DefaultAsyncAnalyticsQueryResult extends Object implements AsyncAnalyticsQueryResult
| Constructor and Description |
|---|
DefaultAsyncAnalyticsQueryResult(rx.Observable<AsyncAnalyticsQueryRow> rows,
rx.Observable<Object> signature,
rx.Observable<AnalyticsMetrics> info,
rx.Observable<JsonObject> errors,
rx.Observable<String> finalStatus,
boolean parsingSuccess,
String requestId,
String clientContextId) |
| Modifier and Type | Method and Description |
|---|---|
String |
clientContextId() |
rx.Observable<JsonObject> |
errors() |
rx.Observable<Boolean> |
finalSuccess()
Asynchronously denotes the success or failure of the query.
|
rx.Observable<AnalyticsMetrics> |
info() |
boolean |
parseSuccess()
Immediately denotes initial parsing success of the query.
|
String |
requestId() |
rx.Observable<AsyncAnalyticsQueryRow> |
rows() |
rx.Observable<Object> |
signature() |
rx.Observable<String> |
status()
Asynchronously returns the final status of the query.
|
public DefaultAsyncAnalyticsQueryResult(rx.Observable<AsyncAnalyticsQueryRow> rows, rx.Observable<Object> signature, rx.Observable<AnalyticsMetrics> info, rx.Observable<JsonObject> errors, rx.Observable<String> finalStatus, boolean parsingSuccess, String requestId, String clientContextId)
public rx.Observable<AsyncAnalyticsQueryRow> rows()
rows in interface AsyncAnalyticsQueryResultpublic rx.Observable<Object> signature()
signature in interface AsyncAnalyticsQueryResultrow. This signature is usually a JsonObject, but could also be any JSON-valid type like a boolean scalar, JsonArray…public rx.Observable<AnalyticsMetrics> info()
info in interface AsyncAnalyticsQueryResultpublic rx.Observable<Boolean> finalSuccess()
AsyncAnalyticsQueryResultAsynchronously denotes the success or failure of the query. It could fail slower than with AsyncAnalyticsQueryResult.parseSuccess(), for example if a fatal error comes up while streaming the results to the client. Receiving a (single) value for finalSuccess means the query is over.
finalSuccess in interface AsyncAnalyticsQueryResultpublic rx.Observable<String> status()
AsyncAnalyticsQueryResultAsynchronously returns the final status of the query. For example, a successful query will return “success” (which is equivalent to AsyncAnalyticsQueryResult.finalSuccess() returning true). Other statuses include (but are not limited to) “fatal” when fatal errors occurred and “timeout” when the query timed out on the server side but not yet on the client side. Receiving a (single) value for status means the query is over.
status in interface AsyncAnalyticsQueryResultpublic boolean parseSuccess()
AsyncAnalyticsQueryResultImmediately denotes initial parsing success of the query.
As rows are processed, it could be that a late failure occurs. See AsyncAnalyticsQueryResult.finalSuccess() for the end of processing status.
parseSuccess in interface AsyncAnalyticsQueryResultpublic rx.Observable<JsonObject> errors()
errors in interface AsyncAnalyticsQueryResultpublic String requestId()
requestId in interface AsyncAnalyticsQueryResultpublic String clientContextId()
clientContextId in interface AsyncAnalyticsQueryResultCopyright © 2015 Couchbase, Inc.