Index

_

__init__() (bspump.abc.connection.Connection method) (bspump.abc.generator.Generator method) (bspump.abc.lookup.DictionaryLookup method) (bspump.abc.lookup.Lookup method) (bspump.abc.processor.ProcessorBase method) (bspump.abc.source.Source method) (bspump.abc.source.TriggerSource method) (bspump.Analyzer method), [1] (bspump.analyzer.Analyzer method) (bspump.analyzer.AnalyzingSource method) (bspump.analyzer.GeoAnalyzer method) (bspump.analyzer.LatchAnalyzer method) (bspump.analyzer.SessionAnalyzer method) (bspump.analyzer.ThresholdAnalyzer method) (bspump.analyzer.TimeDriftAnalyzer method) (bspump.analyzer.TimeWindowAnalyzer method) (bspump.BSPumpApplication method), [1] (bspump.BSPumpService method), [1] (bspump.common.Aggregator method) (bspump.common.BytesToStringParser method) (bspump.common.DictToJsonBytesParser method) (bspump.common.DirectSource method) (bspump.common.FlattenDictProcessor method) (bspump.common.InternalSource method) (bspump.common.IteratorSource method) (bspump.common.ListAggregationStrategy method) (bspump.common.ListEventAggregationStrategy method) (bspump.common.MappingTransformator method) (bspump.common.PPrintContextProcessor method) (bspump.common.PPrintProcessor method) (bspump.common.PPrintSink method) (bspump.common.PrintContextProcessor method) (bspump.common.PrintProcessor method) (bspump.common.PrintSink method) (bspump.common.RouterProcessor method) (bspump.common.RouterSink method) (bspump.common.StringAggregationStrategy method) (bspump.common.StringToBytesParser method) (bspump.common.TeeProcessor method) (bspump.common.TeeSource method) (bspump.common.TimeZoneNormalizer method) (bspump.Connection method), [1] (bspump.DictionaryLookup method), [1] (bspump.elasticsearch.ElasticSearchAggsSource method) (bspump.elasticsearch.ElasticSearchConnection method) (bspump.elasticsearch.ElasticSearchLookup method) (bspump.elasticsearch.ElasticSearchSink method) (bspump.elasticsearch.ElasticSearchSource method) (bspump.file.FileBatchLookupProvider method) (bspump.file.FileBlockSink method) (bspump.file.FileBlockSource method) (bspump.file.FileCSVSink method) (bspump.file.FileCSVSource method) (bspump.file.FileJSONSource method) (bspump.file.FileLineSource method) (bspump.file.FileMultiLineSource method) (bspump.Generator method), [1] (bspump.jupyter.FinalizeEvent method) (bspump.kafka.KafkaConnection method) (bspump.kafka.KafkaKeyFilter method) (bspump.kafka.KafkaSink method) (bspump.kafka.KafkaSource method) (bspump.kafka.KafkaTopicInitializer method) (bspump.Lookup method), [1] (bspump.lookup.BitMapIndex method) (bspump.lookup.Index method) (bspump.lookup.IPGeoLookup method) (bspump.lookup.MatrixLookup method) (bspump.lookup.SliceIndex method) (bspump.lookup.TreeRangeIndex method) (bspump.Matrix method), [1] (bspump.matrix.GeoMatrix method) (bspump.matrix.Matrix method) (bspump.matrix.MatrixSource method) (bspump.matrix.NamedMatrix method) (bspump.matrix.PersistentGeoMatrix method) (bspump.matrix.PersistentMatrix method) (bspump.matrix.PersistentSessionMatrix method) (bspump.matrix.PersistentTimeWindowMatrix method) (bspump.matrix.SessionMatrix method) (bspump.Model method) (bspump.mongodb.MongoDBChangeStreamSource method) (bspump.mongodb.MongoDBConnection method) (bspump.mongodb.MongoDBLookup method) (bspump.mongodb.MongoDBSink method) (bspump.mongodb.MongoDBSource method) (bspump.mqtt.MQTTConnection method) (bspump.mqtt.MQTTService method) (bspump.mqtt.MQTTSink method) (bspump.mqtt.MQTTSource method) (bspump.NamedMatrix method) (bspump.PersistentMatrix method) (bspump.PersistentNamedMatrix method) (bspump.Pipeline method), [1] (bspump.PumpBuilder method), [1] (bspump.Source method), [1] (bspump.trigger.CronTrigger method) (bspump.trigger.OpportunisticTrigger method) (bspump.trigger.PeriodicTrigger method) (bspump.trigger.PubSubTrigger method) (bspump.trigger.RunOnceTrigger method) (bspump.trigger.Trigger method) (bspump.TriggerSource method), [1]

