public class ProcessorNode extends Object
Node that wraps a processor in the stream.
Modifier and Type | Field and Description |
---|---|
protected String |
componentId |
protected org.apache.storm.streams.GroupingInfo |
groupingInfo |
protected Fields |
outputFields |
protected int |
parallelism |
Constructor and Description |
---|
ProcessorNode(Processor<?> processor,
String outputStream,
Fields outputFields) |
ProcessorNode(Processor<?> processor,
String outputStream,
Fields outputFields,
boolean preservesKey) |
Modifier and Type | Method and Description |
---|---|
boolean |
emitsPair() |
Fields |
getOutputFields() |
Processor<?> |
getProcessor() |
Set<String> |
getWindowedParentStreams() |
boolean |
isBatch() |
boolean |
isPreservesKey() |
boolean |
isWindowed() |
void |
setEmitsPair(boolean emitsPair) |
void |
setWindowed(boolean windowed) |
String |
toString() |
protected final Fields outputFields
protected org.apache.storm.streams.GroupingInfo groupingInfo
protected String componentId
protected int parallelism
public ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields, boolean preservesKey)
public Processor<?> getProcessor()
public boolean isBatch()
public boolean isPreservesKey()
public String toString()
public Fields getOutputFields()
public boolean isWindowed()
public void setWindowed(boolean windowed)
public boolean emitsPair()
public void setEmitsPair(boolean emitsPair)
Copyright © 2022 The Apache Software Foundation. All rights reserved.