Packages

c

io.dataos.spark.readers

ReaderFactory

class ReaderFactory extends AnyRef

The ReaderFactory class is responsible for creating instances of different readers based on the provided InputConfig. It uses the AddressResolver and SparkSecretLoader to resolve addresses and load secrets if required.

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

Instance Constructors

  1. new ReaderFactory(addressResolver: AddressResolver, secretLoader: SparkSecretLoader)

    addressResolver

    The AddressResolver used for resolving addresses.

    secretLoader

    The SparkSecretLoader used for loading secrets.

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()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. def get(name: String, input: InputConfig): Reader

    Get the appropriate reader based on the provided name and InputConfig.

    Get the appropriate reader based on the provided name and InputConfig.

    name

    The name of the reader.

    input

    The InputConfig representing the configuration of the reader.

    returns

    The appropriate Reader instance.

    Exceptions thrown

    io.dataos.spark.exceptions.FlareException if the InputConfig is not supported.

  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def getDatasourceInputReader(name: String, datasourceInput: DatasourceInput): DatasourceReader

    Get the appropriate DatasourceReader based on the provided name and DatasourceInput.

    Get the appropriate DatasourceReader based on the provided name and DatasourceInput.

    name

    The name of the reader.

    datasourceInput

    The DatasourceInput representing the configuration of the reader.

    returns

    The appropriate DatasourceReader instance.

    Exceptions thrown

    io.dataos.spark.exceptions.FlareException if the DatasourceInput is not supported.

  12. def getMinervaInputQueryReader(minervaInput: MinervaInput): MinervaQueryReader

    Get a MinervaQueryReader for the given MinervaInput.

    Get a MinervaQueryReader for the given MinervaInput.

    minervaInput

    The MinervaInput configuration.

    returns

    A MinervaQueryReader instance.

  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  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. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped