Index

A

adjustable_window_agent() (in module Operators) adjustable_window_func() (in module Operators) Agent (class in Agent) (module) append() (Stream.Stream method) assert_is_list() (in module Operators) assert_is_list_of_lists() (in module Operators) assert_is_list_of_streams() (in module Operators) assert_is_list_of_streams_or_None() (in module Operators) assert_is_list_or_None() (in module Operators)

asynch_element_agent() (in module Operators) asynch_element_func() (in module Operators) average() (in module examples_element_wrapper) average_stream() (in module examples_element_wrapper) avg_of_difference_of_two_windows() (in module examples_window_wrapper) avg_of_max_and_min_in_timed_list() (in module examples_timed_window_wrapper) avg_of_max_and_min_values_in_all_timed_lists() (in module examples_timed_window_wrapper) awf() (in module Operators)

B

boolean_of_values_greater_than_threshold() (in module examples_element_wrapper)

C

call() (Stream.Stream method) close() (Stream.Stream method) combine_windows() (in module examples_window_wrapper)

computeCentroids() (in module ML.KMeans.kmeans) cumulative_stream() (in module examples_element_wrapper) cumulative_sum() (in module examples_element_wrapper)

D

delete_caller() (Stream.Stream method) delete_reader() (Stream.Stream method) dif() (in module tutorial_merge) diff_of_counts_in_lists() (in module examples_timed_window_wrapper) diff_of_means_of_two_windows() (in module examples_window_wrapper) discard_odds() (in module examples_element_wrapper)

discard_odds_1() (in module examples_element_wrapper) double() (in module examples_element_wrapper) double_stream() (in module examples_element_wrapper) dynamic_window_agent() (in module Operators) dynamic_window_func() (in module Operators)

E

ef() (in module Operators) element_agent() (in module Operators) element_func() (in module Operators) EPSILON (in module Agent) evaluate_error() (in module ML.KMeans.kmeans) (in module ML.LinearRegression.linear_regression) even() (in module examples_element_wrapper) even2() (in module examples_element_wrapper) even3() (in module examples_element_wrapper) even_1() (in module examples_element_wrapper) even_odd() (in module examples_element_wrapper) even_odd_stream() (in module examples_element_wrapper)

evens_and_halves() (in module examples_element_wrapper) evens_and_halves_3() (in module examples_element_wrapper) examples_element_wrapper (module) examples_timed_window_wrapper (module) examples_window_wrapper (module) execute() (in module tutorial_split) exp_mult_div_stream() (in module examples_element_wrapper) exp_smoothing_mean_and_std_of_stream() (in module examples_window_wrapper) exponential_smoothed_timed_windows() (in module examples_timed_window_wrapper) extend() (Stream.Stream method) (Stream.StreamArray method) extent() (in module examples_window_wrapper)

F

file_to_stream() (in module examples_element_wrapper) findClosestCentroids() (in module ML.KMeans.kmeans)

ft() (in module tutorial_filter_1)

H

h() (in module Operators)

h_agent() (in module Operators)

I

init_plot() (in module ML.KMeans.kmeans) (in module ML.LinearRegression.linear_regression) initialize() (in module ML.KMeans.kmeans) initializeCentroids() (in module ML.KMeans.kmeans) initializeData() (in module ML.KMeans.kmeans)

initializeDataCenter() (in module ML.KMeans.kmeans) InList (class in Agent) inrange_and_outlier_streams() (in module examples_element_wrapper) (in module examples_window_wrapper)

J

join_streams() (in module examples_element_wrapper)

K

kmeans() (in module ML.KMeans.kmeans)

KMeansStream (class in ML.KMeans.KMeansStream)

L

lf() (in module Operators) LinearRegressionStream (class in ML.LinearRegression.LinearRegressionStream) list (Agent.InList attribute)

list_agent() (in module Operators) list_func() (in module Operators) list_index_for_timestamp() (in module Operators)

M

main() (in module examples_element_wrapper) (in module Operators) (in module source_stream) many_outputs_source() (in module Operators) many_to_many() (in module Operators) many_to_many_agent() (in module Operators) max_and_min() (in module examples_window_wrapper) max_and_min_of_values_in_timed_list() (in module examples_timed_window_wrapper) max_and_min_seen_across_all_streams() (in module examples_element_wrapper) max_and_min_stream() (in module examples_element_wrapper) max_and_min_values_in_all_timed_lists() (in module examples_timed_window_wrapper) max_and_min_with_names() (in module examples_element_wrapper) max_of_all_inputs() (in module examples_element_wrapper) max_seen_across_all_streams() (in module examples_element_wrapper) max_stream() (in module examples_element_wrapper) max_sums_timed_windows() (in module examples_timed_window_wrapper) max_with_index() (in module examples_element_wrapper)

mean_inc() (in module examples_window_wrapper) mean_of_window() (in module examples_window_wrapper) mean_stream() (in module examples_element_wrapper) merge() (in module Operators) merge_agent() (in module Operators) ML (module) ML.KMeans (module) ML.KMeans.kmeans (module) ML.KMeans.KMeansStream (module) ML.LinearRegression (module) ML.LinearRegression.linear_regression (module) ML.LinearRegression.LinearRegressionStream (module) ML.Stream_Learn (module) multiply_elements_in_stream() (in module examples_element_wrapper)

N

next() (Agent.Agent method)

O

op() (in module Operators) op_agent() (in module Operators)

Operators (module)

P

plot() (in module ML.LinearRegression.linear_regression) plotKMeans() (in module ML.KMeans.kmeans) predict() (in module ML.LinearRegression.linear_regression) print0() (in module examples_element_wrapper)

print_recent() (Stream.Stream method) print_stream() (in module examples_element_wrapper) print_streams() (in module examples_element_wrapper) print_sums() (in module examples_element_wrapper)

R

rand() (in module examples_element_wrapper) reader() (Stream.Stream method) remove_novalue_and_open_multivalue() (in module Operators)

reset() (ML.KMeans.KMeansStream.KMeansStream method) (ML.LinearRegression.LinearRegressionStream.LinearRegressionStream method) (ML.Stream_Learn.Stream_Learn method) run() (ML.Stream_Learn.Stream_Learn method)

S

set_name() (Stream.Stream method) set_start() (Stream.Stream method) single_output_source() (in module Operators) single_output_source_agent() (in module Operators) single_stream_of_random_numbers() (in module examples_element_wrapper) sink() (in module Operators) sink_merge() (in module Operators) source_stream (module) source_stream() (in module source_stream) split() (in module Operators) split_agent() (in module Operators) square() (in module examples_element_wrapper) square_and_double() (in module examples_element_wrapper) square_and_double_stream() (in module examples_element_wrapper)

square_stream() (in module examples_element_wrapper) start (Agent.InList attribute) stop (Agent.InList attribute) Stream (class in Stream) (module) stream_agent() (in module Operators) stream_func() (in module Operators) Stream_Learn (class in ML.Stream_Learn) stream_to_file() (in module examples_element_wrapper) StreamArray (class in Stream) StreamSeries (class in Stream) StreamTimed (class in Stream) sum_values_in_all_timed_lists() (in module examples_timed_window_wrapper) sum_values_in_timed_list() (in module examples_timed_window_wrapper) SystemParameters (module)

T

temperature_and_humidity_streams() (in module examples_element_wrapper) tf() (in module Operators) time (Stream.TimeAndValue attribute) TimeAndValue (class in Stream) timed_agent() (in module Operators) timed_func() (in module Operators) timer() (in module examples_element_wrapper) train() (in module ML.LinearRegression.linear_regression) train_sgd() (in module ML.LinearRegression.linear_regression)

tutorial_average_of_stream (module) tutorial_element_wrapper_stream_operator (module) tutorial_exponential_smoothing (module) tutorial_filter_1 (module) tutorial_many_to_many (module) tutorial_merge (module) tutorial_sine (module) tutorial_split (module)

U

update_avg() (in module tutorial_average_of_stream)

update_smooth() (in module tutorial_exponential_smoothing)

V

value (Stream.TimeAndValue attribute)

W

weave_streams (module) wf() (in module Operators)

window_agent() (in module Operators) window_func() (in module Operators)