Package org.apache.storm.streams
Class ProcessorNode
java.lang.Object
org.apache.storm.streams.ProcessorNode
- All Implemented Interfaces:
- Serializable
Node that wraps a processor in the stream.
- See Also:
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionProcessorNode(Processor<?> processor, String outputStream, Fields outputFields) ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields, boolean preservesKey) 
- 
Method SummaryModifier and TypeMethodDescriptionbooleanProcessor<?>booleanisBatch()booleanbooleanvoidsetEmitsPair(boolean emitsPair) voidsetWindowed(boolean windowed) toString()
- 
Field Details- 
outputFields
- 
groupingInfoprotected org.apache.storm.streams.GroupingInfo groupingInfo
- 
componentId
- 
parallelismprotected int parallelism
 
- 
- 
Constructor Details- 
ProcessorNode
- 
ProcessorNode
 
- 
- 
Method Details- 
getProcessor
- 
isBatchpublic boolean isBatch()
- 
getWindowedParentStreams
- 
isPreservesKeypublic boolean isPreservesKey()
- 
toString
- 
getOutputFields
- 
isWindowedpublic boolean isWindowed()
- 
setWindowedpublic void setWindowed(boolean windowed) 
- 
emitsPairpublic boolean emitsPair()
- 
setEmitsPairpublic void setEmitsPair(boolean emitsPair) 
 
-