Package com.snowflake.snowpark_java

Class TypedAsyncJob<T>

  • public class TypedAsyncJob<T>
extends AsyncJob
    Provides a way to track an asynchronously executed action in a DataFrame.

    To get the result of the action (e.g. the number of results from a `count()` action or an Array of Row objects from the `collect()` action), call the getResult method.

    To perform an action on a DataFrame asynchronously, call an action method on the DataFrameAsyncActor object returned by DataFrame.async.

    Since:
    1.2.0

    • Method Detail

      • getResult

        public T getResult​(int maxWaitTimeInSeconds)
        Returns the result for the specific DataFrame action.
        Parameters:
        maxWaitTimeInSeconds - The maximum number of seconds to wait for the query to complete before attempting to retrieve the results.
        Returns:
        The result
        Since:
        1.2.0

      • getResult

        public T getResult()
        Returns the result for the specific DataFrame action.

        The max waiting time is the value of `snowpark_request_timeout_in_seconds` configuration property.

        Returns:
        The result
        Since:
        1.2.0