Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
findepi committed Feb 18, 2025
1 parent 042d04b commit cd030cb
Show file tree
Hide file tree
Showing 9 changed files with 3 additions and 193 deletions.
1 change: 0 additions & 1 deletion datafusion/excalibur/lib/src/invoke.rs
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,6 @@ where
>(record)
};
invoke(position, record, out_arg)
// invoke(position, (head_arg, tail_args), out_arg)
},
builder,
)
Expand Down
11 changes: 1 addition & 10 deletions datafusion/excalibur/lib/src/option_ret.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,20 +15,11 @@
// specific language governing permissions and limitations
// under the License.

use crate::builder::{ExArrayBuilder, ExFullResultType};
// use crate::ret_type::ExRetType;
use crate::__private::ExInstantiable;
use crate::builder::{ExArrayBuilder, ExFullResultType};
use arrow::array::ArrayRef;
use arrow::datatypes::DataType;
use datafusion_common::Result;
// impl<T> ExRetType for Option<T>
// where
// T: ExRetType,
// {
// fn data_type() -> DataType {
// T::data_type()
// }
// }

impl<T> ExFullResultType for ((), Option<T>)
where
Expand Down
6 changes: 0 additions & 6 deletions datafusion/excalibur/lib/src/primitives.rs
Original file line number Diff line number Diff line change
Expand Up @@ -51,11 +51,5 @@ macro_rules! primitive_type {
}
}
}

// impl $crate::ret_type::ExRetType for $native_type {
// fn data_type() -> DataType {
// DataType::$dt_option_name
// }
// }
};
}
11 changes: 1 addition & 10 deletions datafusion/excalibur/lib/src/result.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,20 +15,11 @@
// specific language governing permissions and limitations
// under the License.

use crate::builder::{ExArrayBuilder, ExFullResultType};
// use crate::ret_type::ExRetType;
use crate::__private::ExInstantiable;
use crate::builder::{ExArrayBuilder, ExFullResultType};
use arrow::array::ArrayRef;
use arrow::datatypes::DataType;
use datafusion_common::Result;
// impl<T> ExRetType for Result<T>
// where
// T: ExRetType,
// {
// fn data_type() -> DataType {
// T::data_type()
// }
// }

impl<T> ExFullResultType for ((), Result<T>)
where
Expand Down
4 changes: 0 additions & 4 deletions datafusion/excalibur/lib/src/ret_type.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,10 +15,6 @@
// specific language governing permissions and limitations
// under the License.

// pub trait ExRetType {
// fn data_type() -> DataType;
// }

pub type FindExOutArgType<T> = <T as ExFindOutImplementation>::Type;

pub trait ExFindOutImplementation {
Expand Down
4 changes: 1 addition & 3 deletions datafusion/excalibur/lib/src/scalar_udf.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,11 @@
// specific language governing permissions and limitations
// under the License.

use crate::__private::ExInstantiable;
use crate::arg_type_list::ExArgTypeList;
use crate::bridge::ExcaliburScalarUdf;
use crate::builder::{ExArrayBuilder, ExFullResultType};
use crate::invoke::{excalibur_invoke, ApplyList};
// use crate::ret_type::ExRetType;
use crate::__private::ExInstantiable;
use crate::signature::{create_excalibur_signature, ExcaliburSignature};
use arrow::datatypes::DataType;
use datafusion_common::Result;
Expand All @@ -35,7 +34,6 @@ where
T: ExcaliburScalarUdf + Send + Sync + 'static,
T::ArgumentRustTypes: ExArgTypeList,
T::ArgumentRustTypes: ApplyList,
//T::ReturnRustType: ExRetType,
(T::OutArgRustType, T::ReturnRustType): ExFullResultType<
BuilderType: ExArrayBuilder<
OutArg: for<'a> ExInstantiable<
Expand Down
3 changes: 0 additions & 3 deletions datafusion/excalibur/lib/src/signature.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@

use crate::arg_type_list::ExArgTypeList;
use crate::bridge::ExcaliburScalarUdf;
// use crate::ret_type::ExRetType;
use crate::builder::ExFullResultType;
use arrow::datatypes::DataType;
use datafusion_common::Result;
Expand All @@ -28,7 +27,6 @@ pub fn create_excalibur_signature<T>() -> ExcaliburSignature
where
T: ExcaliburScalarUdf,
T::ArgumentRustTypes: ExArgTypeList,
// T::ReturnRustType: ExRetType,
(T::OutArgRustType, T::ReturnRustType): ExFullResultType,
{
ExcaliburSignature {
Expand All @@ -46,7 +44,6 @@ where
}

pub struct ExcaliburSignature {
// For now just constant signature
signature: Signature,
return_type: DataType,
}
Expand Down
2 changes: 0 additions & 2 deletions datafusion/excalibur/lib/src/string.rs
Original file line number Diff line number Diff line change
Expand Up @@ -69,8 +69,6 @@ impl ExArgType for RefStrArgType {
}
}

// TODO implement this in terms of GenericByteArray

impl<'a> ExArrayReader<'a> for &'a StringArray {
type ValueType = &'a str;

Expand Down
154 changes: 0 additions & 154 deletions datafusion/excalibur/lib/tests/str_.rs

This file was deleted.

0 comments on commit cd030cb

Please sign in to comment.