Package 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 Description protected com.snowflake.snowpark.Session
session
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TypedAsyncJob<Row[]>
collect()
ExecutesDataFrame.collect
asynchronously.TypedAsyncJob<Long>
count()
ExecutesDataFrame.count
asynchronously.TypedAsyncJob<Iterator<Row>>
toLocalIterator()
ExecutesDataFrame.toLocalIterator
asynchronously.
-
-
-
Method Detail
-
collect
public TypedAsyncJob<Row[]> collect()
ExecutesDataFrame.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()
ExecutesDataFrame.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()
ExecutesDataFrame.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
-
-