org.turro.ranking.ProcessRanking< T > Class Template Reference

Inheritance diagram for org.turro.ranking.ProcessRanking< T >:

Collaboration diagram for org.turro.ranking.ProcessRanking< T >:

Public Member Functions
void	startProcess ()
void	startProcessFor (Object entity)
void	process (Stream< T > stream, List< IndicatorVariable > variables)
void	processFor (T entity, List< IndicatorVariable > variables)
Object	createInstance ()
void	poolInstance (Object value)
void	finishPreprocessor ()
String	tableName ()
Public Member Functions inherited from org.turro.action.IProcess< T >
boolean	itsMine (Object entity)

Protected Member Functions
void	start ()
void	end ()
void	truncate ()
IRanking	process (T entity, IndicatorVariable variable)
void	prepareProcess (List< IndicatorVariable > variables)
void	postProcess (List< IndicatorVariable > variables)
void	prepareEntity (T entity)
double	calculate (RankingSet set)
IRanking	createRankingInstance (String entityPath, IndicatorVariable variable)
abstract Stream< T >	getEntityStream ()
abstract IRanking	createRankingInstance ()
abstract Class	instanceClass ()
abstract String	indicatorsRoot ()
abstract String	entitiesRoot ()
abstract Dao	createDao ()
Dao	getDao ()

Detailed Description

Author

Lluis Turró Cutiller lluis.nosp@m.@tur.nosp@m.ro.or.nosp@m.g

Definition at line 41 of file ProcessRanking.java.

Member Function Documentation

calculate()

double org.turro.ranking.ProcessRanking< T >.calculate ( RankingSet  set )

protected

Definition at line 136 of file ProcessRanking.java.

                                             {
    return set.applyFrom(Formulas.load().getFormula(instanceClass()));
  }

Here is the call graph for this function:

createDao()

abstract Dao org.turro.ranking.ProcessRanking< T >.createDao ( )

abstractprotected

Here is the caller graph for this function:

createInstance()

Object org.turro.ranking.ProcessRanking< T >.createInstance

(

)

Implements org.turro.indicator.IPreprocessor.

Definition at line 208 of file ProcessRanking.java.

                                 {
    return createRankingInstance();
  }

Here is the call graph for this function:

createRankingInstance() [1/2]

abstract IRanking org.turro.ranking.ProcessRanking< T >.createRankingInstance ( )

abstractprotected

Here is the caller graph for this function:

createRankingInstance() [2/2]

IRanking org.turro.ranking.ProcessRanking< T >.createRankingInstance ( String  entityPath, IndicatorVariable  variable  )

protected

Definition at line 140 of file ProcessRanking.java.

                                                                                          {
    IRanking ranking = createRankingInstance();
    ranking.setEntityPath(entityPath);
    ranking.setConcept(variable.getName());
    ranking.setRanking(0);
    return ranking;
  }

Here is the call graph for this function:

end()

void org.turro.ranking.ProcessRanking< T >.end ( )

protected

Definition at line 103 of file ProcessRanking.java.

{}

Here is the caller graph for this function:

entitiesRoot()

abstract String org.turro.ranking.ProcessRanking< T >.entitiesRoot ( )

abstractprotected

Here is the caller graph for this function:

finishPreprocessor()

void org.turro.ranking.ProcessRanking< T >.finishPreprocessor

(

)

Implements org.turro.indicator.IPreprocessor.

Definition at line 218 of file ProcessRanking.java.

                                   {
    getDao().finishPool();
  }

Here is the call graph for this function:

getDao()

Dao org.turro.ranking.ProcessRanking< T >.getDao ( )

protected

