File tree Expand file tree Collapse file tree 1 file changed +5
-7
lines changed Expand file tree Collapse file tree 1 file changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -42,21 +42,19 @@ int main() {
42
42
dataflow df(multithread::enable(10));
43
43
44
44
std::ifstream data("data.json");
45
- auto [ x, v, w] = df.read(
46
- dataset::input<json >(data), dataset::column<double >("x"),
47
- dataset::column< std::vector<double > >("v"), dataset::column<double >("w"));
45
+ auto [ x, w] = df.read(
46
+ dataset::input<json >(data), dataset::column< std::vector<double > >("x"), dataset::column<double >("w"));
48
47
49
48
auto zero = df.define(column::constant(0));
50
- auto v0 = v [ zero] ;
49
+ auto x0 = x [ zero] ;
51
50
52
51
auto sel =
53
52
df.weight(w)
54
53
.filter(column::expression(
55
- [ ] (std::vector<double > const &v) { return v.size(); }))(v)
56
- .filter(column::expression([ ] (double x) { return x > 100.0; }))(x);
54
+ [ ] (std::vector<double > const &v) { return v.size(); }))(v);
57
55
58
56
auto h_x0_w = df.get(query::output<h1d >(linax(20, 0.0, 200.0)))
59
- .fill(v0 )
57
+ .fill(x0 )
60
58
.at(sel)
61
59
.result();
62
60
You can’t perform that action at this time.
0 commit comments