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 Details

    • getStatusHandleUri

      @Private String getStatusHandleUri()
    • getResultHandleUri

      @Private String 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

      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
    • status

      rx.Observable<String> status​(long timeout, TimeUnit timeunit)
      Returns:
      the current status of the query execution retrieved from the server with custom timeout