MCPcopy Create free account
hub / github.com/apache/datafusion / set

Method set

datafusion-cli/src/object_storage.rs:355–385  ·  view source on GitHub ↗
(&mut self, key: &str, value: &str)

Source from the content-addressed store, hash-verified

353 }
354
355 fn set(&mut self, key: &str, value: &str) -> Result<()> {
356 let (_key, aws_key) = key.split_once('.').unwrap_or((key, ""));
357 let (key, rem) = aws_key.split_once('.').unwrap_or((aws_key, ""));
358 match key {
359 "access_key_id" => {
360 self.access_key_id.set(rem, value)?;
361 }
362 "secret_access_key" => {
363 self.secret_access_key.set(rem, value)?;
364 }
365 "session_token" => {
366 self.session_token.set(rem, value)?;
367 }
368 "region" => {
369 self.region.set(rem, value)?;
370 }
371 "oss" | "cos" | "endpoint" => {
372 self.endpoint.set(rem, value)?;
373 }
374 "allow_http" => {
375 self.allow_http.set(rem, value)?;
376 }
377 "skip_signature" | "nosign" => {
378 self.skip_signature.set(rem, value)?;
379 }
380 _ => {
381 return config_err!("Config value \"{}\" not found on AwsOptions", rem);
382 }
383 }
384 Ok(())
385 }
386
387 fn entries(&self) -> Vec<ConfigEntry> {
388 struct Visitor(Vec<ConfigEntry>);

Callers 2

reset_hintMethod · 0.45
hintMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected