public abstract class Operator extends Pipe
Pipe
. Operators pass specified arguments to a given BaseOperation
.
The argFields value select the input fields used by the operation. By default the whole input Tuple is passes as arguments.
The outFields value select the fields in the result Tuple returned by this Pipe. By default, the operation results
of the given operation replace the input Tuple.Modifier and Type | Field and Description |
---|---|
protected Fields |
argumentSelector
Field argumentSelector
|
protected Operation |
operation
Field operation
|
protected Fields |
outputSelector
Field outputSelector
|
protected PlannerLevel |
plannerLevel
Field assertionLevel
|
configDef, name, nodeConfigDef, parent, previous, stepConfigDef
Modifier | Constructor and Description |
---|---|
protected |
Operator(Operation operation) |
protected |
Operator(Pipe previous,
Fields argumentSelector,
Operation operation) |
protected |
Operator(Pipe previous,
Fields argumentSelector,
Operation operation,
Fields outputSelector) |
protected |
Operator(Pipe previous,
Fields argumentSelector,
PlannerLevel plannerLevel,
PlannedOperation operation,
Fields outputSelector) |
protected |
Operator(Pipe previous,
Operation operation) |
protected |
Operator(Pipe previous,
Operation operation,
Fields outputSelector) |
protected |
Operator(Pipe previous,
PlannerLevel plannerLevel,
PlannedOperation operation,
Fields outputSelector) |
protected |
Operator(String name,
Fields argumentSelector,
Operation operation) |
protected |
Operator(String name,
Fields argumentSelector,
Operation operation,
Fields outputSelector) |
protected |
Operator(String name,
Fields argumentSelector,
PlannerLevel plannerLevel,
PlannedOperation operation,
Fields outputSelector) |
protected |
Operator(String name,
Operation operation) |
protected |
Operator(String name,
Operation operation,
Fields outputSelector) |
protected |
Operator(String name,
PlannerLevel plannerLevel,
PlannedOperation operation,
Fields outputSelector) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object object) |
Fields |
getArgumentSelector()
Method getArgumentSelector returns the argumentSelector of this Operator object.
|
Fields |
getFieldDeclaration()
Method getFieldDeclaration returns the fieldDeclaration of this Operator object.
|
Operation |
getOperation()
Method getOperation returns the operation managed by this Operator object.
|
Fields |
getOutputSelector()
Method getOutputSelector returns the outputSelector of this Operator object.
|
PlannerLevel |
getPlannerLevel()
Method getPlannerLevel returns the plannerLevel of this Operator object.
|
int |
hashCode() |
boolean |
hasPlannerLevel()
Method hasPlannerLevel returns true if this Operator object holds a
PlannedOperation object with an associated
PlannerLevel level. |
abstract Scope |
outgoingScopeFor(Set<Scope> incomingScopes)
Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement.
|
protected void |
printInternal(StringBuffer buffer,
Scope scope) |
protected Fields |
resolveRemainderFields(Set<Scope> incomingScopes,
Fields argumentFields) |
String |
toString() |
protected void |
verifyOperation() |
getConfigDef, getHeads, getName, getNodeConfigDef, getParent, getPrevious, getStepConfigDef, getTrace, hasConfigDef, hasNodeConfigDef, hasStepConfigDef, id, named, names, pipes, print, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, setParent
protected Fields argumentSelector
protected Fields outputSelector
protected PlannerLevel plannerLevel
protected Operator(String name, Fields argumentSelector, Operation operation, Fields outputSelector)
protected Operator(Pipe previous, Fields argumentSelector, Operation operation, Fields outputSelector)
protected Operator(String name, PlannerLevel plannerLevel, PlannedOperation operation, Fields outputSelector)
protected Operator(String name, Fields argumentSelector, PlannerLevel plannerLevel, PlannedOperation operation, Fields outputSelector)
protected Operator(Pipe previous, PlannerLevel plannerLevel, PlannedOperation operation, Fields outputSelector)
protected Operator(Pipe previous, Fields argumentSelector, PlannerLevel plannerLevel, PlannedOperation operation, Fields outputSelector)
protected void verifyOperation()
public Operation getOperation()
public Fields getArgumentSelector()
public Fields getFieldDeclaration()
public Fields getOutputSelector()
public PlannerLevel getPlannerLevel()
public boolean hasPlannerLevel()
PlannedOperation
object with an associated
PlannerLevel
level.protected Fields resolveRemainderFields(Set<Scope> incomingScopes, Fields argumentFields)
public abstract Scope outgoingScopeFor(Set<Scope> incomingScopes)
ScopedElement
outgoingScopeFor
in interface ScopedElement
outgoingScopeFor
in class Pipe
incomingScopes
- of type Setprotected void printInternal(StringBuffer buffer, Scope scope)
printInternal
in class Pipe
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.