A

add() (bspump.trigger.Trigger method) add_column() (bspump.matrix.PersistentTimeWindowMatrix method) add_connection() (bspump.BSPumpService method), [1] add_connections() (bspump.BSPumpService method), [1] add_lookup() (bspump.BSPumpService method), [1] add_lookup_factory() (bspump.BSPumpService method), [1] add_lookups() (bspump.BSPumpService method), [1] add_matrix() (bspump.BSPumpService method), [1] add_matrixes() (bspump.BSPumpService method), [1] add_pipeline() (bspump.BSPumpService method), [1] add_pipelines() (bspump.BSPumpService method), [1] add_row() (bspump.Matrix method), [1] (bspump.matrix.Matrix method) (bspump.matrix.NamedMatrix method) (bspump.matrix.PersistentTimeWindowMatrix method) (bspump.NamedMatrix method) (bspump.PersistentNamedMatrix method) add_test_probe() (in module bspump.jupyter) advance() (bspump.matrix.PersistentTimeWindowMatrix method) AggregationStrategy (class in bspump.common) Aggregator (class in bspump.common)

alarm() (bspump.analyzer.ThresholdAnalyzer method) analyze() (bspump.Analyzer method), [1] (bspump.analyzer.Analyzer method) (bspump.analyzer.ThresholdAnalyzer method) (bspump.analyzer.TimeDriftAnalyzer method) (bspump.Matrix method), [1] (bspump.matrix.Matrix method) Analyzer (class in bspump), [1] (class in bspump.analyzer) AnalyzingSource (class in bspump.analyzer) Anomaly (class in bspump) (class in bspump.abc.anomaly) App (class in bspump.jupyter) append() (bspump.common.AggregationStrategy method) (bspump.common.ListAggregationStrategy method) (bspump.common.ListEventAggregationStrategy method) (bspump.common.StringAggregationStrategy method) append_processor() (bspump.Pipeline method), [1] async_step() (in module bspump.jupyter) AsyncLookupMixin (class in bspump.abc.lookup) auto_pipeline() (in module bspump.jupyter)

B

bind() (bspump.common.TeeProcessor method) (bspump.common.TeeSource method) BitMapIndex (class in bspump.lookup) bspump module bspump.abc module bspump.abc.anomaly module bspump.abc.connection module bspump.abc.generator module bspump.abc.lookup module bspump.abc.processor module bspump.abc.sink module bspump.abc.source module bspump.analyzer module bspump.common module bspump.elasticsearch module bspump.file module

bspump.http.client module bspump.http.web module bspump.jupyter module bspump.kafka module bspump.lookup module bspump.matrix module bspump.mongodb module bspump.mqtt module bspump.trigger module BSPumpApplication (class in bspump), [1] BSPumpService (class in bspump), [1] build() (bspump.common.MappingTransformator method) (bspump.Pipeline method), [1] (Pipeline method) build_find_one_query() (bspump.elasticsearch.ElasticSearchLookup method) build_query() (bspump.mongodb.MongoDBLookup method) build_shape() (bspump.Matrix method), [1] (bspump.matrix.Matrix method) (bspump.matrix.PersistentTimeWindowMatrix method) BytesToStringParser (class in bspump.common)

C

