org.turro.matching.ProcessMatching< T > Class Template Reference

Inheritance diagram for org.turro.matching.ProcessMatching< T >:

Collaboration diagram for org.turro.matching.ProcessMatching< 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 ()
List< String >	getSelectedPaths ()
IMatching	process (T entity, String relatedPath, IndicatorVariable variable)
void	prepareProcess (List< IndicatorVariable > variables)
void	postProcess (List< IndicatorVariable > variables)
void	prepareEntity (T entity)
double	calculate (MatchingSet set)
IMatching	createMatchingInstance (String entityPath, String relatedPath, IndicatorVariable variable)
abstract Stream< T >	getEntityStream ()
abstract IMatching	createMatchingInstance ()
abstract Class	instanceClass ()
abstract String	indicatorsRoot ()
abstract String	entitiesRoot ()
abstract String	relatedRoot ()
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 ProcessMatching.java.

Member Function Documentation

calculate()

double org.turro.matching.ProcessMatching< T >.calculate ( MatchingSet  set )

protected

Definition at line 146 of file ProcessMatching.java.

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

Here is the call graph for this function:

createDao()

abstract Dao org.turro.matching.ProcessMatching< T >.createDao ( )

abstractprotected

Here is the caller graph for this function:

createInstance()

Object org.turro.matching.ProcessMatching< T >.createInstance

(

)

Implements org.turro.indicator.IPreprocessor.

Definition at line 226 of file ProcessMatching.java.

                                 {
    return createMatchingInstance();
  }

Here is the call graph for this function:

createMatchingInstance() [1/2]

abstract IMatching org.turro.matching.ProcessMatching< T >.createMatchingInstance ( )

abstractprotected

Here is the caller graph for this function:

createMatchingInstance() [2/2]

IMatching org.turro.matching.ProcessMatching< T >.createMatchingInstance ( String  entityPath, String  relatedPath, IndicatorVariable  variable  )

protected

Definition at line 150 of file ProcessMatching.java.

                                                                                                                {
    IMatching matching = createMatchingInstance();
    matching.setEntityPath(entityPath);
    matching.setRelatedPath(relatedPath);
    matching.setConcept(variable.getName());
    matching.setMatching(0);
    return matching;
  }

Here is the call graph for this function:

end()

void org.turro.matching.ProcessMatching< T >.end ( )

protected

Definition at line 102 of file ProcessMatching.java.

{}

Here is the caller graph for this function:

entitiesRoot()

abstract String org.turro.matching.ProcessMatching< T >.entitiesRoot ( )

abstractprotected

Here is the caller graph for this function:

finishPreprocessor()

void org.turro.matching.ProcessMatching< T >.finishPreprocessor

(

)

Implements org.turro.indicator.IPreprocessor.

Definition at line 236 of file ProcessMatching.java.

                                   {
    getDao().finishPool();
  }

Here is the call graph for this function:

getDao()

Dao org.turro.matching.ProcessMatching< T >.getDao ( )

protected

Definition at line 249 of file ProcessMatching.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.matching.ProcessMatching< T >.getEntityStream ( )

abstractprotected

Here is the caller graph for this function:

getSelectedPaths()

List<String> org.turro.matching.ProcessMatching< T >.getSelectedPaths ( )

protected

Definition at line 115 of file ProcessMatching.java.

                                            {
    return null;
  }

Here is the caller graph for this function:

indicatorsRoot()

abstract String org.turro.matching.ProcessMatching< T >.indicatorsRoot ( )

abstractprotected

Here is the caller graph for this function:

instanceClass()

abstract Class org.turro.matching.ProcessMatching< T >.instanceClass ( )

abstractprotected

Here is the caller graph for this function:

poolInstance()

void org.turro.matching.ProcessMatching< T >.poolInstance

(

Object

value

)

Implements org.turro.indicator.IPreprocessor.

Definition at line 231 of file ProcessMatching.java.

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

Here is the call graph for this function:

postProcess()

void org.turro.matching.ProcessMatching< T >.postProcess ( List< IndicatorVariable >  variables )

protected

Definition at line 137 of file ProcessMatching.java.

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

Here is the call graph for this function:

Here is the caller graph for this function:

prepareEntity()

void org.turro.matching.ProcessMatching< T >.prepareEntity ( T  entity )

protected

Definition at line 144 of file ProcessMatching.java.

{ }

Here is the caller graph for this function:

prepareProcess()

void org.turro.matching.ProcessMatching< T >.prepareProcess ( List< IndicatorVariable >  variables )

protected

Definition at line 128 of file ProcessMatching.java.

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

Here is the caller graph for this function:

process() [1/2]

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

Definition at line 82 of file ProcessMatching.java.

                                                                           {
    stream.forEach(t -> {
      processFor(t, variables);
    });
  }

Here is the call graph for this function:

Here is the caller graph for this function:

process() [2/2]

IMatching org.turro.matching.ProcessMatching< T >.process ( T  entity, String  relatedPath, IndicatorVariable  variable  )

protected

Definition at line 119 of file ProcessMatching.java.

                                                                                        {
    IMatching matching = createMatchingInstance(getDao().getPath(entity), relatedPath, variable);
    matching.setMatching(Indicators.getValue(entity, relatedPath, variable));
    if(!Zero.near(matching.getMatching(), 2)) {
      matching = getDao().saveObject(matching);
    }
    return matching;
  }

Here is the call graph for this function:

processFor()

void org.turro.matching.ProcessMatching< T >.processFor	(	T	entity,
		List< IndicatorVariable >	variables
	)

Definition at line 88 of file ProcessMatching.java.

                                                                      {
    prepareEntity(entity);
    try(Stream<String> related = Indicators.getIndicator("generic").getEntityPaths(relatedRoot())) {
      related.forEach(r -> {
        variables.forEach(v -> {
          if(!v.isPreprocess()) {
            process(entity, r, v);
          }
        });
      });
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

relatedRoot()

abstract String org.turro.matching.ProcessMatching< T >.relatedRoot ( )

abstractprotected

Here is the caller graph for this function:

start()

void org.turro.matching.ProcessMatching< T >.start ( )

protected

Definition at line 101 of file ProcessMatching.java.

{}

Here is the caller graph for this function:

startProcess()

void org.turro.matching.ProcessMatching< T >.startProcess

(

)

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

Definition at line 44 of file ProcessMatching.java.

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

Here is the call graph for this function:

startProcessFor()

void org.turro.matching.ProcessMatching< T >.startProcessFor

(

Object

entity

)

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

Definition at line 72 of file ProcessMatching.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.getMatchingVariables(indicatorsRoot()));
  }

Here is the call graph for this function:

tableName()

String org.turro.matching.ProcessMatching< T >.tableName

(

)

Implements org.turro.indicator.IPreprocessor.

Definition at line 241 of file ProcessMatching.java.

                            {
    return instanceClass().getSimpleName();
  }  

Here is the call graph for this function:

truncate()

void org.turro.matching.ProcessMatching< T >.truncate ( )

protected

Definition at line 104 of file ProcessMatching.java.

                            {
    if(getSelectedPaths() == null) {
      getDao().executeNativeUpdate("truncate table " + instanceClass().getSimpleName());
    } else {
      WhereClause wc = new WhereClause();
      wc.addClause("delete from " + instanceClass().getSimpleName());
      wc.addIn("where", "entityPath", getSelectedPaths());
      getDao().executeUpdate(wc);
    }
  }

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:

• ProcessMatching.java