Interface AsyncAnalyticsDeferredResultHandle
- All Known Implementing Classes:
DefaultAsyncAnalyticsDeferredResultHandle
@Experimental @Public public interface AsyncAnalyticsDeferredResultHandle
An async handle to fetch the status and results of a deferred
Analytics Query
- Since:
- 2.7.2
- Author:
- Subhashni Balakrishnan
-
Method Summary
Modifier and Type Method Description String
getResultHandleUri()
String
getStatusHandleUri()
rx.Observable<AsyncAnalyticsQueryRow>
rows()
rx.Observable<AsyncAnalyticsQueryRow>
rows(long timeout, TimeUnit timeunit)
rx.Observable<String>
status()
rx.Observable<String>
status(long timeout, TimeUnit timeunit)
-
Method Details
-
getStatusHandleUri
-
getResultHandleUri
-
rows
rx.Observable<AsyncAnalyticsQueryRow> rows()- Returns:
- an async stream of each row resulting from the query (empty if fatal errors occurred) with custom timeout for deferred queries since it does a later fetch. If no timeout is specified, it uses the default query timeout. If the results are not yet available, throws
-
rows
- Returns:
- an async stream of each row resulting from the deferrred query (empty if fatal errors occurred) with custom timeout for deferred queries since it does a later fetch. If no timeout is specified, it uses the default query timeout.
-
status
rx.Observable<String> status()- Returns:
- the current status of the query execution retrieved from the server with default timeout
-
status
- Returns:
- the current status of the query execution retrieved from the server with custom timeout
-