check_and_initialize() (bspump.kafka.KafkaTopicInitializer method) close() (bspump.abc.anomaly.Anomaly method) (bspump.Anomaly method) close_row() (bspump.Matrix method), [1] (bspump.matrix.Matrix method) (bspump.matrix.NamedMatrix method) (bspump.matrix.PersistentMatrix method) (bspump.matrix.PersistentTimeWindowMatrix method) (bspump.NamedMatrix method) (bspump.PersistentMatrix method) (bspump.PersistentNamedMatrix method) close_rows() (bspump.Matrix method), [1] (bspump.matrix.Matrix method) (bspump.matrix.NamedMatrix method) (bspump.NamedMatrix method) (bspump.PersistentNamedMatrix method) components_initialize() (bspump.mqtt.MQTTService method) ConfigDefaults (bspump.abc.lookup.Lookup attribute) (bspump.Analyzer attribute), [1] (bspump.analyzer.Analyzer attribute) (bspump.analyzer.GeoAnalyzer attribute) (bspump.analyzer.LatchAnalyzer attribute) (bspump.analyzer.ThresholdAnalyzer attribute) (bspump.analyzer.TimeDriftAnalyzer attribute) (bspump.common.Aggregator attribute) (bspump.common.BytesToStringParser attribute) (bspump.common.DictToJsonBytesParser attribute) (bspump.common.FlattenDictProcessor attribute) (bspump.common.InternalSource attribute) (bspump.common.StringToBytesParser attribute) (bspump.common.TeeProcessor attribute) (bspump.common.TimeZoneNormalizer attribute) (bspump.elasticsearch.ElasticSearchAggsSource attribute) (bspump.elasticsearch.ElasticSearchConnection attribute) (bspump.elasticsearch.ElasticSearchLookup attribute) (bspump.elasticsearch.ElasticSearchSink attribute) (bspump.elasticsearch.ElasticSearchSource attribute) (bspump.file.FileBlockSink attribute) (bspump.file.FileCSVSink attribute) (bspump.file.FileCSVSource attribute) (bspump.kafka.KafkaConnection attribute) (bspump.kafka.KafkaSink attribute) (bspump.kafka.KafkaSource attribute) (bspump.kafka.KafkaTopicInitializer attribute) (bspump.Lookup attribute), [1] (bspump.lookup.IPGeoLookup attribute) (bspump.lookup.MatrixLookup attribute) (bspump.Matrix attribute), [1] (bspump.matrix.GeoMatrix attribute) (bspump.matrix.Matrix attribute) (bspump.matrix.PersistentGeoMatrix attribute) (bspump.matrix.PersistentMatrix attribute) (bspump.matrix.PersistentSessionMatrix attribute) (bspump.matrix.SessionMatrix attribute) (bspump.Model attribute) (bspump.mongodb.MongoDBChangeStreamSource attribute) (bspump.mongodb.MongoDBConnection attribute) (bspump.mongodb.MongoDBLookup attribute) (bspump.mongodb.MongoDBSink attribute) (bspump.mongodb.MongoDBSource attribute) (bspump.mqtt.MQTTConnection attribute) (bspump.mqtt.MQTTSink attribute) (bspump.mqtt.MQTTSource attribute) (bspump.PersistentMatrix attribute) (bspump.Pipeline attribute), [1]

Connection (class in bspump), [1] (class in bspump.abc.connection) construct() (bspump.abc.connection.Connection class method) (bspump.abc.processor.ProcessorBase class method) (bspump.abc.source.Source class method) (bspump.Connection class method), [1] (bspump.elasticsearch.ElasticSearchLookup class method) (bspump.mongodb.MongoDBLookup class method) (bspump.Source class method), [1] (bspump.trigger.CronTrigger class method) (bspump.trigger.OpportunisticTrigger class method) (bspump.trigger.PeriodicTrigger class method) (bspump.trigger.PubSubTrigger class method) construct_connection() (bspump.PumpBuilder method), [1] construct_connections() (bspump.PumpBuilder method), [1] construct_lookup() (bspump.PumpBuilder method), [1] construct_lookups() (bspump.PumpBuilder method), [1] construct_pipeline() (bspump.PumpBuilder method), [1] construct_pipelines() (bspump.PumpBuilder method), [1] construct_processor() (bspump.PumpBuilder method), [1] construct_processors() (bspump.PumpBuilder method), [1] construct_pump() (bspump.PumpBuilder method), [1] construct_source() (bspump.PumpBuilder method), [1] construct_sources() (bspump.PumpBuilder method), [1] construct_trigger() (bspump.PumpBuilder method), [1] consume() (bspump.elasticsearch.ElasticSearchConnection method) create_argument_parser() (bspump.BSPumpApplication method), [1] create_eps_counter() (bspump.Pipeline method), [1] create_index() (bspump.lookup.MatrixLookup method) create_path() (bspump.matrix.PersistentMatrix method) (bspump.PersistentMatrix method) CronTrigger (class in bspump.trigger) cycle() (bspump.abc.source.TriggerSource method) (bspump.analyzer.AnalyzingSource method) (bspump.common.IteratorSource method) (bspump.elasticsearch.ElasticSearchAggsSource method) (bspump.elasticsearch.ElasticSearchSource method) (bspump.matrix.MatrixSource method) (bspump.mongodb.MongoDBSource method) (bspump.TriggerSource method), [1]

