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 18:36:45 UTC
[incubator-streampipes-extensions] branch dev updated (d7f821d ->
cd0fc2a)
This is an automated email from the ASF dual-hosted git repository.
micklich pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
from d7f821d fix STREAMPIPES-123
add 0f81507 change to ontology vocabulary, changed text and new icon
add cd1fc3d format fix
add a71d887 env
add d7b5bbe changed from label.from to withID
add 370cdc6 format code
new cd0fc2a Merge remote-tracking branch 'origin/feature/latLngGeo' into feature/latLngGeo
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java | 6 ++++++
1 file changed, 6 insertions(+)
[incubator-streampipes-extensions] 01/01: Merge remote-tracking
branch 'origin/feature/latLngGeo' into feature/latLngGeo
Posted by mi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
micklich pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit cd0fc2a3736b845b5b48694fb03e629c9d31fe5f
Merge: d7f821d 370cdc6
Author: micklich <fl...@disy.net>
AuthorDate: Tue May 12 20:35:56 2020 +0200
Merge remote-tracking branch 'origin/feature/latLngGeo' into feature/latLngGeo
.../geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --cc streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java
index 747ffaf,d9a82c9..1df6aba
--- a/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java
+++ b/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java
@@@ -76,10 -77,10 +76,16 @@@ public class LatLngToGeoController exte
.build();
}
++ .supportedFormats(SupportedFormats.jsonFormat())
++ .supportedProtocols(SupportedProtocols.kafka())
++ .build();
++ }
@Override
public ConfiguredEventProcessor<LatLngToGeoParameter> onInvocation(DataProcessorInvocation graph, ProcessingElementParameterExtractor extractor) {
++ @Override
++ public ConfiguredEventProcessor<LatLngToGeoParameter> onInvocation(DataProcessorInvocation graph, ProcessingElementParameterExtractor extractor) {
String lat = extractor.mappingPropertyValue(LAT_KEY);
String lng = extractor.mappingPropertyValue(LNG_KEY);