Package org.apache.storm.streams
Class ProcessorNode
- java.lang.Object
-
- org.apache.storm.streams.ProcessorNode
-
- All Implemented Interfaces:
Serializable
public class ProcessorNode extends Object
Node that wraps a processor in the stream.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description protected StringcomponentIdprotected org.apache.storm.streams.GroupingInfogroupingInfoprotected FieldsoutputFieldsprotected intparallelism
-
Constructor Summary
Constructors Constructor Description ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields)ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields, boolean preservesKey)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanemitsPair()FieldsgetOutputFields()Processor<?>getProcessor()Set<String>getWindowedParentStreams()booleanisBatch()booleanisPreservesKey()booleanisWindowed()voidsetEmitsPair(boolean emitsPair)voidsetWindowed(boolean windowed)StringtoString()
-
-
-
Method Detail
-
getProcessor
public Processor<?> getProcessor()
-
isBatch
public boolean isBatch()
-
isPreservesKey
public boolean isPreservesKey()
-
toString
public String toString()
-
getOutputFields
public Fields getOutputFields()
-
isWindowed
public boolean isWindowed()
-
setWindowed
public void setWindowed(boolean windowed)
-
emitsPair
public boolean emitsPair()
-
setEmitsPair
public void setEmitsPair(boolean emitsPair)
-
-