19 package org.turro.indicator;
21 import java.util.stream.Stream;
22 import org.turro.annotation.ElephantIndicator;
23 import org.turro.elephant.db.ElephantPU;
24 import org.turro.elephant.db.WhereClause;
25 import org.turro.jpa.Dao;
26 import org.turro.matching.GenericMatching;
27 import org.turro.matching.IMatching;
28 import org.turro.ranking.GenericRanking;
29 import org.turro.ranking.IRanking;
60 if(
"contact".equals(entityRoot)) {
100 try(Stream<GenericRanking> stream = dao.stream(
GenericRanking.class, wc, 1000)) {
101 stream.forEach(r -> {
112 if(
"contact".equals(relatedRoot)) {
137 try(Stream<GenericMatching> stream = dao.stream(
GenericMatching.class, wc, 1000)) {
138 stream.forEach(m -> {
void addVariable(String name, VariableType type)
void processMatchingVariable(Dao dao, IPreprocessor preprocessor, IndicatorVariable variable, String entityRoot, String relatedRoot)
void initExternalVariables()
void processRankingVariable(Dao dao, IPreprocessor preprocessor, IndicatorVariable variable, String entityRoot)
PreprocessClause setMatchingField(String pathField)
PreprocessClause setVariable(IndicatorVariable variable)
PreprocessClause setMatchingRoot(String entityRoot)
PreprocessClause setAggregate(String aggregate)
PreprocessClause setRankingRoot(String entityRoot)
static PreprocessClause load(String table)
PreprocessClause setRankingField(String pathField)
void poolInstance(Object value)
void finishPreprocessor()