Skip to content

Commit a93186d

Browse files
authored
Merge pull request #49 from MarcoGorelli/bump-version
bump version
2 parents b3f27e6 + 7c5c61a commit a93186d

File tree

12 files changed

+129
-108
lines changed

12 files changed

+129
-108
lines changed

Cargo.lock

Lines changed: 90 additions & 62 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,12 @@ crate-type= ["cdylib"]
1313

1414
[dependencies]
1515
pyo3 = { version = "0.22.2", features = ["extension-module", "abi3-py38"] }
16-
pyo3-polars = { version = "0.16.1", features = ["derive", "dtype-struct", "dtype-decimal", "dtype-array"] }
16+
pyo3-polars = { version = "0.17.0", features = ["derive", "dtype-struct", "dtype-decimal", "dtype-array"] }
1717
serde = { version = "1", features = ["derive"] }
18-
polars = { version = "0.42.0", features = ["dtype-struct"], default-features = false }
19-
polars-arrow = { version = "0.42.0", default-features = false }
20-
polars-core = { version = "0.42.0", features = ["dtype-array"], default-features = false }
21-
polars-sql = { version = "0.42.0", default-features = false }
18+
polars = { version = "0.43.1", features = ["dtype-struct"], default-features = false }
19+
polars-arrow = { version = "0.43.1", default-features = false }
20+
polars-core = { version = "0.43.1", features = ["dtype-array"], default-features = false }
21+
polars-sql = { version = "0.43.1", default-features = false }
2222
reverse_geocoder = "4.1.1"
2323
# rust-stemmers = "1.2.0"
2424

docs/aggregate.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ fn vertical_weighted_mean(inputs: &[Series]) -> PolarsResult<Series> {
4646
}
4747
});
4848
let result = numerator / denominator;
49-
Ok(Series::new("", vec![result]))
49+
Ok(Series::new(PlSmallStr::EMPTY, vec![result]))
5050
}
5151
```
5252

docs/arrays.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ And we can finally move to the actual plugin code:
7676
// #[polars_expr(output_type=Array)]
7777
pub fn point_2d_output(_: &[Field]) -> PolarsResult<Field> {
7878
Ok(Field::new(
79-
"point_2d",
79+
PlSmallStr::from_static("point_2d"),
8080
DataType::Array(Box::new(DataType::Float64), 2),
8181
))
8282
}

docs/cum_sum.md

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,6 @@ fn cum_sum(inputs: &[Series]) -> PolarsResult<Series> {
5050
}
5151
})
5252
.collect_trusted();
53-
let out: Int64Chunked = out.with_name(ca.name());
5453
Ok(out.into_series())
5554
}
5655
```

docs/life_pt1.md

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,7 @@ fn life_step(inputs: &[Series]) -> PolarsResult<Series> {
267267

268268
let len = lf.len();
269269

270-
let mut out: Int64Chunked = mid
270+
let out: Int64Chunked = mid
271271
.iter()
272272
.enumerate()
273273
.map(|(idx, val)| {
@@ -297,7 +297,6 @@ fn life_step(inputs: &[Series]) -> PolarsResult<Series> {
297297
})
298298
})
299299
.collect_trusted();
300-
out.rename(ca_curr.name());
301300
Ok(out.into_series())
302301
}
303302
```

docs/lists.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ where
7272
(Some(lhs), Some(rhs)) => f(&lhs, &rhs),
7373
_ => None,
7474
})
75-
.collect_ca(lhs.name())
75+
.collect_ca(PlSmallStr::EMPTY)
7676
}
7777
}
7878
```

docs/lists_in_lists_out.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,8 @@ a function to each element of a List Series. In this case, we just want to find
3636
elements, so we'll do:
3737

