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.StatefulProcessorExceptionpublic void resetState()
throws Exception
resetState in interface stream.StatefulProcessorExceptionpublic void finish()
throws Exception
finish in interface stream.StatefulProcessorExceptionpublic stream.Data process(stream.Data item)
process in interface stream.ProcessorCopyright © 2019. All rights reserved.