D

decode_row() (bspump.matrix.PersistentSessionMatrix method) (bspump.matrix.SessionMatrix method) degrees_to_radians() (bspump.matrix.GeoMatrix method) (bspump.matrix.PersistentGeoMatrix method) del_pipeline() (bspump.BSPumpService method), [1] deploy() (in module bspump.jupyter) deserialize() (bspump.abc.lookup.DictionaryLookup method) (bspump.abc.lookup.Lookup method) (bspump.DictionaryLookup method), [1] (bspump.Lookup method), [1] (bspump.lookup.BitMapIndex method) (bspump.lookup.MatrixLookup method) (bspump.lookup.SliceIndex method) (bspump.lookup.TreeRangeIndex method) (bspump.matrix.NamedMatrix method) (bspump.NamedMatrix method)

DictionaryLookup (class in bspump), [1] (class in bspump.abc.lookup) DictToJsonBytesParser (class in bspump.common) DirectSource (class in bspump.common) done() (bspump.trigger.OpportunisticTrigger method) (bspump.trigger.RunOnceTrigger method) (bspump.trigger.Trigger method)

E

ElasticSearchAggsSource (class in bspump.elasticsearch) ElasticSearchConnection (class in bspump.elasticsearch) ElasticSearchLookup (class in bspump.elasticsearch) ElasticSearchSink (class in bspump.elasticsearch) ElasticSearchSource (class in bspump.elasticsearch) end_pipeline() (in module bspump.jupyter) enqueue() (bspump.elasticsearch.ElasticSearchConnection method)

ensure_future() (bspump.Pipeline method), [1] ensure_future_update() (bspump.abc.lookup.Lookup method) (bspump.Lookup method), [1] evaluate() (bspump.Analyzer method), [1] (bspump.analyzer.Analyzer method) (bspump.analyzer.ThresholdAnalyzer method) (bspump.analyzer.TimeDriftAnalyzer method)

F

fetch_existing_topics() (bspump.kafka.KafkaTopicInitializer method) FileBatchLookupProvider (class in bspump.file) FileBlockSink (class in bspump.file) FileBlockSource (class in bspump.file) FileCSVSink (class in bspump.file) FileCSVSource (class in bspump.file) FileJSONSource (class in bspump.file) FileLineSource (class in bspump.file) FileMultiLineSource (class in bspump.file) finalize() (bspump.BSPumpService method), [1] FinalizeEvent fire() (bspump.trigger.Trigger method) flatten() (bspump.common.FlattenDictProcessor method) FlattenDictProcessor (class in bspump.common)

flush() (bspump.common.AggregationStrategy method) (bspump.common.Aggregator method) (bspump.common.ListAggregationStrategy method) (bspump.common.ListEventAggregationStrategy method) (bspump.common.StringAggregationStrategy method) (bspump.elasticsearch.ElasticSearchConnection method) (bspump.Matrix method), [1] (bspump.matrix.Matrix method) (bspump.matrix.NamedMatrix method) (bspump.matrix.PersistentMatrix method) (bspump.matrix.PersistentTimeWindowMatrix method) (bspump.NamedMatrix method) (bspump.PersistentMatrix method) (bspump.PersistentNamedMatrix method)

G

generate() (bspump.abc.generator.Generator method) (bspump.common.Aggregator method) (bspump.common.IteratorGenerator method) (bspump.common.MappingItemsGenerator method) (bspump.common.MappingKeysGenerator method) (bspump.common.MappingValuesGenerator method) (bspump.Generator method), [1] Generator (class in bspump), [1] (class in bspump.abc.generator) GeoAnalyzer (class in bspump.analyzer) GeoMatrix (class in bspump.matrix) get() (bspump.abc.lookup.AsyncLookupMixin method) (bspump.elasticsearch.ElasticSearchLookup method) (bspump.mongodb.MongoDBLookup method) (Config method) get_column() (bspump.matrix.PersistentTimeWindowMatrix method) get_diff() (bspump.analyzer.TimeDriftAnalyzer method)

