public class AggrShifter extends AggregatorModule
Modifier and Type | Field and Description |
---|---|
protected int |
shift_factor |
protected int |
shiftAttrID |
protected int[] |
shiftAttrs |
protected java.lang.String |
shiftAttrValue |
config, logger
Constructor and Description |
---|
AggrShifter(ConfigIfc config,
LoggerIfc logger)
Creates a shifter object with the configuration and logger objects.
|
Modifier and Type | Method and Description |
---|---|
protected void |
getConfigData()
Gets the shifting-related rules
|
boolean |
needShift(NAR nar)
Checks if the given NAR needs shifting.
|
int[] |
recordInitFields()
Returns those fields needed by a newly created record
|
void |
shift(NAR nar)
Shifts the appropriate fields of the given NAR by the configured
shift factor.
|
void |
shutdown()
Performs shutdown procedures.
|
protected int shift_factor
protected int[] shiftAttrs
protected int shiftAttrID
protected java.lang.String shiftAttrValue
protected void getConfigData()
getConfigData
in class AggregatorModule
public int[] recordInitFields()
recordInitFields
in class AggregatorModule
public void shutdown()
shutdown
in class AggregatorModule
public boolean needShift(NAR nar)
nar
- NAR to checkpublic void shift(NAR nar)
nar
- NAR to shift