cascading.pattern.model.clustering
Class ClusteringFunction
java.lang.Object
cascading.operation.BaseOperation<ModelScoringFunction.Context<P>>
cascading.pattern.model.ModelScoringFunction<ClusteringSpec,ClusteringFunction.EvaluatorContext>
cascading.pattern.model.clustering.ClusteringFunction
- All Implemented Interfaces:
- cascading.flow.planner.DeclaresResults, Function<ModelScoringFunction.Context<ClusteringFunction.EvaluatorContext>>, Operation<ModelScoringFunction.Context<ClusteringFunction.EvaluatorContext>>, cascading.util.Traceable, Serializable
public class ClusteringFunction
- extends ModelScoringFunction<ClusteringSpec,ClusteringFunction.EvaluatorContext>
Class ClusteringFunction applies a given ClusteringSpec
model to a stream of data.
Use the ClusteringSpec to define the incoming and result values.
If ModelSchema.isIncludePredictedCategories()
is true
then
a field named after every declared category will be emitted with the result of each Cluster
.
- See Also:
- Serialized Form
Fields inherited from interface cascading.operation.Operation |
ANY |
ClusteringFunction
public ClusteringFunction(ClusteringSpec clusteringParam)
prepare
public void prepare(FlowProcess flowProcess,
OperationCall<ModelScoringFunction.Context<ClusteringFunction.EvaluatorContext>> operationCall)
- Specified by:
prepare
in interface Operation<ModelScoringFunction.Context<ClusteringFunction.EvaluatorContext>>
- Overrides:
prepare
in class ModelScoringFunction<ClusteringSpec,ClusteringFunction.EvaluatorContext>
operate
public void operate(FlowProcess flowProcess,
FunctionCall<ModelScoringFunction.Context<ClusteringFunction.EvaluatorContext>> functionCall)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.