get_file_name() (bspump.file.FileBlockSink method) (bspump.file.FileCSVSink method) get_gps_distance() (bspump.matrix.GeoMatrix method) (bspump.matrix.PersistentGeoMatrix method) get_new_time() (bspump.trigger.CronTrigger method) get_row_index() (bspump.matrix.NamedMatrix method) (bspump.NamedMatrix method) (bspump.PersistentNamedMatrix method) get_row_name() (bspump.matrix.NamedMatrix method) (bspump.NamedMatrix method) (bspump.PersistentNamedMatrix method) get_session() (bspump.elasticsearch.ElasticSearchConnection method) get_throttles() (bspump.Pipeline method), [1] get_url() (bspump.elasticsearch.ElasticSearchConnection method) getboolean() (Config method) getfloat() (Config method) getint() (Config method)

H

handle_error() (bspump.abc.sink.Sink method) (bspump.Pipeline method), [1] (bspump.Sink method), [1]

HexlifyProcessor (class in bspump.common)

I

include_topics() (bspump.kafka.KafkaTopicInitializer method) include_topics_from_config() (bspump.kafka.KafkaTopicInitializer method) include_topics_from_file() (bspump.kafka.KafkaTopicInitializer method) Index (class in bspump.lookup) init_bitswan_jupyter() (in module bspump.jupyter) init_componets() (bspump.jupyter.App method) initialize() (bspump.BSPumpService method), [1] initialize_topics() (bspump.kafka.KafkaTopicInitializer method) inject() (bspump.Pipeline method), [1] insert_after() (bspump.Pipeline method), [1] insert_before() (bspump.Pipeline method), [1] InternalSource (class in bspump.common) inverse_equirectangular() (bspump.matrix.GeoMatrix method) (bspump.matrix.PersistentGeoMatrix method) IPGeoLookup (class in bspump.lookup)

is_closed() (bspump.abc.anomaly.Anomaly method) (bspump.Anomaly method) is_empty() (bspump.common.AggregationStrategy method) (bspump.common.ListAggregationStrategy method) (bspump.common.ListEventAggregationStrategy method) (bspump.common.StringAggregationStrategy method) is_error() (bspump.Pipeline method), [1] is_in_boundaries() (bspump.matrix.GeoMatrix method) (bspump.matrix.PersistentGeoMatrix method) is_master() (bspump.abc.lookup.Lookup method) (bspump.Lookup method), [1] is_ready() (bspump.Pipeline method), [1] iter_processors() (bspump.Pipeline method), [1] IteratorGenerator (class in bspump.common) IteratorSource (class in bspump.common)

K

KafkaConnection (class in bspump.kafka) KafkaKeyFilter (class in bspump.kafka)

KafkaSink (class in bspump.kafka) KafkaSource (class in bspump.kafka) KafkaTopicInitializer (class in bspump.kafka)

L

LatchAnalyzer (class in bspump.analyzer) link() (bspump.Pipeline method), [1] ListAggregationStrategy (class in bspump.common) ListEventAggregationStrategy (class in bspump.common) load() (bspump.abc.lookup.Lookup method) (bspump.elasticsearch.ElasticSearchLookup method) (bspump.file.FileBatchLookupProvider method) (bspump.Lookup method), [1] (bspump.lookup.IPGeoLookup method) (bspump.mongodb.MongoDBLookup method) load_json_file() (in module bspump) load_model_from_file() (bspump.Model method) load_on_thread() (bspump.file.FileBatchLookupProvider method) load_parameters_from_file() (bspump.Model method)

locate() (bspump.BSPumpService method), [1] locate_address() (bspump.abc.processor.ProcessorBase method) (bspump.abc.source.Source method) (bspump.Source method), [1] locate_connection() (bspump.BSPumpService method), [1] (bspump.Pipeline method), [1] locate_lookup() (bspump.BSPumpService method), [1] locate_matrix() (bspump.BSPumpService method), [1] locate_processor() (bspump.Pipeline method), [1] locate_source() (bspump.Pipeline method), [1] Lookup (class in bspump), [1] (class in bspump.abc.lookup) lookup_location() (bspump.lookup.IPGeoLookup method) lookup_location_ipv4() (bspump.lookup.IPGeoLookup method) lookup_location_ipv6() (bspump.lookup.IPGeoLookup method)

M