3838
```rust
39-
fn list_idx_dtype(input_fields: &[Field]) -> PolarsResult<Field> {
40-
let field = Field::new(input_fields[0].name(), DataType::List(Box::new(IDX_DTYPE)));
39+
fn list_idx_dtype(_input_fields: &[Field]) -> PolarsResult<Field> {
40+
let field = Field::new(PlSmallStr::EMPTY, DataType::List(Box::new(IDX_DTYPE)));
4141
Ok(field.clone())
4242
}
4343

@@ -57,7 +57,7 @@ fn non_zero_indices(inputs: &[Series]) -> PolarsResult<Series> {
5757
.enumerate()
5858
.filter(|(_idx, opt_val)| opt_val != &Some(0))
5959
.map(|(idx, _opt_val)| Some(idx as IdxSize))
60-
.collect_ca("");
60+
.collect_ca(PlSmallStr::EMPTY);
6161
out.into_series()
6262
});
6363
Ok(out.into_series())

docs/struct.md

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -25,27 +25,26 @@ On the Rust side, we need to start by activating the necessary
2525
feature - in `Cargo.toml`, please make this change:
2626

2727
```diff
28-
-polars = { version = "0.42.0", default-features = false }
29-
+polars = { version = "0.42.0", features=["dtype-struct"], default-features = false }
28+
-polars = { version = "0.43.1", default-features = false }
29+
+polars = { version = "0.43.1", features=["dtype-struct"], default-features = false }
3030
```
3131

3232
Then, we need to get the schema right.
3333

3434
```Rust
3535
fn shifted_struct(input_fields: &[Field]) -> PolarsResult<Field> {
3636
let field = &input_fields[0];
37-
match field.data_type() {
37+
match field.dtype() {
3838
DataType::Struct(fields) => {
3939
let mut field_0 = fields[0].clone();
40-
let name = field_0.name().clone();
4140
field_0.set_name(fields[fields.len() - 1].name().clone());
4241
let mut fields = fields[1..]
4342
.iter()
4443
.zip(fields[0..fields.len() - 1].iter())
45-
.map(|(fld, name)| Field::new(name.name(), fld.data_type().clone()))
44+
.map(|(fld, name)| Field::new(name.name().clone(), fld.dtype().clone()))
4645
.collect::<Vec<_>>();
4746
fields.push(field_0);
48-
Ok(Field::new(&name, DataType::Struct(fields)))
47+
Ok(Field::new(PlSmallStr::EMPTY, DataType::Struct(fields)))
4948
}
5049
_ => unreachable!(),
5150
}
@@ -68,18 +67,18 @@ fn shift_struct(inputs: &[Series]) -> PolarsResult<Series> {
6867
return Ok(inputs[0].clone());
6968
}
7069
let mut field_0 = fields[0].clone();
71-
field_0.rename(fields[fields.len() - 1].name());
70+
field_0.rename(fields[fields.len() - 1].name()).clone();
7271
let mut fields = fields[1..]
7372
.iter()
7473
.zip(fields[..fields.len() - 1].iter())
7574
.map(|(s, name)| {
7675
let mut s = s.clone();
77-
s.rename(name.name());
76+
s.rename(name.name().clone());
7877
s
7978
})
8079
.collect::<Vec<_>>();
8180
fields.push(field_0);
82-
StructChunked::from_series(struct_.name(), &fields).map(|ca| ca.into_series())
81+
StructChunked::from_series(PlSmallStr::EMPTY, &fields).map(|ca| ca.into_series())
8382
}
8483
```
8584

docs/vec_of_option.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ where
9696
out.into(),
9797
Some(validity.into()),
9898
);
99-
ChunkedArray::with_chunk(chunked_arr.name(), array)
99+
ChunkedArray::with_chunk(PlSmallStr::EMPTY, array)
100100
} else {
101101
ChunkedArray::from_vec(chunked_arr.name(), out)
102102
}
@@ -164,7 +164,7 @@ if first != 0 || last != chunked_arr.len() {
164164
out.into(),
165165
Some(validity.into()),
166166
);
167-
ChunkedArray::with_chunk(chunked_arr.name(), array)
167+
ChunkedArray::with_chunk(PlSmallStr::EMPTY, array)
168168
} else {
169169
ChunkedArray::from_vec(chunked_arr.name(), out)
170170
}

0 commit comments

Comments
 (0)