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
All Methods Instance Methods Abstract Methods 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 Detail
-
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
rx.Observable<AsyncAnalyticsQueryRow> rows(long timeout, TimeUnit timeunit)
- 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
-
-