Definition at line 231 of file ProcessRanking.java.

                         {
    if(_dao == null) {
      _dao = createDao();
    }
    return _dao;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

getEntityStream()

abstract Stream<T> org.turro.ranking.ProcessRanking< T >.getEntityStream ( )

abstractprotected

Here is the caller graph for this function:

indicatorsRoot()

abstract String org.turro.ranking.ProcessRanking< T >.indicatorsRoot ( )

abstractprotected

Here is the caller graph for this function:

instanceClass()

abstract Class org.turro.ranking.ProcessRanking< T >.instanceClass ( )

abstractprotected

Here is the caller graph for this function:

poolInstance()

void org.turro.ranking.ProcessRanking< T >.poolInstance

(

Object

value

)

Implements org.turro.indicator.IPreprocessor.

Definition at line 213 of file ProcessRanking.java.

                                         {
    getDao().poolObject(value, 1000);
  }

Here is the call graph for this function:

postProcess()

void org.turro.ranking.ProcessRanking< T >.postProcess ( List< IndicatorVariable >  variables )

protected

Definition at line 127 of file ProcessRanking.java.

                                                                {
    variables.forEach(v -> {
      IElephantIndicator ei = Indicators.getIndicator(v);
      ei.postprocess(v, this, entitiesRoot(), null);
    });
  }

Here is the call graph for this function:

Here is the caller graph for this function:

prepareEntity()

void org.turro.ranking.ProcessRanking< T >.prepareEntity ( T  entity )

protected

Definition at line 134 of file ProcessRanking.java.

{ }

Here is the caller graph for this function:

prepareProcess()

void org.turro.ranking.ProcessRanking< T >.prepareProcess ( List< IndicatorVariable >  variables )

protected

Definition at line 118 of file ProcessRanking.java.

                                                                   {
    variables.forEach(v -> {
      if(v.isPreprocess()) {
        IElephantIndicator ei = Indicators.getIndicator(v);
        ei.preprocess(v, this, entitiesRoot(), null);
      }
    });
  }

Here is the caller graph for this function:

process() [1/2]

void org.turro.ranking.ProcessRanking< T >.process	(	Stream< T >	stream,
		List< IndicatorVariable >	variables
	)

Definition at line 82 of file ProcessRanking.java.

                                                                           {
    try {
      stream.forEach(t -> {
        processFor(t, variables);
      });
    } catch(Exception ex) {
      Logger.getLogger(ProcessRanking.class.getName())
            .log(Level.SEVERE, ElephantContext.logMsg("Processing"), ex);
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

process() [2/2]

IRanking org.turro.ranking.ProcessRanking< T >.process ( T  entity, IndicatorVariable  variable  )

protected

Definition at line 109 of file ProcessRanking.java.

                                                                   {
    IRanking ranking = createRankingInstance(getDao().getPath(entity), variable);
    ranking.setRanking(Indicators.getValue(entity, variable));
    if(!Zero.near(ranking.getRanking(), 2)) {
      ranking = getDao().saveObject(ranking);
    }
    return ranking;
  }

Here is the call graph for this function:

processFor()

void org.turro.ranking.ProcessRanking< T >.processFor	(	T	entity,
		List< IndicatorVariable >	variables
	)

Definition at line 93 of file ProcessRanking.java.

                                                                      {
    prepareEntity(entity);
    variables.forEach(v -> {
      if(!v.isPreprocess()) {
        process(entity, v);
      }
    });
  }

Here is the call graph for this function:

Here is the caller graph for this function:

start()

void org.turro.ranking.ProcessRanking< T >.start ( )

protected

Definition at line 102 of file ProcessRanking.java.

{}

Here is the caller graph for this function:

startProcess()

void org.turro.ranking.ProcessRanking< T >.startProcess

(

)

Implements org.turro.action.IProcess< T >.

Definition at line 44 of file ProcessRanking.java.

                             {
    Logger.getLogger(ProcessRanking.class.getName())
            .log(Level.INFO, ElephantContext.logMsg("Start " + instanceClass().getSimpleName() + "..."));
    start();
    truncate();
    Logger.getLogger(ProcessRanking.class.getName())
            .log(Level.INFO, ElephantContext.logMsg("Truncated"));
    List<IndicatorVariable> vars = Indicators.getRankingVariables(indicatorsRoot());
    prepareProcess(vars);
    Logger.getLogger(ProcessRanking.class.getName())
            .log(Level.INFO, ElephantContext.logMsg("Preprocessed"));
    if(Indicators.hasDirectProcess(vars)) {
      try(Stream<T> entities = getEntityStream()) {
        process(entities, vars);
      }
    }
    Logger.getLogger(ProcessRanking.class.getName())
            .log(Level.INFO, ElephantContext.logMsg("Processed"));
    postProcess(vars);
    Logger.getLogger(ProcessRanking.class.getName())
            .log(Level.INFO, ElephantContext.logMsg("Postprocessed"));
    calculateRanking();
    end();
    Logger.getLogger(ProcessRanking.class.getName())
            .log(Level.INFO, ElephantContext.logMsg("End " + instanceClass().getSimpleName()));
  }

Here is the call graph for this function:

startProcessFor()

void org.turro.ranking.ProcessRanking< T >.startProcessFor

(

Object

entity

)

Implements org.turro.action.IProcess< T >.

Definition at line 72 of file ProcessRanking.java.

                                             {
    String entityPath = getDao().getPath(entity);
    WhereClause wc = new WhereClause();
    wc.addClause("delete from " + instanceClass().getSimpleName());
    wc.addClause("where entityPath = :entityPath");
    wc.addNamedValue("entityPath", entityPath);
    getDao().executeUpdate(wc);
    processFor((T) entity, Indicators.getRankingVariables(indicatorsRoot()));
  }

Here is the call graph for this function:

tableName()

String org.turro.ranking.ProcessRanking< T >.tableName

(

)

Implements org.turro.indicator.IPreprocessor.

Definition at line 223 of file ProcessRanking.java.

                            {
    return instanceClass().getSimpleName();
  }  

Here is the call graph for this function:

truncate()

void org.turro.ranking.ProcessRanking< T >.truncate ( )

protected

Definition at line 105 of file ProcessRanking.java.

                            {
    getDao().executeNativeUpdate("truncate table " + instanceClass().getSimpleName());
  }

Here is the call graph for this function:

Here is the caller graph for this function:

---

The documentation for this class was generated from the following file:

• ProcessRanking.java