Skip to content

Instantly share code, notes, and snippets.

View kaiwaehner's full-sized avatar

Kai Waehner kaiwaehner

View GitHub Profile
select eventid, anomaly(SENSORINPUT) from carsensor;
package com.github.megachucky.kafka.streams.machinelearning;
import java.util.Arrays;
import hex.genmodel.GenModel;
import hex.genmodel.easy.EasyPredictModelWrapper;
import hex.genmodel.easy.RowData;
import hex.genmodel.easy.exception.PredictException;
import hex.genmodel.easy.prediction.AutoEncoderModelPrediction;
import io.confluent.ksql.function.udf.Udf;
@Udf(description = "apply analytic model to sensor input")
public String anomaly(String sensorinput){ "YOUR LOGIC" }
SELECT STRINGTOTIMESTAMP(timestamp, 'yyyy-MM-dd HH:mm:ss.SSS') FROM TimestampStream;
java.lang.NoClassDefFoundError: Could not initialize class com.fasterxml.jackson.databind.SerializationConfig
at com.fasterxml.jackson.databind.ObjectMapper.<init>(ObjectMapper.java:558)
at com.fasterxml.jackson.databind.ObjectMapper.<init>(ObjectMapper.java:474)
at io.confluent.rest.Application.getJsonMapper(Application.java:407)
at io.confluent.rest.Application.configureBaseApplication(Application.java:380)
at io.confluent.rest.Application.createServer(Application.java:148)
at io.confluent.kafka.schemaregistry.RestApp.start(RestApp.java:59)
at com.github.megachucky.kafka.streams.machinelearning.test.utils.EmbeddedSingleNodeKafkaCluster.start(EmbeddedSingleNodeKafkaCluster.java:68)
at com.github.megachucky.kafka.streams.machinelearning.test.utils.EmbeddedSingleNodeKafkaCluster.before(EmbeddedSingleNodeKafkaCluster.java:83)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)