Skip to content

Commit 0a39479

Browse files
committed
Rename channel manager to channel resolver
1 parent 0eae0ea commit 0a39479

File tree

5 files changed

+5
-5
lines changed

5 files changed

+5
-5
lines changed
File renamed without changes.

src/distributed_ext.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use crate::channel_manager_ext::set_distributed_channel_resolver;
1+
use crate::channel_resolver_ext::set_distributed_channel_resolver;
22
use crate::config_extension_ext::{
33
set_distributed_option_extension, set_distributed_option_extension_from_headers,
44
};

src/execution_plans/arrow_flight_read.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use crate::channel_manager_ext::get_distributed_channel_resolver;
1+
use crate::channel_resolver_ext::get_distributed_channel_resolver;
22
use crate::config_extension_ext::ContextGrpcMetadata;
33
use crate::errors::{map_flight_to_datafusion_error, map_status_to_datafusion_error};
44
use crate::execution_plans::StageExec;

src/execution_plans/stage.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use crate::channel_manager_ext::get_distributed_channel_resolver;
1+
use crate::channel_resolver_ext::get_distributed_channel_resolver;
22
use crate::{ArrowFlightReadExec, ChannelResolver, PartitionIsolatorExec};
33
use datafusion::common::{exec_err, internal_err};
44
use datafusion::error::{DataFusionError, Result};

src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
#![deny(clippy::all)]
22

3-
mod channel_manager_ext;
3+
mod channel_resolver_ext;
44
mod common;
55
mod config_extension_ext;
66
mod distributed_ext;
@@ -13,7 +13,7 @@ mod protobuf;
1313
#[cfg(any(feature = "integration", test))]
1414
pub mod test_utils;
1515

16-
pub use channel_manager_ext::{BoxCloneSyncChannel, ChannelResolver};
16+
pub use channel_resolver_ext::{BoxCloneSyncChannel, ChannelResolver};
1717
pub use distributed_ext::DistributedExt;
1818
pub use execution_plans::{
1919
display_stage_graphviz, ArrowFlightReadExec, ExecutionTask, PartitionIsolatorExec, StageExec,

0 commit comments

Comments
 (0)