tabsdatak.conn.druid

AzBlobLocation	Azure Blob staging area for DruidDest.
CloudLocation	Abstract base for a DruidDest cloud staging area.
CredentialsSpec
DatasourceSpec
DestCfgKey
DestCfgSpec
DruidDest	Druid destination for @subscriber -- one slot per datasource.
DruidDestConn	Druid Overlord connection used by DruidDest.
DruidTableNameSpec
DruidTableNamesSpec
IfTableExistsSpec
S3Location	S3 staging area for DruidDest.
SegmentGranularitySpec
UrlSpec

---

CredentialsSpec

type_alias

CredentialsSpec: UserPassword

---

DatasourceSpec

type_alias

DatasourceSpec: str

---

DestCfgKey

type_alias

DestCfgKey: Literal['druid.logging_level', 'druid.poll_interval_seconds', 'druid.retry_attempts', 'druid.retry_backoff_seconds']

---

DestCfgSpec

type_alias

DestCfgSpec: Mapping[DestCfgKey, Any]

Resolved type:

Mapping[Literal['druid.logging_level', 'druid.poll_interval_seconds', 'druid.retry_attempts', 'druid.retry_backoff_seconds'], Any]

---

DruidTableNameSpec

type_alias

DruidTableNameSpec: DatasourceSpec

Resolved type:

str

---

DruidTableNamesSpec

type_alias

DruidTableNamesSpec: list[DruidTableNameSpec]

Resolved type:

list[str]

---

IfTableExistsSpec

type_alias

IfTableExistsSpec: Literal['append', 'replace']

---

SegmentGranularitySpec

type_alias

SegmentGranularitySpec: Literal['ALL', 'NONE', 'SECOND', 'MINUTE', 'FIFTEEN_MINUTE', 'THIRTY_MINUTE', 'HOUR', 'SIX_HOUR', 'DAY', 'WEEK', 'MONTH', 'QUARTER', 'YEAR']

---

UrlSpec

type_alias

UrlSpec: StrOrSecretSpec

Resolved type:

str | Secret