public class ProcessorNode extends Node
Modifier and Type | Field and Description |
---|---|
boolean |
committer |
TridentProcessor |
processor |
Fields |
selfOutFields |
allOutputFields, creationIndex, name, parallelismHint, stateInfo, streamId
Constructor and Description |
---|
ProcessorNode(String streamId,
String name,
Fields allOutputFields,
Fields selfOutFields,
TridentProcessor processor) |
Modifier and Type | Method and Description |
---|---|
String |
shortString() |
addSharedMemory, getResources, getSharedMemory, setCPULoad, setMemoryLoad, setMemoryLoad
public boolean committer
public TridentProcessor processor
public Fields selfOutFields
public ProcessorNode(String streamId, String name, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor)
public String shortString()
shortString
in class Node
Copyright © 2022 The Apache Software Foundation. All rights reserved.