main() (bspump.abc.source.Source method) (bspump.abc.source.TriggerSource method) (bspump.BSPumpApplication method), [1] (bspump.common.DirectSource method) (bspump.common.InternalSource method) (bspump.common.TeeSource method) (bspump.kafka.KafkaSource method) (bspump.mongodb.MongoDBChangeStreamSource method) (bspump.mqtt.MQTTSource method) (bspump.Source method), [1] (bspump.TriggerSource method), [1] MappingItemsGenerator (class in bspump.common) MappingItemsProcessor (class in bspump.common) MappingKeysGenerator (class in bspump.common) MappingKeysProcessor (class in bspump.common) MappingLookup (class in bspump), [1] (class in bspump.abc.lookup) MappingTransformator (class in bspump.common) MappingValuesGenerator (class in bspump.common) MappingValuesProcessor (class in bspump.common) Matrix (class in bspump), [1] (class in bspump.matrix) MatrixLookup (class in bspump.lookup) MatrixSource (class in bspump.matrix) Model (class in bspump) module bspump bspump.abc bspump.abc.anomaly bspump.abc.connection bspump.abc.generator bspump.abc.lookup bspump.abc.processor bspump.abc.sink bspump.abc.source bspump.analyzer bspump.common bspump.elasticsearch bspump.file bspump.http.client bspump.http.web bspump.jupyter bspump.kafka bspump.lookup bspump.matrix bspump.mongodb bspump.mqtt bspump.trigger

MongoDBChangeStreamSource (class in bspump.mongodb) MongoDBConnection (class in bspump.mongodb) MongoDBLookup (class in bspump.mongodb) MongoDBSink (class in bspump.mongodb) MongoDBSource (class in bspump.mongodb) MQTTConnection (class in bspump.mqtt) MQTTService (class in bspump.mqtt) MQTTSink (class in bspump.mqtt) MQTTSource (class in bspump.mqtt)

N

NamedMatrix (class in bspump) (class in bspump.matrix)

new_pipeline() (in module bspump.jupyter) normalize() (bspump.common.TimeZoneNormalizer method) NullSink (class in bspump.common)

O

OFlagDict (bspump.file.FileBlockSink attribute) on() (bspump.abc.source.TriggerSource method) (bspump.TriggerSource method), [1] on_clock_tick() (bspump.Analyzer method), [1] (bspump.analyzer.Analyzer method) (bspump.matrix.PersistentTimeWindowMatrix method) on_connect() (bspump.mqtt.MQTTConnection method) on_message() (bspump.mqtt.MQTTService method) (bspump.mqtt.MQTTSource method) (bspump.trigger.PubSubTrigger method)

on_tick() (bspump.abc.anomaly.Anomaly method) (bspump.Anomaly method) (bspump.trigger.OpportunisticTrigger method) on_timer() (bspump.trigger.CronTrigger method) (bspump.trigger.PeriodicTrigger method) OpportunisticTrigger (class in bspump.trigger)

P

parse_arguments() (bspump.BSPumpApplication method), [1] pause() (bspump.trigger.CronTrigger method) (bspump.trigger.OpportunisticTrigger method) (bspump.trigger.Trigger method) PeriodicTrigger (class in bspump.trigger) PersistentGeoMatrix (class in bspump.matrix) PersistentMatrix (class in bspump) (class in bspump.matrix) PersistentNamedMatrix (class in bspump) PersistentSessionMatrix (class in bspump.matrix) PersistentTimeWindowMatrix (class in bspump.matrix) Pipeline (class in bspump), [1] PPrintContextProcessor (class in bspump.common) PPrintProcessor (class in bspump.common) PPrintSink (class in bspump.common) predicate() (bspump.Analyzer method), [1] (bspump.analyzer.Analyzer method) (bspump.analyzer.ThresholdAnalyzer method) (bspump.analyzer.TimeDriftAnalyzer method) predict() (bspump.Model method) PrintContextProcessor (class in bspump.common) PrintProcessor (class in bspump.common) PrintSink (class in bspump.common) process() (bspump.abc.generator.Generator method) (bspump.abc.processor.ProcessorBase method) (bspump.abc.source.Source method) (bspump.Analyzer method), [1] (bspump.analyzer.Analyzer method) (bspump.analyzer.LatchAnalyzer method) (bspump.common.Aggregator method) (bspump.common.BytesToStringParser method) (bspump.common.DictToJsonBytesParser method) (bspump.common.FlattenDictProcessor method) (bspump.common.HexlifyProcessor method) (bspump.common.MappingItemsProcessor method) (bspump.common.MappingKeysProcessor method) (bspump.common.MappingTransformator method) (bspump.common.MappingValuesProcessor method) (bspump.common.NullSink method) (bspump.common.PPrintContextProcessor method) (bspump.common.PPrintProcessor method) (bspump.common.PPrintSink method) (bspump.common.PrintContextProcessor method) (bspump.common.PrintProcessor method) (bspump.common.PrintSink method) (bspump.common.StdDictToJsonParser method) (bspump.common.StdJsonToDictParser method) (bspump.common.StringToBytesParser method) (bspump.common.TeeProcessor method) (bspump.common.TimeZoneNormalizer method) (bspump.elasticsearch.ElasticSearchSink method) (bspump.file.FileBlockSink method) (bspump.file.FileCSVSink method) (bspump.Generator method), [1] (bspump.kafka.KafkaKeyFilter method) (bspump.kafka.KafkaSink method) (bspump.matrix.SessionMatrixExportCSVGenerator method) (bspump.matrix.TimeWindowMatrixExportCSVGenerator method) (bspump.mongodb.MongoDBSink method) (bspump.mqtt.MQTTSink method) (bspump.Pipeline method), [1] (bspump.Source method), [1] (Pipeline method)

process_aggs() (bspump.elasticsearch.ElasticSearchAggsSource method) process_buckets() (bspump.elasticsearch.ElasticSearchAggsSource method) ProcessingError (class in bspump) Processor (class in bspump), [1] (class in bspump.abc.processor) ProcessorBase (class in bspump.abc.processor) project_equirectangular() (bspump.matrix.GeoMatrix method) (bspump.matrix.PersistentGeoMatrix method) Provider (bspump.abc.lookup.Lookup attribute) (bspump.Lookup attribute) publish_event() (bspump.mqtt.MQTTService method) publish_to_topic() (bspump.mqtt.MQTTConnection method) PubSubTrigger (class in bspump.trigger) PumpBuilder (class in bspump), [1] put() (bspump.common.DirectSource method) (bspump.common.InternalSource method) put_async() (bspump.common.InternalSource method)

R

read() (bspump.file.FileBlockSource method) (bspump.file.FileCSVSource method) (bspump.file.FileJSONSource method) (bspump.file.FileLineSource method) (bspump.file.FileMultiLineSource method) reader() (bspump.file.FileCSVSource method) ready() (bspump.Pipeline method), [1] (Pipeline method) register_app_post_init() (in module bspump.jupyter) register_connection() (in module bspump.jupyter) register_generator() (in module bspump.jupyter) register_handler() (bspump.mqtt.MQTTConnection method) register_lookup() (in module bspump.jupyter) register_processor() (in module bspump.jupyter) register_sink() (in module bspump.jupyter) register_source() (in module bspump.jupyter) remove() (bspump.trigger.Trigger method) remove_processor() (bspump.Pipeline method), [1] reshape() (bspump.Matrix method), [1] (bspump.matrix.Matrix method) (bspump.matrix.PersistentGeoMatrix method) (bspump.matrix.PersistentTimeWindowMatrix method)

rest_get() (bspump.abc.lookup.DictionaryLookup method) (bspump.abc.lookup.Lookup method) (bspump.abc.processor.ProcessorBase method) (bspump.abc.source.Source method) (bspump.abc.source.TriggerSource method) (bspump.common.InternalSource method) (bspump.DictionaryLookup method), [1] (bspump.Lookup method), [1] (bspump.lookup.IPGeoLookup method) (bspump.lookup.MatrixLookup method) (bspump.Pipeline method), [1] (bspump.Source method), [1] (bspump.TriggerSource method), [1] restart() (bspump.abc.source.Source method) (bspump.Source method), [1] retrieve_sample_events() (in module bspump.jupyter) rotate() (bspump.file.FileCSVSink method) RouterProcessor (class in bspump.common) RouterSink (class in bspump.common) RunOnceTrigger (class in bspump.trigger)

S

