Class for storing arbitrary data for passing between the various Spark stages.
Class to wrap errors generated by Bullet.
Class to wrap the result being emitted from Bullet.
Class to wrap Metadata object with a Signal.
Class to wrap the result from the FilterStreaming phase, including the RunningQuery.
Class to wrap a Bullet Querier instance with data and stores the batch time in addition.
Class to wrap the RunningQuery and Metadata.
Class for storing arbitrary data for passing between the various Spark stages. It also stores the Metadata for the query this data is intended for.
It's the parent class for all data.