Interface AsyncAnalyticsDeferredResultHandle

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

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