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.Sessionsession
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TypedAsyncJob<Row[]>collect()ExecutesDataFrame.collectasynchronously.TypedAsyncJob<Long>count()ExecutesDataFrame.countasynchronously.TypedAsyncJob<Iterator<Row>>toLocalIterator()ExecutesDataFrame.toLocalIteratorasynchronously.
-
-
-
Method Detail
-
collect
public TypedAsyncJob<Row[]> collect()
ExecutesDataFrame.collectasynchronously.- 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.toLocalIteratorasynchronously.- 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.countasynchronously.- Returns:
- A TypedAsyncJob object that you can use to check the status of the action and get the results.
- Since:
- 1.2.0
-
-