com.snowflake.snowpark_java

Class DataFrameAsyncActor

java.lang.Object

com.snowflake.snowpark_java.DataFrameAsyncActor

Direct Known Subclasses:

CopyableDataFrameAsyncActor, UpdatableAsyncActor

public class DataFrameAsyncActor
extends Object

Provides APIs to execute DataFrame actions asynchronously.

Since:

1.2.0

Field Summary

Fields

Modifier and Type	Field and Description
protected com.snowflake.snowpark.Session	session

Method Summary

Modifier and Type	Method and Description
TypedAsyncJob<Row[]>	collect() Executes DataFrame.collect asynchronously.
TypedAsyncJob<Long>	count() Executes DataFrame.count asynchronously.
TypedAsyncJob<Iterator<Row>>	toLocalIterator() Executes DataFrame.toLocalIterator asynchronously.

Methods inherited from class java.lang.Object

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

Field Detail

session

protected final com.snowflake.snowpark.Session session

Method Detail

collect

public TypedAsyncJob<Row[]> collect()

Executes DataFrame.collect asynchronously.

Returns:

A TypedAsyncJob object that you can use to check the status of the action and get the results.

Since:

1.2.0

toLocalIterator

public TypedAsyncJob<Iterator<Row>> toLocalIterator()

Executes DataFrame.toLocalIterator asynchronously.

Returns:

A TypedAsyncJob object that you can use to check the status of the action and get the results.

Since:

1.2.0

count

public TypedAsyncJob<Long> count()

Executes DataFrame.count asynchronously.

Returns:

A TypedAsyncJob object that you can use to check the status of the action and get the results.

Since:

1.2.0