Skip to content

Commit

Permalink
Remove deprecated config setup functions (#12486)
Browse files Browse the repository at this point in the history
These were deprecated since v 32.
  • Loading branch information
findepi authored Sep 16, 2024
1 parent 9faf3d4 commit 4282c45
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 46 deletions.
19 changes: 0 additions & 19 deletions datafusion/core/src/execution/context/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -312,13 +312,6 @@ impl SessionContext {
Self::new_with_config_rt(config, runtime)
}

/// Creates a new `SessionContext` using the provided
/// [`SessionConfig`] and a new [`RuntimeEnv`].
#[deprecated(since = "32.0.0", note = "Use SessionContext::new_with_config")]
pub fn with_config(config: SessionConfig) -> Self {
Self::new_with_config(config)
}

/// Creates a new `SessionContext` using the provided
/// [`SessionConfig`] and a [`RuntimeEnv`].
///
Expand All @@ -341,13 +334,6 @@ impl SessionContext {
Self::new_with_state(state)
}

/// Creates a new `SessionContext` using the provided
/// [`SessionConfig`] and a [`RuntimeEnv`].
#[deprecated(since = "32.0.0", note = "Use SessionState::new_with_config_rt")]
pub fn with_config_rt(config: SessionConfig, runtime: Arc<RuntimeEnv>) -> Self {
Self::new_with_config_rt(config, runtime)
}

/// Creates a new `SessionContext` using the provided [`SessionState`]
pub fn new_with_state(state: SessionState) -> Self {
Self {
Expand Down Expand Up @@ -404,11 +390,6 @@ impl SessionContext {
ctx
}

/// Creates a new `SessionContext` using the provided [`SessionState`]
#[deprecated(since = "32.0.0", note = "Use SessionContext::new_with_state")]
pub fn with_state(state: SessionState) -> Self {
Self::new_with_state(state)
}
/// Returns the time this `SessionContext` was created
pub fn session_start_time(&self) -> DateTime<Utc> {
self.session_start_time
Expand Down
27 changes: 0 additions & 27 deletions datafusion/core/src/execution/session_state.rs
Original file line number Diff line number Diff line change
Expand Up @@ -258,17 +258,6 @@ impl SessionState {
.build()
}

/// Returns new [`SessionState`] using the provided
/// [`SessionConfig`] and [`RuntimeEnv`].
#[deprecated(since = "32.0.0", note = "Use SessionStateBuilder")]
pub fn with_config_rt(config: SessionConfig, runtime: Arc<RuntimeEnv>) -> Self {
SessionStateBuilder::new()
.with_config(config)
.with_runtime_env(runtime)
.with_default_features()
.build()
}

/// Returns new [`SessionState`] using the provided
/// [`SessionConfig`], [`RuntimeEnv`], and [`CatalogProviderList`]
#[deprecated(since = "40.0.0", note = "Use SessionStateBuilder")]
Expand All @@ -285,22 +274,6 @@ impl SessionState {
.build()
}

/// Returns new [`SessionState`] using the provided
/// [`SessionConfig`] and [`RuntimeEnv`].
#[deprecated(since = "32.0.0", note = "Use SessionStateBuilder")]
pub fn with_config_rt_and_catalog_list(
config: SessionConfig,
runtime: Arc<RuntimeEnv>,
catalog_list: Arc<dyn CatalogProviderList>,
) -> Self {
SessionStateBuilder::new()
.with_config(config)
.with_runtime_env(runtime)
.with_catalog_list(catalog_list)
.with_default_features()
.build()
}

pub(crate) fn resolve_table_ref(
&self,
table_ref: impl Into<TableReference>,
Expand Down

0 comments on commit 4282c45

Please sign in to comment.