spark

Ordering

Visibility

class BulletSparkMetrics extends BulletSparkLogger with Serializable
class BulletSparkStreamingBaseJob extends BulletSparkLogger
class DSLDataProducer extends DataProducer
The DSLDataProducer gets a Bullet record stream by deserializing and converting the output of a DSLReceiver.
class DSLReceiver extends Receiver[AnyRef] with BulletSparkLogger
Create a DSLReceiver from the given configuration.
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.
class QueryReceiver extends Receiver[PubSubMessage] with BulletSparkLogger
QueryReceiver receives queries from the PubSub and feeds it to the rest of the DAG.
class ResultPublisher extends BulletSparkLogger
Utility class to publish results.

Packages