logisland
logisland copied to clipboard
Hurence
Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex ev...
The aim of this processor is to show how to deploy a DeepLearning processor in logisland using deepLearning4j. It implement a (preliminary built and trained with MNIST dataset) Neural Network...
Would like a "generic" linear regression processor that applies linear regressions on incoming events
Would like a markov model processor (a processor that identifies sequences of events) and therefore can detect the bypassing of "normal" sequences in case of intrusion detection or predict on...
can get information from https://github.com/whois-server-list/whois-server-list
could be based on this project : https://github.com/komoot/photon
# Expected behavior and actual behavior. When deserializing an Avro record from Kafka topic, I got the following Java exception: java.lang.IllegalArgumentException: No enum constant com.hurence.logisland.record.FieldType.UNION at java.lang.Enum.valueOf(Unknown Source) at com.hurence.logisland.record.FieldType.valueOf(FieldType.java:23)...
the feed must be able to schedule db updates and to be embedded into a live processor to tag events - Soltra - OpenTaxi
this processor gets data from many threat intelligence providers and tag events if ip are in blacklist Each threat intel source has two components: an enrichment data source and an...
It is a common task to decompose the useragent from the http header into several properties that can be easily reused afterwards. This should go into a processor.
In the index-apache-logs.yml config file, the stream for the SplitText processor has the following config key: avro.output.schema: > { "version":1, "type": "record", "name": "com.hurence.logisland.record.apache_log", "fields": [ { "name": "record_errors", "type":...
