streampipes-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zehn...@apache.org
Subject [incubator-streampipes] 25/25: Merge branch 'dev' of https://github.com/apache/incubator-streampipes-examples into dev
Date Tue, 17 Dec 2019 09:48:26 GMT
This is an automated email from the ASF dual-hosted git repository.

zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git

commit 6d041dd5d10024b966801a7d067869724bd72c5d
Merge: 22d66b2 067bea1
Author: Philipp Zehnder <zehnder@fzi.de>
AuthorDate: Tue Dec 17 10:45:00 2019 +0100

    Merge branch 'dev' of https://github.com/apache/incubator-streampipes-examples into dev

 .gitignore                                         |   2 +-
 .gitlab-ci.yml                                     |   1 -
 README.md                                          |   4 -
 development/.env                                   |  19 ++++
 pom.xml                                            |  40 +++++++-
 .../pom.xml                                        |  79 ++++++++++++++++
 .../streampipes/pe/examples/jvm/ExamplesInit.java  |  77 ++++++++++++++++
 .../pe/examples/jvm/base/DummyController.java      |  41 +++++++++
 .../pe/examples/jvm/base/DummyEngine.java          |  43 +++++++++
 .../pe/examples/jvm/base/DummyParameters.java      |  28 ++++++
 .../pe/examples/jvm/config/ConfigKeys.java         |  27 ++++++
 .../pe/examples/jvm/config/ExamplesJvmConfig.java  |  87 ++++++++++++++++++
 .../examples/jvm/engine/ExampleExternalEngine.java |  41 +++++++++
 .../engine/ExampleExternalEngineController.java    |  50 ++++++++++
 .../engine/ExampleExternalEngineParameters.java    |  28 ++++++
 .../jvm/eventmodel/EventModelExamples.java         |  72 +++++++++++++++
 .../jvm/outputstrategy/AppendOutputController.java |  62 +++++++++++++
 .../jvm/outputstrategy/CustomOutputController.java |  61 +++++++++++++
 .../CustomTransformOutputController.java           |  76 ++++++++++++++++
 .../jvm/outputstrategy/FixedOutputController.java  |  61 +++++++++++++
 .../jvm/outputstrategy/KeepOutputController.java   |  58 ++++++++++++
 .../outputstrategy/TransformOutputController.java  |  67 ++++++++++++++
 .../requirements/ListRequirementsController.java   |  60 ++++++++++++
 .../requirements/NestedRequirementsController.java |  21 +++++
 .../SimpleStreamRequirementsController.java        |  66 ++++++++++++++
 .../CollectionExampleController.java               |  69 ++++++++++++++
 .../MultiValueSelectionExampleController.java      |  69 ++++++++++++++
 .../NaryMappingPropertyExampleController.java      |  66 ++++++++++++++
 .../NumberParameterExampleController.java          |  74 +++++++++++++++
 .../NumberParameterWithRangeExampleController.java |  69 ++++++++++++++
 .../RuntimeResolvableSingleValue.java              | 101 +++++++++++++++++++++
 .../SecretStaticPropertyExampleController.java     |  68 ++++++++++++++
 .../SingleValueSelectionExampleController.java     |  68 ++++++++++++++
 .../StaticPropertyAlternativesController.java      |  82 +++++++++++++++++
 .../TextParameterExampleController.java            |  67 ++++++++++++++
 .../UnaryMappingPropertyExampleController.java     |  64 +++++++++++++
 36 files changed, 1961 insertions(+), 7 deletions(-)

