Struct IcebergCommon 

pub struct IcebergCommon {

    pub catalog_type: Option<String>,
    pub region: Option<String>,
    pub endpoint: Option<String>,
    pub access_key: Option<String>,
    pub secret_key: Option<String>,
    pub gcs_credential: Option<String>,
    pub azblob_account_name: Option<String>,
    pub azblob_account_key: Option<String>,
    pub azblob_endpoint_url: Option<String>,
    pub adlsgen2_account_name: Option<String>,
    pub adlsgen2_account_key: Option<String>,
    pub adlsgen2_endpoint: Option<String>,
    pub warehouse_path: Option<String>,
    pub glue_id: Option<String>,
    pub catalog_name: Option<String>,
    pub catalog_uri: Option<String>,
    pub credential: Option<String>,
    pub token: Option<String>,
    pub oauth2_server_uri: Option<String>,
    pub scope: Option<String>,
    pub rest_signing_region: Option<String>,
    pub rest_signing_name: Option<String>,
    pub rest_sigv4_enabled: Option<bool>,
    pub path_style_access: Option<bool>,
    pub enable_config_load: Option<bool>,
    pub hosted_catalog: Option<bool>,
    pub header: Option<String>,
    pub vended_credentials: Option<bool>,
}

Fields

catalog_type: Option<String>

region: Option<String>

endpoint: Option<String>

access_key: Option<String>

secret_key: Option<String>

gcs_credential: Option<String>

azblob_account_name: Option<String>

azblob_account_key: Option<String>

azblob_endpoint_url: Option<String>

adlsgen2_account_name: Option<String>

adlsgen2_account_key: Option<String>

adlsgen2_endpoint: Option<String>

warehouse_path: Option<String>

Path of iceberg warehouse.

glue_id: Option<String>

AWS Client id, can be omitted for storage catalog or when caller’s AWS account ID matches glue id

catalog_name: Option<String>

Catalog name, default value is risingwave.

catalog_uri: Option<String>

URI of iceberg catalog, only applicable in rest catalog.

credential: Option<String>

Credential for accessing iceberg catalog, only applicable in rest catalog. A credential to exchange for a token in the OAuth2 client credentials flow.

token: Option<String>

token for accessing iceberg catalog, only applicable in rest catalog. A Bearer token which will be used for interaction with the server.

oauth2_server_uri: Option<String>

oauth2_server_uri for accessing iceberg catalog, only applicable in rest catalog. Token endpoint URI to fetch token from if the Rest Catalog is not the authorization server.

scope: Option<String>

scope for accessing iceberg catalog, only applicable in rest catalog. Additional scope for OAuth2.

rest_signing_region: Option<String>

The signing region to use when signing requests to the REST catalog.

rest_signing_name: Option<String>

The signing name to use when signing requests to the REST catalog.

rest_sigv4_enabled: Option<bool>

Whether to use SigV4 for signing requests to the REST catalog.

path_style_access: Option<bool>

enable_config_load: Option<bool>

Enable config load. This parameter set to true will load warehouse credentials from the environment. Only allowed to be used in a self-hosted environment.

hosted_catalog: Option<bool>

This is only used by iceberg engine to enable the hosted catalog.

header: Option<String>

The http header to be used in the catalog requests. Example: catalog.header = "key1=value1;key2=value2;key3=value3" explain the format of the header:

• Each header is a key-value pair, separated by an ‘=’.
• Multiple headers can be specified, separated by a ‘;’.

vended_credentials: Option<bool>

Enable vended credentials for iceberg REST catalog.

Implementations

impl IcebergCommon

pub fn catalog_type(&self) -> &str

pub fn vended_credentials(&self) -> bool

pub fn catalog_name(&self) -> String

pub fn headers(&self) -> ConnectorResult<HashMap<String, String>>

pub fn enable_config_load(&self) -> bool

fn build_jni_catalog_configs( &self, java_catalog_props: &HashMap<String, String>, ) -> ConnectorResult<(HashMap<String, String>, HashMap<String, String>)>

For both V1 and V2.

impl IcebergCommon

pub async fn create_catalog( &self, java_catalog_props: &HashMap<String, String>, ) -> ConnectorResult<Arc<dyn Catalog>>

TODO: remove the arguments and put them into IcebergCommon. Currently the handling in source and sink are different, so pass them separately to be safer.

pub async fn load_table( &self, table: &IcebergTableIdentifier, java_catalog_props: &HashMap<String, String>, ) -> ConnectorResult<Table>

TODO: remove the arguments and put them into IcebergCommon. Currently the handling in source and sink are different, so pass them separately to be safer.

Trait Implementations

impl Clone for IcebergCommon

fn clone(&self) -> IcebergCommon

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IcebergCommon

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IcebergCommon

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl EnforceSecret for IcebergCommon

const ENFORCE_SECRET_PROPERTIES: Set<&'static str>

fn enforce_secret<'a>(prop_iter: impl Iterator<Item = &'a str>) -> Result<()>

fn enforce_one(prop: &str) -> Result<()>

impl PartialEq for IcebergCommon

fn eq(&self, other: &IcebergCommon) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for IcebergCommon

impl StructuralPartialEq for IcebergCommon

impl WithOptions for IcebergCommon