cascading.pattern.ensemble
Class ParallelEnsembleAssembly

java.lang.Object
  cascading.pipe.Pipe
      cascading.pipe.SubAssembly
          cascading.pattern.ensemble.ParallelEnsembleAssembly

All Implemented Interfaces:

FlowElement, cascading.util.Traceable, Serializable

public class ParallelEnsembleAssembly
extends SubAssembly

Class ParallelEnsembleAssembly allows for the execution of multiple models in parallel where the result is either a prediction or classification, depending on the predicted fields data type.

If Spec.isPredictedCategorical() returns true, the ensemble will return a category based on the current CategoricalSelector. If ModelSchema.isIncludePredictedCategories() returns true, a field will be created for each declared category, and the count of occurrences of each category will be returned.

Otherwise a numeric prediction is returned based on the current PredictionSelector. isIncludePredictedCategories() is ignored.

If EnsembleSpec.isParallel() returns false, this assembly will throw an IllegalArgumentException. The chosen SelectionStrategy must support parallel execution.

If ModelSchema.getKeyFields() is Fields.NONE, a globally unique ID will be created to that the results of each independent model can be grouped together so the SelectionStrategy can be applied. This field will be discarded downstream.

Currently ParallelEnsembleAssembly does not support associating models with predicates.

See Also:

Serialized Form

Field Summary

Fields inherited from class cascading.pipe.Pipe

configDef, name, parent, stepConfigDef

Constructor Summary

ParallelEnsembleAssembly(Pipe pipe, EnsembleSpec ensembleSpec)

Method Summary

Methods inherited from class cascading.pipe.SubAssembly

getName, getPrevious, getTailNames, getTails, setPrevious, setTails, unwind

Methods inherited from class cascading.pipe.Pipe

equals, getConfigDef, getHeads, getParent, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasStepConfigDef, id, isEquivalentTo, named, names, outgoingScopeFor, pipes, print, printInternal, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, setParent, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ParallelEnsembleAssembly

public ParallelEnsembleAssembly(Pipe pipe,
                                EnsembleSpec ensembleSpec)