Huy

@briareosiso: change all casts `AS INT` to `AS DECIMAL` in `sql/jorani.sql` and run again.

Hi Ben. Can I use this lib in Java at the moment?

How do I call the `writeToKafka()` function? I need to write a `JavaDStream` to Kafka.

I can call `dstream` from `JavaDStream`, but it doesn't provide `.writeToKafka()` function.

This is the code I write. However, it complains that `Function1` is not serializable: ```java Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("value.serializer", StringSerializer.class); KafkaWriter kafkaWriter = new DStreamKafkaWriter(myStream.dstream(), scala.reflect.ClassTag$.MODULE$.apply(String.class));...

Hey, thanks. It works now. I'll leave here my complete code with proper Java syntax for anyone who's interested in: ```java abstract class MyFunc extends AbstractFunction1 implements Serializable {} public...

I've created pull request #60. Please have a look. Thanks.

Is there any plan to fix this? It's really annoying when alt-tab'ing back and forth between book and IDE to learn some programming.

Is there any update to this issue? My computer's fan spins like crazy when video plays. CPU load sits at ~50%.

Thanks for your explanation. There're several other errors as well but I don't recall for now. Will report when I see them again. Cheers.