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.StatefulProcessor
Exception
public stream.Data process(stream.Data item)
process
in interface stream.Processor
public void resetState() throws Exception
resetState
in interface stream.StatefulProcessor
Exception
Copyright © 2019. All rights reserved.