@@ -138,8 +138,7 @@ auto make_spawn(InputSpec const& input, ProcessingContext& pc)
138138 return o2::framework::spawner<D>(extractOriginals<sources.size (), sources>(pc), input.binding .c_str (), projectors.data (), projector, schema);
139139}
140140
141- struct Maker
142- {
141+ struct Maker {
143142 std::string binding;
144143 std::vector<std::string> labels;
145144 std::vector<std::shared_ptr<gandiva::Expression>> expressions;
@@ -169,7 +168,6 @@ struct Maker
169168
170169 return spawnerHelper (fullTable, schema, binding.c_str (), schema->num_fields (), projector);
171170 }
172-
173171};
174172
175173struct Spawnable {
@@ -185,17 +183,17 @@ struct Spawnable {
185183 header::DataHeader::SubSpecificationType version;
186184
187185 Spawnable (InputSpec const & spec)
188- : binding{spec.binding }
186+ : binding{spec.binding }
189187 {
190188 auto && [origin_, description_, version_] = DataSpecUtils::asConcreteDataMatcher (spec);
191189 origin = origin_;
192190 description = description_;
193191 version = version_;
194- auto loc = std::find_if (spec.metadata .begin (), spec.metadata .end (), [](ConfigParamSpec const & cps){ return cps.name .compare (" projectors" ) == 0 ; });
192+ auto loc = std::find_if (spec.metadata .begin (), spec.metadata .end (), [](ConfigParamSpec const & cps) { return cps.name .compare (" projectors" ) == 0 ; });
195193 std::stringstream iws (loc->defaultValue .get <std::string>());
196194 projectors = ExpressionJSONHelpers::read (iws);
197195
198- loc = std::find_if (spec.metadata .begin (), spec.metadata .end (), [](ConfigParamSpec const & cps){ return cps.name .compare (" schema" ) == 0 ; });
196+ loc = std::find_if (spec.metadata .begin (), spec.metadata .end (), [](ConfigParamSpec const & cps) { return cps.name .compare (" schema" ) == 0 ; });
199197 iws.clear ();
200198 iws.str (loc->defaultValue .get <std::string>());
201199 outputSchema = ArrowJSONHelpers::read (iws);
@@ -209,14 +207,14 @@ struct Spawnable {
209207 std::vector<std::shared_ptr<arrow::Field>> fields;
210208 for (auto & p : projectors) {
211209 expressions::walk (p.node .get (),
212- [&fields](expressions::Node* n) mutable {
213- if (n->self .index () == 1 ) {
214- auto & b = std::get<expressions::BindingNode>(n->self );
215- if ( std::find_if (fields.begin (), fields.end (), [&b](std::shared_ptr<arrow::Field> const & field){ return field->name () == b.name ; }) == fields.end () ) {
216- fields.emplace_back (std::make_shared<arrow::Field>(b.name , expressions::concreteArrowType (b.type )));
217- }
218- }
219- });
210+ [&fields](expressions::Node* n) mutable {
211+ if (n->self .index () == 1 ) {
212+ auto & b = std::get<expressions::BindingNode>(n->self );
213+ if (std::find_if (fields.begin (), fields.end (), [&b](std::shared_ptr<arrow::Field> const & field) { return field->name () == b.name ; }) == fields.end ()) {
214+ fields.emplace_back (std::make_shared<arrow::Field>(b.name , expressions::concreteArrowType (b.type )));
215+ }
216+ }
217+ });
220218 }
221219 inputSchema = std::make_shared<arrow::Schema>(fields);
222220
@@ -227,8 +225,7 @@ struct Spawnable {
227225 expressions::createExpressionTree (
228226 expressions::createOperations (p),
229227 inputSchema),
230- outputSchema->field (i))
231- );
228+ outputSchema->field (i)));
232229 ++i;
233230 }
234231 }
@@ -248,10 +245,8 @@ struct Spawnable {
248245 outputSchema,
249246 origin,
250247 description,
251- version
252- };
248+ version};
253249 }
254-
255250};
256251
257252} // namespace
0 commit comments