public class Accumulator extends java.lang.Object implements DataSignal.ProcessorConfig
Modifier and Type | Class and Description |
---|---|
static class |
Accumulator.State
Representation of the accumulator's internal state
|
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
FIELD_OUTPUT |
java.lang.Byte |
output |
static java.lang.String |
SCHEME_NAME |
Constructor and Description |
---|
Accumulator()
Constructs a config object with inferred output size
|
Accumulator(byte output)
Constructs a config object with user defined output size
|
Accumulator(java.util.Map<java.lang.String,java.lang.String> query)
Constructs an accumulator config object from a URI string
|
public static final java.lang.String SCHEME_NAME
public static final java.lang.String FIELD_OUTPUT
public final java.lang.Byte output
public Accumulator(java.util.Map<java.lang.String,java.lang.String> query)
query
- String-String map containing the fields from the URI stringpublic Accumulator()
public Accumulator(byte output)
output
- How many bytes to allocate for the output, between [1-4]