public final class NPLDataProcessor extends DataProcessor implements NPLConfigIfc
Constructor and Description |
---|
NPLDataProcessor(PartitionedDCNode dcNode) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getConfigValue(java.lang.String key) |
int |
getIntConfigValue(java.lang.String key) |
void |
initialize() |
void |
processData(java.lang.Object data)
Implement this to perform work on incoming data.
|
provideData, removeProvider, removeReceiver, setProvider, setReceiver, shutdown
public NPLDataProcessor(PartitionedDCNode dcNode)
public void initialize()
initialize
in interface BaseDataProcessorIfc
public void processData(java.lang.Object data)
DataReceiverProcessorIfc
processData
in interface DataReceiverProcessorIfc
public java.lang.String getConfigValue(java.lang.String key)
getConfigValue
in interface NPLConfigIfc
public int getIntConfigValue(java.lang.String key)
getIntConfigValue
in interface NPLConfigIfc