spark

Type Members

1. class BulletSparkMetrics extends BulletSparkLogger with Serializable

   

2. class BulletSparkStreamingBaseJob extends BulletSparkLogger

   

3. trait DataProducer extends AnyRef

   

   Trait that can be implemented to produce BulletRecord data as input to Bullet running on Spark Streaming.

   Trait that can be implemented to produce BulletRecord data as input to Bullet running on Spark Streaming.

   This trait is used to plugin users' source of data to Bullet. The data can be from anywhere. For example, Kafka, HDFS, H3, Kinesis etc. This generally involves hooking in a Receiver. Users can also do any transformations on the data before emitting it to Bullet in their own implementations by using the provided Spark Streaming Context. This will be the same context used to wire in the rest of the Bullet DAG.

4. class QueryReceiver extends Receiver[PubSubMessage] with BulletSparkLogger

   

   QueryReceiver receives queries from the PubSub and feeds it to the rest of the DAG.

5. class ResultPublisher extends BulletSparkLogger

   

   Utility class to publish results.