Mirko Kämpf
Mirko Kämpf
Using the TLS demo works as expected. I can bring up the cluster and use the produce and consume example as recommended at the end in the script named **up**....
Using overpass-api.de it was not possible to load results for this query: ["out":"json"]["timeout":"30"]; ( node ["amenity"="parking"] ["access"!="private"] (47.48047027491862,19.039797484874725,47.51331674014172,19.07404761761427);
This is a draft pull request. I wanted to test the added function readKafkaTopic(topicName: String) which is new in the JavaPlanBuilder. Here is my test code: import org.apache.wayang.api.JavaPlanBuilder; import org.apache.wayang.basic.data.Tuple2;...
I have added the logging functionality to the CsvRowConverter. Also added the CsvRowConverterTest.java to test the thing. Tested with: mvn compile test -Dlog4j2.level=DEBUG Shows: [INFO] ------------------------------------------------------- [INFO] T E S...
This issue is related to #386 . **In this issue we want to identify the scope of Apache Wayang - Apache Kafka support.** Apache Kafka does not offer a processing...
This is a PR to prep the release v1.0.0. I started working on this, using the original repository, not a clone, but due to missing permissions I can't push directly....
In order to read text input files from remote sources like SOLID Datapods I added this functionality to the JavaTextSource.
Besides the following processing platforms: [Java 8 Streams] [Apache Spark](https://spark.apache.org/) [GraphChi](https://github.com/GraphChi/graphchi-java) [Postgres](http://www.postgresql.org/) [SQLite](https://www.sqlite.org/) [Apache Flink](https://flink.apache.org/) it is suggested to also support Apache Kafka. This issue is considered to be an...
Implementation of Event-Synchronization, Granger-Causality and Cross-Correlation (for pairs of time series) as well as Partial-Correlation analysis (for triples) are implemented in Java. There is also a test-data generator to prep...