Package com.snowflake.snowpark_java

Class DataFrameWriterAsyncActor

  • public class DataFrameWriterAsyncActor
extends Object
    Provides APIs to execute DataFrameWriter actions asynchronously.
    Since:
    1.2.0

    • 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

        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

        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

        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