You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by mi...@apache.org on 2020/05/12 08:14:38 UTC
[incubator-streampipes-extensions] 03/03: format code
This is an automated email from the ASF dual-hosted git repository.
micklich pushed a commit to branch feature/trajectory
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit c80f858a04295debc5dac4d4dd8c3bf0801fa2d7
Author: micklich <fl...@disy.net>
AuthorDate: Tue May 12 10:14:10 2020 +0200
format code
---
.../trajectory/CreateTrajectoryFromPoints.java | 68 +++++----
.../CreateTrajectoryFromPointsController.java | 161 ++++++++++-----------
.../CreateTrajectoryFromPointsParameter.java | 69 +++++----
3 files changed, 146 insertions(+), 152 deletions(-)
diff --git a/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPoints.java b/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPoints.java
index 26a695e..5ccb42e 100755
--- a/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPoints.java
+++ b/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPoints.java
@@ -31,52 +31,50 @@ import org.locationtech.jts.geom.Point;
public class CreateTrajectoryFromPoints implements EventProcessor<CreateTrajectoryFromPointsParameter> {
- private static Logger LOG;
+ private static Logger LOG;
- private SpTrajectoryBuilder trajectory;
+ private SpTrajectoryBuilder trajectory;
- private String geom_wkt;
- private String epsg_code;
- private String m_value;
+ private String geom_wkt;
+ private String epsg_code;
+ private String m_value;
+ @Override
+ public void onInvocation(CreateTrajectoryFromPointsParameter params, SpOutputCollector spOutputCollector, EventProcessorRuntimeContext runtimeContext) {
- @Override
- public void onInvocation(CreateTrajectoryFromPointsParameter params, SpOutputCollector spOutputCollector, EventProcessorRuntimeContext runtimeContext) {
+ LOG = params.getGraph().getLogger(CreateTrajectoryFromPointsParameter.class);
+ this.geom_wkt = params.getWkt();
+ this.epsg_code = params.getEpsg();
+ this.m_value = params.getM();
- LOG = params.getGraph().getLogger(CreateTrajectoryFromPointsParameter.class);
- this.geom_wkt = params.getWkt();
- this.epsg_code = params.getEpsg();
- this.m_value = params.getM();
+ trajectory = new SpTrajectoryBuilder(params.getSubpoints(), params.getDescription());
+ }
- trajectory = new SpTrajectoryBuilder(params.getSubpoints(), params.getDescription());
- }
+ @Override
+ public void onEvent(Event in, SpOutputCollector out) {
- @Override
- public void onEvent(Event in, SpOutputCollector out) {
+ // extract values
+ String wkt = in.getFieldBySelector(geom_wkt).getAsPrimitive().getAsString();
+ Integer epsg = in.getFieldBySelector(epsg_code).getAsPrimitive().getAsInt();
+ Integer m = in.getFieldBySelector(m_value).getAsPrimitive().getAsInt();
- // extract values
- String wkt = in.getFieldBySelector(geom_wkt).getAsPrimitive().getAsString();
- Integer epsg = in.getFieldBySelector(epsg_code).getAsPrimitive().getAsInt();
- Integer m = in.getFieldBySelector(m_value).getAsPrimitive().getAsInt();
+ //create JTS geometry
+ Point eventGeom = (Point) SpGeometryBuilder.createSPGeom(wkt, epsg);
- //create JTS geometry
- Point eventGeom = (Point) SpGeometryBuilder.createSPGeom(wkt,epsg);
+ //adds point and m value to trajectory object
+ trajectory.addPointToTrajectory(eventGeom, m);
+ // returns JTS LineString
+ LineString geom = trajectory.returnAsLineString(eventGeom.getFactory());
- //adds point and m value to trajectory object
- trajectory.addPointToTrajectory(eventGeom, m);
- // returns JTS LineString
- LineString geom = trajectory.returnAsLineString(eventGeom.getFactory());
+ // adds to stream
+ in.addField("wkt-trajectory", geom.toString());
+ in.addField("description", trajectory.getDescription());
+ out.collect(in);
+ }
- // adds to stream
- in.addField("wkt-trajectory", geom.toString());
- in.addField("description", trajectory.getDescription());
- out.collect(in);
+ @Override
+ public void onDetach() {
- }
-
- @Override
- public void onDetach() {
-
- }
+ }
}
diff --git a/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsController.java b/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsController.java
index a94140c..e3c3021 100755
--- a/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsController.java
+++ b/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsController.java
@@ -31,86 +31,83 @@ import org.apache.streampipes.vocabulary.SO;
import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor;
import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer;
-public class CreateTrajectoryFromPointsController extends StandaloneEventProcessingDeclarer<CreateTrajectoryFromPointsParameter> {
-
-
-
-
- public final static String POINT_KEY = "point-key";
- public final static String EPSG_KEY = "epsg-key";
- public final static String M_KEY = "m-key";
- public final static String DESCRIPTION_KEY = "description-key";
- public final static String SUBPOINTS_KEY = "subpoints-key";
-
- public final static String WKT = "trajectory_wkt";
- public final static String EPA_NAME = "Create Single Trajectory";
-
-
- @Override
- public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder
- .create("org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory")
- .category(DataProcessorType.GEO)
- .withAssets(Assets.DOCUMENTATION, Assets.ICON)
- .withLocales(Locales.EN)
- .requiredStream(
- StreamRequirementsBuilder
- .create()
- .requiredPropertyWithUnaryMapping(
- EpRequirements.domainPropertyReq("http://www.opengis.net/ont/geosparql#Geometry"),
- Labels.withId(POINT_KEY), PropertyScope.MEASUREMENT_PROPERTY
- )
- .requiredPropertyWithUnaryMapping(
- EpRequirements.domainPropertyReq("http://data.ign.fr/def/ignf#CartesianCS"),
- Labels.withId(EPSG_KEY), PropertyScope.MEASUREMENT_PROPERTY
- )
- .requiredPropertyWithUnaryMapping(
- EpRequirements.numberReq(),
- Labels.withId(M_KEY), PropertyScope.MEASUREMENT_PROPERTY
- )
- .build()
- )
- .requiredTextParameter(
- Labels.withId(DESCRIPTION_KEY)
- )
- .requiredIntegerParameter(
- Labels.withId(SUBPOINTS_KEY),
- 2, 30, 1
- )
-
- .outputStrategy(OutputStrategies.append(
- EpProperties.numberEp(
- Labels.withId(M_KEY),
- "m-value",
- SO.Number
- ),
- EpProperties.numberEp(
- Labels.withId(WKT),
- "trajectory-wkt",
- "http://www.opengis.net/ont/geosparql#Geometry")
- )
- )
-
- .supportedFormats(SupportedFormats.jsonFormat())
- .supportedProtocols(SupportedProtocols.kafka())
- .build();
- }
-
-
- @Override
- public ConfiguredEventProcessor<CreateTrajectoryFromPointsParameter> onInvocation(DataProcessorInvocation graph, ProcessingElementParameterExtractor extractor) {
-
-
- String wkt = extractor.mappingPropertyValue(WKT);
- String epsg = extractor.mappingPropertyValue(EPSG_KEY);
- String m = extractor.mappingPropertyValue(M_KEY);
-
- String description = extractor.singleValueParameter(DESCRIPTION_KEY, String.class);
- Integer subpoints = extractor.singleValueParameter(SUBPOINTS_KEY, Integer.class);
-
-
- CreateTrajectoryFromPointsParameter params = new CreateTrajectoryFromPointsParameter(graph, wkt, epsg, description, subpoints, m);
-
- return new ConfiguredEventProcessor<>(params, CreateTrajectoryFromPoints::new);
- }
+public class CreateTrajectoryFromPointsController extends StandaloneEventProcessingDeclarer<CreateTrajectoryFromPointsParameter> {
+
+
+ public final static String POINT_KEY = "point-key";
+ public final static String EPSG_KEY = "epsg-key";
+ public final static String M_KEY = "m-key";
+ public final static String DESCRIPTION_KEY = "description-key";
+ public final static String SUBPOINTS_KEY = "subpoints-key";
+
+ public final static String WKT = "trajectory_wkt";
+
+
+ @Override
+ public DataProcessorDescription declareModel() {
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory")
+ .category(DataProcessorType.GEO)
+ .withAssets(Assets.DOCUMENTATION, Assets.ICON)
+ .withLocales(Locales.EN)
+ .requiredStream(
+ StreamRequirementsBuilder
+ .create()
+ .requiredPropertyWithUnaryMapping(
+ EpRequirements.domainPropertyReq("http://www.opengis.net/ont/geosparql#Geometry"),
+ Labels.withId(POINT_KEY), PropertyScope.MEASUREMENT_PROPERTY
+ )
+ .requiredPropertyWithUnaryMapping(
+ EpRequirements.domainPropertyReq("http://data.ign.fr/def/ignf#CartesianCS"),
+ Labels.withId(EPSG_KEY), PropertyScope.MEASUREMENT_PROPERTY
+ )
+ .requiredPropertyWithUnaryMapping(
+ EpRequirements.numberReq(),
+ Labels.withId(M_KEY), PropertyScope.MEASUREMENT_PROPERTY
+ )
+ .build()
+ )
+ .requiredTextParameter(
+ Labels.withId(DESCRIPTION_KEY)
+ )
+ .requiredIntegerParameter(
+ Labels.withId(SUBPOINTS_KEY),
+ 2, 30, 1
+ )
+
+ .outputStrategy(OutputStrategies.append(
+ EpProperties.numberEp(
+ Labels.withId(M_KEY),
+ "m-value",
+ SO.Number
+ ),
+ EpProperties.numberEp(
+ Labels.withId(WKT),
+ "trajectory-wkt",
+ "http://www.opengis.net/ont/geosparql#Geometry")
+ )
+ )
+
+ .supportedFormats(SupportedFormats.jsonFormat())
+ .supportedProtocols(SupportedProtocols.kafka())
+ .build();
+ }
+
+
+ @Override
+ public ConfiguredEventProcessor<CreateTrajectoryFromPointsParameter> onInvocation(DataProcessorInvocation graph, ProcessingElementParameterExtractor extractor) {
+
+
+ String wkt = extractor.mappingPropertyValue(WKT);
+ String epsg = extractor.mappingPropertyValue(EPSG_KEY);
+ String m = extractor.mappingPropertyValue(M_KEY);
+
+ String description = extractor.singleValueParameter(DESCRIPTION_KEY, String.class);
+ Integer subpoints = extractor.singleValueParameter(SUBPOINTS_KEY, Integer.class);
+
+
+ CreateTrajectoryFromPointsParameter params = new CreateTrajectoryFromPointsParameter(graph, wkt, epsg, description, subpoints, m);
+
+ return new ConfiguredEventProcessor<>(params, CreateTrajectoryFromPoints::new);
+ }
}
diff --git a/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsParameter.java b/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsParameter.java
index 0397ac5..872fb00 100755
--- a/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsParameter.java
+++ b/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/CreateTrajectoryFromPointsParameter.java
@@ -23,39 +23,38 @@ import org.apache.streampipes.wrapper.params.binding.EventProcessorBindingParams
public class CreateTrajectoryFromPointsParameter extends EventProcessorBindingParams {
- private String epsg;
- private String wkt;
- private String description;
- private Integer subpoints;
- private String m;
-
-
- public CreateTrajectoryFromPointsParameter(DataProcessorInvocation graph, String wkt, String epsg, String description, Integer subpoints, String m) {
- super(graph);
- this.wkt = wkt;
- this.epsg = epsg;
- this.description = description;
- this.subpoints = subpoints;
- this.m = m;
- }
-
- public String getEpsg() {
- return epsg;
- }
-
- public String getWkt() {
- return wkt;
- }
-
- public String getDescription() {
- return description;
- }
-
- public Integer getSubpoints() {
- return subpoints;
- }
-
- public String getM() {
- return m;
- }
+ private String epsg;
+ private String wkt;
+ private String description;
+ private Integer subpoints;
+ private String m;
+
+ public CreateTrajectoryFromPointsParameter(DataProcessorInvocation graph, String wkt, String epsg, String description, Integer subpoints, String m) {
+ super(graph);
+ this.wkt = wkt;
+ this.epsg = epsg;
+ this.description = description;
+ this.subpoints = subpoints;
+ this.m = m;
+ }
+
+ public String getEpsg() {
+ return epsg;
+ }
+
+ public String getWkt() {
+ return wkt;
+ }
+
+ public String getDescription() {
+ return description;
+ }
+
+ public Integer getSubpoints() {
+ return subpoints;
+ }
+
+ public String getM() {
+ return m;
+ }
}