Struct IcebergCommon

pub struct IcebergCommon {

    pub catalog_type: Option<String>,
    pub region: Option<String>,
    pub endpoint: Option<String>,
    pub access_key: String,
    pub secret_key: String,
    pub warehouse_path: Option<String>,
    pub catalog_name: Option<String>,
    pub catalog_uri: Option<String>,
    pub database_name: Option<String>,
    pub table_name: String,
    pub credential: Option<String>,
    pub token: Option<String>,
    pub oauth2_server_uri: Option<String>,
    pub scope: Option<String>,
    pub path_style_access: Option<bool>,
}

Fields

catalog_type: Option<String>

region: Option<String>

endpoint: Option<String>

access_key: String

secret_key: String

warehouse_path: Option<String>

Path of iceberg warehouse, only applicable in storage catalog.

catalog_name: Option<String>

Catalog name, can be omitted for storage catalog, but must be set for other catalogs.

catalog_uri: Option<String>

URI of iceberg catalog, only applicable in rest catalog.

database_name: Option<String>

table_name: String

Full name of table, must include schema name.

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.

path_style_access: Option<bool>

Implementations

impl IcebergCommon

pub fn full_table_name(&self) -> ConnectorResult<TableIdentifier>

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

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

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, 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.

impl IcebergCommon

pub fn full_table_name_v2(&self) -> ConnectorResult<TableIdent>

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

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_v2( &self, java_catalog_props: &HashMap<String, String>, ) -> ConnectorResult<TableV2>

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_v2_with_metadata( &self, metadata: TableMetadata, java_catalog_props: &HashMap<String, String>, ) -> ConnectorResult<TableV2>

impl IcebergCommon

pub fn catalog_type(&self) -> &str

pub fn catalog_name(&self) -> String

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

For both V1 and V2.

Trait Implementations

impl Clone for IcebergCommon

fn clone(&self) -> IcebergCommon

Returns a copy 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 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