com.snowflake.snowpark_java

Class DataFrameWriterAsyncActor

java.lang.Object

com.snowflake.snowpark_java.DataFrameWriterAsyncActor

public class DataFrameWriterAsyncActor
extends Object

Provides APIs to execute DataFrameWriter actions asynchronously.

Since:

1.2.0

Method Summary

Modifier and Type	Method and Description
TypedAsyncJob<WriteFileResult>	csv(String path) Executes `DataFrameWriter.csv()` asynchronously.
TypedAsyncJob<WriteFileResult>	json(String path) Executes `DataFrameWriter.json()` asynchronously.
TypedAsyncJob<WriteFileResult>	parquet(String path) Executes `DataFrameWriter.parquet()` asynchronously.
TypedAsyncJob<Void>	saveAsTable(String tableName) Executes `DataFrameWriter.saveAsTable` asynchronously.
TypedAsyncJob<Void>	saveAsTable(String[] multipartIdentifier) Executes `DataFrameWriter.saveAsTable` asynchronously.

Methods inherited from class java.lang.Object

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

Method Detail

saveAsTable

public TypedAsyncJob<Void> saveAsTable(String tableName)

Executes `DataFrameWriter.saveAsTable` asynchronously.

Parameters:

tableName - Name of the table where the data should be saved.

Returns:

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

Since:

1.2.0

saveAsTable

public TypedAsyncJob<Void> saveAsTable(String[] multipartIdentifier)

Executes `DataFrameWriter.saveAsTable` asynchronously.

Parameters:

multipartIdentifier - An array of strings that specify the database name, schema name, and table name.

Returns:

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

Since:

1.2.0

csv

@PublicPreview
public TypedAsyncJob<WriteFileResult> csv(String path)

Executes `DataFrameWriter.csv()` asynchronously.

Parameters:

path - The path (including the stage name) to the CSV file.

Returns:

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

Since:

1.5.0

json

@PublicPreview
public TypedAsyncJob<WriteFileResult> json(String path)

Executes `DataFrameWriter.json()` asynchronously.

Parameters:

path - The path (including the stage name) to the JSON file.

Returns:

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

Since:

1.5.0

parquet

@PublicPreview
public TypedAsyncJob<WriteFileResult> parquet(String path)

Executes `DataFrameWriter.parquet()` asynchronously.

Parameters:

path - The path (including the stage name) to the PARQUET file.

Returns:

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

Since:

1.5.0