public class TimeOverThresholdTL extends Object implements stream.Processor
String
dataKey
int
firstSlice
outputKey
range
double
threshold
TimeOverThresholdTL()
stream.Data
process(stream.Data item)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
@Parameter(required=true) public String dataKey
@Parameter(required=false) public double threshold
@Parameter public int range
@Parameter public int firstSlice
@Parameter(required=true) public String outputKey
public TimeOverThresholdTL()
public stream.Data process(stream.Data item)
process
stream.Processor
Copyright © 2019. All rights reserved.