Commit 80e8cadd authored by Lauri Himanen's avatar Lauri Himanen
Browse files

Starting to modify MongoDB pipeline into ES aggregation.

parent d7a8f902
......@@ -482,12 +482,12 @@ class EncGroupsResource(Resource):
# Find EOS groups
s = Search(index=config.elastic.index_name)
s.aggs.pipeline("pipeline", pipeline("group_eos_hash", "equation of state", 4))
s.aggs.pipeline("eos_pipeline", processors=pipeline("group_eos_hash", "equation of state", 4))
eos_groups = s.execute()
# Find convergence groups
s = Search(index=config.elastic.index_name)
s.aggs.pipeline("pipeline", pipeline("group_parametervariation_hash", "parameter variation", 2))
s.aggs.pipeline("convergence_pipeline", processors=pipeline("group_parametervariation_hash", "parameter variation", 2))
convergence_groups = s.execute()
# Combine both groups
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment