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);