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 bigqueryAddress(dataosAddress: String): BigqueryAddress

   Resolves a DataOS address to a BigQuery address.

   Resolves a DataOS address to a BigQuery address.

   dataosAddress

   The DataOS address.

   returns

   The BigQuery address.

6.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... ) @native()

7.  val depotServiceClient: DepotServiceClient
8.  def elasticsearchAddress(dataosAddress: String): ElasticsearchAddress

   Resolves a DataOS address to an Elasticsearch address.

   Resolves a DataOS address to an Elasticsearch address.

   dataosAddress

   The DataOS address.

   returns

   The Elasticsearch address.

9.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

10.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

11.  def eventhubAddress(dataosAddress: String): EventHubAddress

    Resolves a DataOS address to an EventHub address.

    Resolves a DataOS address to an EventHub address.

    dataosAddress

    The DataOS address.

    returns

    The EventHub address.

12.  def fileOrDir(datasetAddress: String): String

    Returns the file or directory path for a dataset address.

    Returns the file or directory path for a dataset address.

    datasetAddress

    The dataset address.

    returns

    The file or directory path.

13.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

14.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

15.  def getIcebergCatalogType(info: AddressInfo): Option[String]

    Retrieves the Iceberg catalog type for a depot address.

    Retrieves the Iceberg catalog type for a depot address.

    info

    The AddressInfo.

    returns

    An optional string containing the Iceberg catalog type if present, None otherwise.

16.  def getMetastoreUriForDepot(info: AddressInfo): Option[String]

    Retrieves the metastore URI for a depot address.

    Retrieves the metastore URI for a depot address.

    info

    The AddressInfo.

    returns

    An optional string containing the metastore URI if present, None otherwise.

17.  def getSchemaPath(schema: Option[Schema]): Option[String]

    Gets the schema path for a given optional schema path.

    Gets the schema path for a given optional schema path.

    schema

    The optional schema.

    returns

    An optional string containing the schema path if provided, None otherwise.

18.  def getWarehousePathForDepot(depot: String): String

    Retrieves the warehouse path for a depot address.

    Retrieves the warehouse path for a depot address.

    depot

    The depot address.

    returns

    The absolute warehouse path.

19.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

20.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

21.  def jdbcAddress(dataosAddress: String): JdbcAddress

    Resolves a DataOS address to a JDBC address.

    Resolves a DataOS address to a JDBC address.

    dataosAddress

    The DataOS address.

    returns

    The JDBC address.

22.  def kafkaAddress(dataosAddress: String): KafkaAddress

    Resolves a DataOS address to a Kafka address.

    Resolves a DataOS address to a Kafka address.

    dataosAddress

    The DataOS address.

    returns

    The Kafka address.

23.  def mongoAddress(dataosAddress: String): MongoDbAddress

    Resolves a DataOS address to a MongoDB address.

    Resolves a DataOS address to a MongoDB address.

    dataosAddress

    The DataOS address.

    returns

    The MongoDB address.

24.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

25.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

26.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

27.  def opensearchAddress(dataosAddress: String): OpensearchAddress

    Resolves a DataOS address to an Opensearch address.

    Resolves a DataOS address to an Opensearch address.

    dataosAddress

    The DataOS address.

    returns

    The Opensearch address.

28.  def pulsarAddress(dataosAddress: String): PulsarAddress

    Resolves a DataOS address to a Pulsar address.

    Resolves a DataOS address to a Pulsar address.

    dataosAddress

    The DataOS address.

    returns

    The Pulsar address.

29.  def redisAddress(dataosAddress: String): RedisAddress

    Resolves a DataOS address to a Redis address.

    Resolves a DataOS address to a Redis address.

    dataosAddress

    The DataOS address.

    returns

    The Redis address.

30.  def redshiftAddress(dataosAddress: String): RedshiftAddress

    Resolves a DataOS address to a Redshift address.

    Resolves a DataOS address to a Redshift address.

    dataosAddress

    The DataOS address.

    returns

    The Redshift address.

31.  def resolve(address: String): AddressInfo

    Resolves an address using the depot service client.

    Resolves an address using the depot service client.

    address

    The address to resolve.

    returns

    The resolved AddressInfo.

    Exceptions thrown

    io.dataos.spark.exceptions.FlareException if the resolution fails.

32.  def snowflakeAddress(dataosAddress: String): SnowflakeAddress

    Resolves a DataOS address to a Snowflake address.

    Resolves a DataOS address to a Snowflake address.

    dataosAddress

    The DataOS address.

    returns

    The Snowflake address.

33.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

34.  def toString(): String

    Definition Classes

    AnyRef → Any

35.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

36.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

37.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()