public class CastToDoubleArray extends Object implements stream.StatefulProcessor
Constructor and Description |
---|
CastToDoubleArray() |
Modifier and Type | Method and Description |
---|---|
void |
finish() |
void |
init(stream.ProcessContext context) |
stream.Data |
process(stream.Data item) |
void |
resetState() |
@Parameter(required=true, description="The key to your data array.") public String key
@Parameter(required=false) public String outputKey
public void init(stream.ProcessContext context) throws Exception
init
in interface stream.StatefulProcessor
Exception
public void resetState() throws Exception
resetState
in interface stream.StatefulProcessor
Exception
public void finish() throws Exception
finish
in interface stream.StatefulProcessor
Exception
public stream.Data process(stream.Data item)
process
in interface stream.Processor
Copyright © 2019. All rights reserved.