Popular repositories Loading

1. cep cep Public

   complex event processing code

   Java 104 54

2. scripts scripts Public

   Shell 1

3. spark-structured-streaming-vs-dstreams spark-structured-streaming-vs-dstreams Public

   toy project illustrating how to process a mock stream of sensor data via Spark structured streaming and the (older) dstreams API

   Scala 1

4. sparkStreamingFindDupWordsInFiles sparkStreamingFindDupWordsInFiles Public

   Scala

5. json-schema-validation-demo json-schema-validation-demo Public

   short demo -- in scala -- of how to validate arbitrary JSON instance documents against a JSON schema

   Scala

6. spark-streaming-group-by-event-time spark-streaming-group-by-event-time Public

   code samples for this article: http://datalackey.com/2019/06/21/exploring-event-time-and-processing-time-in-spark-structured-streaming/

   Scala 1