pub async fn create_datasink( &self, name: String, destination: String, ) -> Result<CreateDatasinkResponse, KineticaError>
Create a data sink
Creates a data sink, which contains the destination information for a data sink that is external to the database.
name- Name of the data sink to be created.destination- Destination for the output data in format ‘storage_provider_type://path[:port]’.Supported storage provider types are ‘azure’, ‘gcs’, ‘hdfs’, ‘http’, ‘https’, ‘jdbc’, ‘kafka’, and ‘s3’.
pub async fn create_datasink_with_opts( &self, name: String, destination: String, options: CreateDatasinkRequestOptions, ) -> Result<CreateDatasinkResponse, KineticaError>
Create a data sink
Creates a data sink, which contains the destination information for a data sink that is external to the database.
name- Name of the data sink to be created.destination- Destination for the output data in format ‘storage_provider_type://path[:port]’.Supported storage provider types are ‘azure’, ‘gcs’, ‘hdfs’, ‘http’, ‘https’, ‘jdbc’, ‘kafka’, and ‘s3’.
options- The optional parameters; any left unset take the server’s defaults.
pub async fn create_datasink_raw( &self, request: &CreateDatasinkRequest, ) -> Result<CreateDatasinkResponse, KineticaError>
Sends a pre-built CreateDatasinkRequest to the /create/datasink endpoint.
pub async fn create_datasink_from_url( &self, url: &str, request: &CreateDatasinkRequest, ) -> Result<CreateDatasinkResponse, KineticaError>
Sends a pre-built CreateDatasinkRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.