Packages

c

io.dataos.spark.writers

DatasetWriter

case class DatasetWriter(name: String, address: String, datasourceWriter: DatasourceWriter) extends Writer with Product with Serializable

A custom implementation of a Writer that uses a specific DatasourceWriter to write data from a DataFrame to a specified data source.

name

The name of the data source writer.

address

The address of the data source.

datasourceWriter

The DatasourceWriter implementation responsible for writing data to the specified data source.

Linear Supertypes
Product, Equals, Writer, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DatasetWriter
  2. Product
  3. Equals
  4. Writer
  5. Serializable
  6. Serializable
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DatasetWriter(name: String, address: String, datasourceWriter: DatasourceWriter)

    name

    The name of the data source writer.

    address

    The address of the data source.

    datasourceWriter

    The DatasourceWriter implementation responsible for writing data to the specified data source.

Type Members

  1. case class MissingWriterArgumentException(message: String = "", cause: Throwable = None.orNull) extends Exception with Product with Serializable
    Definition Classes
    Writer

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. val address: String
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. val datasourceWriter: DatasourceWriter
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def getMetastoreUrl(addressInfo: Option[AddressInfo]): String

    Get the metastore URL from the provided AddressInfo.

    Get the metastore URL from the provided AddressInfo.

    addressInfo

    An optional AddressInfo that contains the connection information.

    returns

    The metastore URL as a String.

    Definition Classes
    Writer
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. def mergeStreamingConfig(streamingConfig: Option[Streaming], outputOpts: Map[String, AnyRef]): Streaming

    Merge the streaming configuration with the output options for streaming queries.

    Merge the streaming configuration with the output options for streaming queries. This method is used to combine options from both streamingConfig and outputOptions. If the streamingConfig is None, it uses options from the outputOptions and applies default values as needed.

    streamingConfig

    Optional streaming configuration for the streaming query.

    outputOpts

    Output options for the writer.

    returns

    A Streaming object containing the merged streaming configuration.

    Definition Classes
    Writer
  14. val name: String
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. def setMandatoryArguments(mandatoryArgs: String*): Unit

    Set the mandatory arguments required by the writer implementation.

    Set the mandatory arguments required by the writer implementation.

    mandatoryArgs

    The names of mandatory arguments as varargs.

    Attributes
    protected
    Definition Classes
    Writer
  19. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  20. def validateMandatoryArguments(outputOptions: Map[String, Any]): Unit

    Validate if all mandatory arguments are present in the outputOptions map.

    Validate if all mandatory arguments are present in the outputOptions map. If any argument is missing, it throws a MissingWriterArgumentException.

    outputOptions

    The output options map containing the configuration for the writer.

    Definition Classes
    Writer
    Exceptions thrown

    MissingWriterArgumentException if any mandatory argument is missing.

  21. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  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. def write(dataFrame: DataFrame): Unit

    Writes the data from the DataFrame to the specified data source using the provided DatasourceWriter.

    Writes the data from the DataFrame to the specified data source using the provided DatasourceWriter.

    dataFrame

    The DataFrame containing the data to be written.

    Definition Classes
    DatasetWriter → Writer
  25. def writeStream(dataFrame: DataFrame, streamingConfig: Option[Streaming]): StreamingQuery

    Writes the streaming data from the DataFrame to the specified data source using the provided DatasourceWriter.

    Writes the streaming data from the DataFrame to the specified data source using the provided DatasourceWriter.

    dataFrame

    The DataFrame containing the streaming data to be written.

    streamingConfig

    Optional configuration for the streaming query.

    returns

    A StreamingQuery representing the active streaming query.

    Definition Classes
    DatasetWriter → Writer

Inherited from Product

Inherited from Equals

Inherited from Writer

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped