public class GaussConvolution extends Object implements stream.StatefulProcessor
| Modifier and Type | Field and Description |
|---|---|
String |
key |
String |
outputKey |
double |
variance |
| Constructor and Description |
|---|
GaussConvolution() |
| Modifier and Type | Method and Description |
|---|---|
void |
finish() |
void |
init(stream.ProcessContext context) |
stream.Data |
process(stream.Data item) |
void |
resetState() |
@Parameter(required=true) public String key
@Parameter(required=false,
defaultValue="1")
public double variance
@Parameter(required=true) public String outputKey
public void init(stream.ProcessContext context)
throws Exception
init in interface stream.StatefulProcessorExceptionpublic stream.Data process(stream.Data item)
process in interface stream.Processorpublic void resetState()
throws Exception
resetState in interface stream.StatefulProcessorExceptionCopyright © 2019. All rights reserved.