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. Protected

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. def action[T](funcName: String)(func: => T): T
    Attributes
    protected
    Annotations
    @inline()
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  7. 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

  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. 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

  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  17. 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

  18. 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

  19. 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

  20. 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

  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

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

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped