public class GpsTimeCorrection extends Object implements stream.Processor
This processor handles the Gps time correction. It requires a gps time corrected events file either as URL and will read the Unix time data ( unix time seconds, unix time microseconds ) from that. The corrected time datum is then applied to the corresponding FactEvent processed by the process method.
| Modifier and Type | Field and Description |
|---|---|
TreeMap<Integer,Integer[]> |
gpsTimes
This is the structure to hold the gps times in [int,int]: [seconds microseconds].
|
String |
outputKey |
| Constructor and Description |
|---|
GpsTimeCorrection() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
loadGpsTimeCorrection(stream.io.SourceURL in) |
stream.Data |
process(stream.Data item)
This is the method called in the process loop.
|
void |
setUrl(URL url) |
@Parameter(required=true,
description="Key of the GpsUnixTimeUTC[2] output")
public String outputKey
public stream.Data process(stream.Data item)
process in interface stream.Processorprotected void loadGpsTimeCorrection(stream.io.SourceURL in)
public void setUrl(URL url)
Copyright © 2019. All rights reserved.