com.snowflake.snowpark_java

Class TypedAsyncJob<T>

java.lang.Object

com.snowflake.snowpark_java.AsyncJob

com.snowflake.snowpark_java.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 Summary

Modifier and Type	Method and Description
T	getResult() Returns the result for the specific DataFrame action.
T	getResult(int maxWaitTimeInSeconds) Returns the result for the specific DataFrame action.

Methods inherited from class com.snowflake.snowpark_java.AsyncJob

cancel, getIterator, getIterator, getQueryId, getRows, getRows, isDone

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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