c

com . snowflake . snowpark

DataFrameWriterAsyncActor

class DataFrameWriterAsyncActor extends AnyRef

Provides APIs to execute DataFrameWriter actions asynchronously.

Since

0.11.0

Linear Supertypes
AnyRef , Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DataFrameWriterAsyncActor
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def != ( arg0: Any ) : Boolean
    Definition Classes
    AnyRef → Any
  2. final def ## () : Int
    Definition Classes
    AnyRef → Any
  3. final def == ( arg0: Any ) : Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf [ T0 ] : T0
    Definition Classes
    Any
  5. def clone () : AnyRef
    Attributes
    protected[ lang ]
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... ) @native () @HotSpotIntrinsicCandidate ()
  6. def csv ( path: String ) : TypedAsyncJob [ WriteFileResult ]

    Executes DataFrameWriter.csv asynchronously.

    Executes DataFrameWriter.csv asynchronously.

    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

  7. final def eq ( arg0: AnyRef ) : Boolean
    Definition Classes
    AnyRef
  8. def equals ( arg0: Any ) : Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass () : Class [_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native () @HotSpotIntrinsicCandidate ()
  10. def hashCode () : Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native () @HotSpotIntrinsicCandidate ()
  11. final def isInstanceOf [ T0 ] : Boolean
    Definition Classes
    Any
  12. def json ( path: String ) : TypedAsyncJob [ WriteFileResult ]

    Executes DataFrameWriter.json asynchronously.

    Executes DataFrameWriter.json asynchronously.

    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

  13. final def ne ( arg0: AnyRef ) : Boolean
    Definition Classes
    AnyRef
  14. final def notify () : Unit
    Definition Classes
    AnyRef
    Annotations
    @native () @HotSpotIntrinsicCandidate ()
  15. final def notifyAll () : Unit
    Definition Classes
    AnyRef
    Annotations
    @native () @HotSpotIntrinsicCandidate ()
  16. def parquet ( path: String ) : TypedAsyncJob [ WriteFileResult ]

    Executes DataFrameWriter.parquet asynchronously.

    Executes DataFrameWriter.parquet asynchronously.

    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

  17. def saveAsTable ( multipartIdentifier: List [ String ] ) : TypedAsyncJob [ Unit ]

    Executes DataFrameWriter.saveAsTable asynchronously.

    Executes DataFrameWriter.saveAsTable asynchronously.

    multipartIdentifier

    A list 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

    0.11.0

  18. def saveAsTable ( multipartIdentifier: Seq [ String ] ) : TypedAsyncJob [ Unit ]

    Executes DataFrameWriter.saveAsTable asynchronously.

    Executes DataFrameWriter.saveAsTable asynchronously.

    multipartIdentifier

    A sequence of strings that specify the database name, schema name, and table name (e.g. Seq("database_name", "schema_name", "table_name") ).

    returns

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

    Since

    0.11.0

  19. def saveAsTable ( tableName: String ) : TypedAsyncJob [ Unit ]

    Executes DataFrameWriter.saveAsTable asynchronously.

    Executes DataFrameWriter.saveAsTable asynchronously.

    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

    0.11.0

  20. final def synchronized [ T0 ] ( arg0: ⇒ T0 ) : T0
    Definition Classes
    AnyRef
  21. def toString () : String
    Definition Classes
    AnyRef → Any
  22. final def wait ( arg0: Long , arg1: Int ) : Unit
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... )
  23. final def wait ( arg0: Long ) : Unit
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... ) @native ()
  24. final def wait () : Unit
    Definition Classes
    AnyRef
    Annotations
    @throws ( ... )

Deprecated Value Members

  1. def finalize () : Unit
    Attributes
    protected[ lang ]
    Definition Classes
    AnyRef
    Annotations
    @throws ( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped