ess.nmx.streaming

Functions

calculate_number_of_chunks(file_path, *, ...)

Calculate number of chunks in the event data.

Classes

MaxAccumulator(**kwargs)	Accumulator that keeps track of the maximum value seen so far.
MinAccumulator(**kwargs)	Accumulator that keeps track of the maximum value seen so far.