sample_events() (in module bspump.jupyter) save() (bspump.file.FileBatchLookupProvider method) search() (bspump.lookup.BitMapIndex method) (bspump.lookup.Index method) (bspump.lookup.IPGeoLookup method) (bspump.lookup.MatrixLookup method) (bspump.lookup.SliceIndex method) (bspump.lookup.TreeRangeIndex method) serialize() (bspump.abc.lookup.DictionaryLookup method) (bspump.abc.lookup.Lookup method) (bspump.DictionaryLookup method), [1] (bspump.Lookup method), [1] (bspump.lookup.BitMapIndex method) (bspump.lookup.Index method) (bspump.lookup.MatrixLookup method) (bspump.lookup.SliceIndex method) (bspump.lookup.TreeRangeIndex method) (bspump.matrix.NamedMatrix method) (bspump.NamedMatrix method) SessionAnalyzer (class in bspump.analyzer) SessionMatrix (class in bspump.matrix) SessionMatrixExportCSVGenerator (class in bspump.matrix) set() (bspump.abc.lookup.DictionaryLookup method) (bspump.DictionaryLookup method), [1] (bspump.lookup.IPGeoLookup method) set_depth() (bspump.abc.generator.Generator method) (bspump.Generator method), [1] set_error() (bspump.Pipeline method), [1]

set_source() (bspump.Pipeline method), [1] Sink (class in bspump), [1] (class in bspump.abc.sink) SkipEvent SliceIndex (class in bspump.lookup) sorted_array_to_bst() (bspump.lookup.IPGeoLookup method) (bspump.lookup.TreeRangeIndex method) Source (class in bspump), [1] (class in bspump.abc.source) start() (bspump.abc.source.Source method) (bspump.Pipeline method), [1] (bspump.Source method), [1] start_timer() (bspump.Analyzer method), [1] (bspump.analyzer.Analyzer method) StdDictToJsonParser (class in bspump.common) StdJsonToDictParser (class in bspump.common) step() (in module bspump.jupyter) stop() (bspump.abc.source.Source method) (bspump.Pipeline method), [1] (bspump.Source method), [1] stopped() (bspump.abc.source.Source method) (bspump.Source method), [1] store() (bspump.matrix.PersistentSessionMatrix method) (bspump.matrix.SessionMatrix method) store_event() (bspump.matrix.PersistentSessionMatrix method) (bspump.matrix.SessionMatrix method) StringAggregationStrategy (class in bspump.common) StringToBytesParser (class in bspump.common) subscribe_topic() (bspump.mqtt.MQTTConnection method)

T

TeeProcessor (class in bspump.common) TeeSource (class in bspump.common) ThresholdAnalyzer (class in bspump.analyzer) throttle() (bspump.Pipeline method), [1] time() (bspump.abc.connection.Connection method) (bspump.abc.lookup.Lookup method) (bspump.abc.processor.ProcessorBase method) (bspump.abc.source.TriggerSource method) (bspump.Connection method), [1] (bspump.Lookup method), [1] (bspump.Matrix method), [1] (bspump.matrix.Matrix method) (bspump.Pipeline method), [1] (bspump.TriggerSource method), [1]

TimeDriftAnalyzer (class in bspump.analyzer) TimeWindowAnalyzer (class in bspump.analyzer) TimeWindowMatrixExportCSVGenerator (class in bspump.matrix) TimeZoneNormalizer (class in bspump.common) transform() (bspump.Model method) TreeRangeIndex (class in bspump.lookup) Trigger (class in bspump.trigger) TriggerSource (class in bspump), [1] (class in bspump.abc.source) TYPE (bspump.abc.anomaly.Anomaly attribute) (bspump.Anomaly attribute)

U

unbind() (bspump.common.TeeProcessor method) unlink() (bspump.Pipeline method), [1] update() (bspump.lookup.BitMapIndex method) (bspump.lookup.Index method) (bspump.lookup.SliceIndex method) (bspump.lookup.TreeRangeIndex method) (bspump.Model method)

update_indexes() (bspump.lookup.MatrixLookup method)

W

writer() (bspump.file.FileCSVSink method)

Z

zeros() (bspump.Matrix method), [1] (bspump.matrix.GeoMatrix method) (bspump.matrix.Matrix method) (bspump.matrix.NamedMatrix method) (bspump.matrix.PersistentGeoMatrix method) (bspump.matrix.PersistentMatrix method) (bspump.matrix.PersistentTimeWindowMatrix method) (bspump.NamedMatrix method) (bspump.PersistentMatrix method) (bspump.PersistentNamedMatrix method)