diff --cc .gitignore
index 4be343a,3a1f524..44c4ff0
--- a/.gitignore
+++ b/.gitignore
@@@ -67,73 -67,11 +67,73 @@@ fabric.propertie
  */log/*
  */target/*
  
--target/
 -# JS
 +# JS 
  dist/
  
  ./target/*
  npm-debug.log
  
 +# Test Data from running in local mode
 +/test_data/
 +
 +ui/src/assets/lib/apps/*
 +
 +
 +# prebuild
 +ui/src/app/app.module.ts
 +ui/src/app/appng5.module.ts
 +ui/src/app/core/state.config.ts
 +ui/src/app/layout/toolbar.controller.ts
 +ui/src/app/home/home.service.ts
 +ui/src/app/services/version/version.service.ts
 +
 +# compiled output
 +ui/dist
 +ui/dist-server
 +ui/tmp
 +ui/out-tsc
 +
 +# dependencies
 +ui/node_modules/
 +
 +# IDEs and editors
 +/.idea
 +.project
 +.classpath
 +.c9/
 +*.launch
 +.settings/
 +*.sublime-workspace
 +
 +# IDE - VSCode
 +.vscode/*
 +!.vscode/settings.json
 +!.vscode/tasks.json
 +!.vscode/launch.json
 +!.vscode/extensions.json
 +
 +# misc
 +/.sass-cache
 +/connect.lock
 +/coverage
 +/libpeerconnection.log
 +npm-debug.log
 +npm-debug.log.*
 +testem.log
 +/typings
 +
 +# e2e
 +/e2e/*.js
 +/e2e/*.map
 +
 +# System Files
 +.DS_Store
 +Thumbs.db
 +
 +bundle.js
 +bundle.js.map
 +
 +.vscode/
 +
 +package-lock.json
+ logs/
diff --cc .gitlab-ci.yml
index b6fe2df,f2710af..86dd450
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@@ -29,20 -33,19 +29,19 @@@ pull github
    image: maven:3-jdk-8
    stage: github
    script:
 -    - git remote set-url origin $GIT_REPO_ORIGIN/$CI_PROJECT_NAMESPACE/$CI_PROJECT_NAME.git
 -    - git remote add github https://github.com/apache/incubator-streampipes-examples.git
 -    - eval $(ssh-agent -s)
 -    - ssh-add <(echo "$SSH")
 -    - mkdir ~/.ssh
 -    - touch ~/.ssh/known_hosts
 -    - ssh-keyscan -p 2222 -t rsa $GITLAB_HOST > ~/.ssh/known_hosts
 -    - git config --global user.email '$USER_EMAIL'
 -    - git config --global user.name '$USER_NAME'
 -    - git checkout dev
 -    - git pull github dev
 -    - git push origin --all
 +  - git remote set-url origin $GIT_REPO_ORIGIN/$CI_PROJECT_NAMESPACE/$CI_PROJECT_NAME.git
 +  - git remote add github https://github.com/apache/incubator-streampipes-examples.git
 +  - eval $(ssh-agent -s)
 +  - ssh-add <(echo "$SSH")
 +  - mkdir ~/.ssh
 +  - touch ~/.ssh/known_hosts
 +  - ssh-keyscan -p 2222 -t rsa $GITLAB_HOST > ~/.ssh/known_hosts
 +  - git config --global user.email '$USER_EMAIL'
 +  - git config --global user.name '$USER_NAME'
 +  - git checkout dev
 +  - git pull github dev --allow-unrelated-histories
 +  - git push origin --all
  
- 
  build:
    image: maven:3-jdk-8
    stage: build
diff --cc README.md
index b6c2ce2,1ee028e..8d03867
--- a/README.md
+++ b/README.md
@@@ -16,118 -16,23 +16,114 @@@
    ~
    -->
  
 -# StreamPipes
 +[![Github Actions](https://img.shields.io/github/workflow/status/apache/incubator-streampipes/build-and-deploy-docker-dev)](https://github.com/apache/incubator-streampipes/actions/)
 +[![Docker pulls](https://img.shields.io/docker/pulls/streampipes/backend.svg)](https://hub.docker.com/r/streampipes/backend/)
 +[![Maven central](https://img.shields.io/maven-central/v/org.streampipes/streampipes-backend.svg)](https://img.shields.io/maven-central/v/org.streampipes/streampipes-backend.svg)
 +[![License](https://img.shields.io/github/license/apache/incubator-streampipes.svg)](http://www.apache.org/licenses/LICENSE-2.0)
 +[![Last commit](https://img.shields.io/github/last-commit/apache/incubator-streampipes.svg)]()
 +[![Twitter](https://img.shields.io/twitter/follow/StreamPipes.svg?label=Follow&style=social)](https://twitter.com/StreamPipes)
  
 -Apache StreamPipes (incubating) A self-service (Industrial) IoT toolbox to enable non-technical
users to connect
 -, analyze and explore IoT data streams.
 +<h1 align="center">
 +  <br>
 +   <img src="https://streampipes.apache.org/img/sp-logo-color.png" 
 +   alt="StreamPipes Logo" title="Apache StreamPipes Logo" width="50%"/>
 +  <br>
 +</h1>
 +<h3 align="center">Self-Service Data Analytics for the (Industrial) IoT</h3>
 +<h4 align="center">StreamPipes is a self-service (Industrial) IoT toolbox to enable
non-technical users to connect
 +, analyze and explore IoT data streams. </h4>
 +<p align="center">  
 +    <img src="https://streampipes.apache.org/img/screenshots/pipeline-editor-2.png" alt="StreamPipes
Pipeline
 +     Editor"/>
 +</p>
 +
 +***
 +
 +## Table of contents
 +
 +  * [About Apache StreamPipes](#about-streampipes)
 +  * [Use Cases](#use-cases)
 +  * [Installation](#installation)
 +  * [Pipeline Elements](#pipeline-elements)
 +  * [Extending StreamPipes](#extending-streampipes)
 +  * [Get help](#get-help)
 +  * [Contribute](#contribute)
 +  * [Feedback](#feedback)
 +  * [License](#license)
 +
 +***
 +
 +## About Apache StreamPipes
 +
 +Apache StreamPipes (incubating) enables flexible modeling of stream processing pipelines
by providing a graphical
 + modeling
 + editor on top of existing stream processing frameworks.
  
  It leverages non-technical users to quickly define and execute processing pipelines based
on an easily extensible 
 -toolbox of data sources, data processors and data sinks.
 +toolbox of data sources, data processors and data sinks. StreamPipes has an exchangeable
runtime execution layer and executes pipelines using one of the provided wrappers, e.g., for
Apache Flink or Apache Kafka Streams.
 +
 +Pipeline elements in StreamPipes can be installed at runtime - the built-in SDK allows to
easily implement new 
 +pipeline elements according to your needs. Pipeline elements are standalone microservices
that can run anywhere - centrally on your server, in a large-scale cluster or close at the
edge.
 +
- Learn more about StreamPipes at [https://streampipes.apache.org/](https://streampipes.apache.org/)
- 
- Read the full documentation at [https://streampipes.apache.org/docs](https://streampipes.apache.org/docs)
- 
 +## Use Cases
 +
 +StreamPipes allows you to connect IoT data sources using the SDK or the built-in graphical
tool StreamPipes 
 +Connect.
 +
 +The extensible toolbox of data processors and sinks supports use cases such as
 +* Continuously **store** IoT data streams to third party systems (e.g., databases)
 +* **Filter** measurements on streams (e.g., based on thresholds or value ranges)
 +* **Harmonize** data by using data processors for transformations (e.g., by converting measurement
units and data types
 + or by aggregating measurements)
 +* **Detect situations** that should be avoided (e.g., patterns based on time windows)
 +* Wrap **Machine Learning models** into data processors to perform classifications or predictions
on sensor and image data
 +* **Visualize** real-time data from sensors and machines using the built-in Live Dashboard
 +
 +
 +## Installation
 +
 +The quickest way to run StreamPipes is the Docker-based installer script available for Unix,
Mac and Windows (10).
 +
 +It's easy to get started:
 +1. Make sure you have [Docker](https://docs.docker.com/install/) and [Docker Compose](https://docs.docker.com/compose/install/)
installed.
 +2. Clone or download the installer script from [https://www.github.com/apache/incubator-streampipes-installer](https://www.github.com/apache/incubator-streampipes-installer)
 +3. Execute ``./streampipes start`` 
 +4. Enter the hostname and choose the version you'd like to run (the Lite version runs with
less memory assigned to Docker (< 6 GB), use the full version if you have more memory available)
 +5. Open your browser, navigate to ``http://YOUR_HOSTNAME_HERE`` and follow the installation
instructions.
 +6. Once finished, switch to the pipeline editor and start the interactive tour or check
the [online tour](https://streampipes.apache.org/docs/docs/user-guide-tour/) to learn how
to create your first pipeline!
 +
 +For a more in-depth manual, read the installation guide at [https://streampipes.apache.org/docs/docs/user-guide-installation/](https://streampipes.apache.org/docs/docs/user-guide-installation/)!
 +
 +## Pipeline Elements
 +
 +StreamPipes includes a repository of ready-to-use pipeline elements. A description of the
standard elements can be 
 +found in the Github repository [streampipes-extensions](https://www.github.com/apache/incubator-streampipes-extensions).
 +
 +## Extending StreamPipes
 +
 +You can easily add your own data streams, processors or sinks. A [Java-based SDK](https://streampipes.apache.org/docs/docs/dev-guide-tutorial-processors)
and several [run-time wrappers](https://streampipes.apache.org/docs/docs/dev-guide-architecture)
for popular streaming frameworks such as Apache Flink, Apache Spark and Apache 
 +Kafka Streams (and also plain Java programs) can be used to integrate your existing processing
logic into StreamPipes. Pipeline elements are packaged as Docker images and can be installed
at runtime, whenever your requirements change.
 +
 +Check our developer guide at [https://streampipes.apache.org/docs/docs/dev-guide-introduction](https://streampipes.apache.org/docs/docs/dev-guide-introduction).
 +
 +## Get help
 +
 +If you have any problems during the installation or questions around StreamPipes, you'll
get help through one of our 
 +community channels:
 +
 +- [Slack](https://slack.streampipes.org)
 +- [Mailing Lists](https://streampipes.apache.org/mailinglists.html)
 +
 +And don't forget to follow us on [Twitter](https://twitter.com/streampipes)!
 +
 +## Contribute
  
 -Learn more about StreamPipes at [https://streampipes.apache.org/](https://streampipes.apache.org/)
 +We welcome contributions to StreamPipes. If you are interested in contributing to StreamPipes,
let us know!
  
 -Read the full documentation at [https://streampipes.apache.org/docs](https://streampipes.apache.org/docs)
 +## Feedback
  
 -### StreamPipes Pipeline Elements Examples
 +We'd love to hear your feedback! Subscribe to [users@streampipes.apache.org](mailto:users@streampipes.apache.org)
  
 -The pipeline elements defined in this repository **do nothing** - they only serve to provide
examples on how pipeline 
 -elements can be created with StreamPipes. The examples are referenced in the SDK guide 
 -(https://docs.streampipes.org/docs/dev-guide-introduction)
 +## License
  
 -If you are looking for **real** pipeline elements that can be installed in StreamPipes,
have a look at 
 -[StreamPipes Pipeline Elements](https://www.github.com/apache/incubator-streampipes-extensions).
 +[Apache License 2.0](LICENSE)
diff --cc pom.xml
index 2ae11f1,69fd0eb..788859b
--- a/pom.xml
+++ b/pom.xml
@@@ -692,43 -127,7 +692,44 @@@
              <dependency>
                  <groupId>junit</groupId>
                  <artifactId>junit</artifactId>
 +                <version>${junit.version}</version>
 +                <scope>test</scope>
 +            </dependency>
 +            <dependency>
 +                <groupId>net.bytebuddy</groupId>
 +                <artifactId>byte-buddy</artifactId>
 +                <version>${byte-buddy.version}</version>
 +                <scope>test</scope>
 +            </dependency>
 +            <dependency>
 +                <groupId>net.bytebuddy</groupId>
 +                <artifactId>byte-buddy-agent</artifactId>
 +                <version>${byte-buddy.version}</version>
 +                <scope>test</scope>
 +            </dependency>
 +            <dependency>
 +                <groupId>org.mockito</groupId>
 +                <artifactId>mockito-core</artifactId>
 +                <version>${mockito.version}</version>
 +                <scope>test</scope>
 +            </dependency>
 +            <dependency>
 +                <groupId>org.powermock</groupId>
 +                <artifactId>powermock-module-junit4</artifactId>
 +                <version>${powermock.version}</version>
 +                <scope>test</scope>
 +            </dependency>
 +            <dependency>
 +                <groupId>org.powermock</groupId>
 +                <artifactId>powermock-api-mockito2</artifactId>
 +                <version>${powermock.version}</version>
 +                <scope>test</scope>
 +            </dependency>
 +            <dependency>
 +                <groupId>com.jayway.restassured</groupId>
 +                <artifactId>rest-assured</artifactId>
 +                <version>${rest-assured.version}</version>
+                 <version>4.12</version>
                  <scope>test</scope>
              </dependency>
          </dependencies>
@@@ -825,13 -152,12 +826,14 @@@
                                  <goals>
                                      <goal>jar</goal>
                                  </goals>
 +                                <configuration>
 +                                    <additionalparam>-Xdoclint:none</additionalparam>
 +                                    <doclint>none</doclint>
 +                                    <source>8</source>
 +                                </configuration>
                              </execution>
                          </executions>
 -                        <configuration>
 -                            <failOnError>false</failOnError>
 -                            <additionalparam>-Xdoclint:none</additionalparam>
 -                        </configuration>
++
                      </plugin>
                      <plugin>
                          <groupId>external.atlassian.jgitflow</groupId>


Mime
View raw message