Background

https://github.com/apache/streampipes/blob/dev/streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint/documentation.md


Data Setup

import file and seup schema like

+ set timestamp to mark as timestamp

+ add semantic type lat => http://www.w3.org/2003/01/geo/wgs84_pos#lat

+ add semantic type long => http://www.w3.org/2003/01/geo/wgs84_pos#long



jts_points.csv

Pipeline

Result

timestampepsggeometrylatlng
16761390419114326POINT (8.375062 49.0113144)49.0113143920898448.375061988830566
16761390419144326POINT (8.4322996 49.0334015)49.033401489257818.432299613952637
16761390419154326POINT (8.3494587 48.9985352)48.998535156258.349458694458008

Tests


Performance

  • No labels