Type Members

1.  case class BigqueryAddress(project: String, dataset: String, table: String) extends Product with Serializable

   Represents an address for a BigQuery table in a specific project and dataset.

   Represents an address for a BigQuery table in a specific project and dataset.

   project

   The project ID.

   dataset

   The dataset ID.

   table

   The table ID.

2.  case class ElasticsearchAddress(nodes: Seq[String], index: String, type: String) extends Product with Serializable

   Represents an address for an Elasticsearch index with the specified configuration.

   Represents an address for an Elasticsearch index with the specified configuration.

   nodes

   The Elasticsearch cluster nodes.

   index

   The name of the Elasticsearch index.

   type

   The type of the Elasticsearch index (deprecated in newer versions).

3.  case class EventHubAddress(endpoint: String, eventhubName: String) extends Product with Serializable

   Represents the address for an Event Hub in Azure Event Hubs.

   Represents the address for an Event Hub in Azure Event Hubs.

   endpoint

   The endpoint URL for the Event Hub.

   eventhubName

   The name of the Event Hub.

4.  case class JdbcAddress(connectionUrl: String, table: String) extends Product with Serializable

   Represents the address for a JDBC data source, such as a database table.

   Represents the address for a JDBC data source, such as a database table.

   connectionUrl

   The JDBC connection URL.

   table

   The name of the table.

5.  case class KafkaAddress(servers: Seq[String], topic: String, schemaRegistryUrl: Option[String]) extends Product with Serializable

   Represents the address for a Kafka topic in a Kafka cluster.

   Represents the address for a Kafka topic in a Kafka cluster.

   servers

   The list of Kafka server addresses.

   topic

   The name of the Kafka topic.

   schemaRegistryUrl

   An optional URL for the schema registry.

6.  case class MongoDbAddress(url: List[String], subprotocol: String, database: String, table: String, params: Map[String, String]) extends Product with Serializable

   Represents the address for a MongoDB collection in a MongoDB database.

   Represents the address for a MongoDB collection in a MongoDB database.

   url

   The list of MongoDB connection URLs.

   subprotocol

   The subprotocol to use for the MongoDB connection.

   database

   The name of the MongoDB database.

   table

   The name of the MongoDB collection (table).

   params

   Additional parameters for the MongoDB connection.

7.  case class OpensearchAddress(nodes: Seq[String], index: String) extends Product with Serializable

   Represents an address for an Elasticsearch index with the specified configuration.

   Represents an address for an Elasticsearch index with the specified configuration.

   nodes

   The Elasticsearch cluster nodes.

   index

   The name of the Elasticsearch index.

8.  case class PulsarAddress(serviceUrl: String, adminUrl: String, tenant: String, namespace: String, topic: String) extends Product with Serializable

   Represents the address for a topic in an Apache Pulsar cluster.

   Represents the address for a topic in an Apache Pulsar cluster.

   serviceUrl

   The URL of the Pulsar service.

   adminUrl

   The URL of the Pulsar admin service.

   tenant

   The tenant to which the topic belongs.

   namespace

   The namespace to which the topic belongs.

   topic

   The name of the Pulsar topic.

9.  case class RedisAddress(host: String, port: Int, db: Int, table: String) extends Product with Serializable

   Represents the address for a Redis database.

   Represents the address for a Redis database.

   host

   The host address of the Redis server.

   port

   The port number of the Redis server.

   db

   The index of the Redis database.

   table

   The name of the Redis table.

10.  case class RedshiftAddress(jdbcUrl: String, dir: String, table: String, collection: String) extends Product with Serializable

    Represents the address for a Redshift database.

    Represents the address for a Redshift database.

    jdbcUrl

    The JDBC URL for connecting to the Redshift database.

    dir

    The directory path where the data is stored.

    table

    The name of the Redshift table.

    collection

    The name of the collection in the Redshift database.

11.  case class SnowflakeAddress(url: String, database: String, table: String, warehouse: Option[String]) extends Product with Serializable

    Represents the address for a Snowflake database.

    Represents the address for a Snowflake database.

    url

    The URL for connecting to the Snowflake database.

    database

    The name of the Snowflake database.

    table

    The name of the Snowflake table.

    warehouse

    An optional name of the Snowflake warehouse.