Skip to content
Merged
Changes from 1 commit
Commits
Show all changes
23 commits
Select commit Hold shift + click to select a range
3dfc379
deps: update datafusion to 39.0.0, pyo3 to 0.21, and object_store to …
Michael-J-Ward Jun 12, 2024
b98378e
feat: remove GetIndexField
Michael-J-Ward Jun 12, 2024
23f195d
feat: update ScalarFunction
Michael-J-Ward Jun 12, 2024
f7b24df
feat: incorporate upstream array_slice fixes
Michael-J-Ward Jun 12, 2024
2e17661
update ExectionPlan::children impl for DatasetExec
Michael-J-Ward Jun 12, 2024
e1c4ad9
update value_interval_daytime
Michael-J-Ward Jun 12, 2024
2fc90d9
update regexp_replace and regexp_match
Michael-J-Ward Jun 12, 2024
99551fa
add gil-refs feature to pyo3
Michael-J-Ward Jun 12, 2024
656905c
fix signature for octet_length
Michael-J-Ward Jun 12, 2024
232ab81
update signature for covar_samp
Michael-J-Ward Jun 12, 2024
66f25ed
convert covar_pop to expr_fn api
Michael-J-Ward Jun 12, 2024
8a3a606
convert median to expr_fn api
Michael-J-Ward Jun 12, 2024
f36558e
convert variance sample to UDF
Michael-J-Ward Jun 12, 2024
5f08588
convert first_value and last_value to UDFs
Michael-J-Ward Jun 13, 2024
04c5887
checkpointing with a few todos to fix remaining compile errors
Michael-J-Ward Jun 13, 2024
5da84b9
impl PyExpr::python_value for IntervalDayTime and IntervalMonthDayNano
Michael-J-Ward Jun 13, 2024
f319aa4
convert sum aggregate function to UDF
Michael-J-Ward Jun 13, 2024
19e1f1c
remove unnecessary clone on double reference
Michael-J-Ward Jun 13, 2024
f693e7b
apply cargo fmt
Michael-J-Ward Jun 13, 2024
e519c1b
remove duplicate allow-dead-code annotation
Michael-J-Ward Jun 14, 2024
67d3ec5
update tpch examples for new pyarrow interval
Michael-J-Ward Jun 14, 2024
06ecb27
marked q11 tpch example as expected fail
Michael-J-Ward Jun 14, 2024
995171a
add default stride of None back to array_slice
Michael-J-Ward Jun 14, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
add default stride of None back to array_slice
  • Loading branch information
Michael-J-Ward committed Jun 14, 2024
commit 995171a293b09025486e28e489d4599eef901080
2 changes: 2 additions & 0 deletions src/functions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -183,6 +183,7 @@ fn list_indexof(array: PyExpr, element: PyExpr, index: Option<i64>) -> PyExpr {
}

#[pyfunction]
#[pyo3(signature = (array, begin, end, stride = None))]
fn array_slice(array: PyExpr, begin: PyExpr, end: PyExpr, stride: Option<PyExpr>) -> PyExpr {
datafusion_functions_array::expr_fn::array_slice(
array.into(),
Expand All @@ -194,6 +195,7 @@ fn array_slice(array: PyExpr, begin: PyExpr, end: PyExpr, stride: Option<PyExpr>
}

#[pyfunction]
#[pyo3(signature = (array, begin, end, stride = None))]
fn list_slice(array: PyExpr, begin: PyExpr, end: PyExpr, stride: Option<PyExpr>) -> PyExpr {
// alias of array_slice
array_slice(array, begin, end, stride)
Expand Down