StreamPy
latest
Agent module
ML package
MakeProcess module
Operators module
RemoteQueue module
Stream module
SystemParameters module
examples_element_wrapper module
examples_timed_window_wrapper module
examples_window_wrapper module
source_stream module
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
weave_streams module
StreamPy
Docs
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
A
adjustable_window_agent() (in module Operators)
adjustable_window_func() (in module Operators)
Agent (class in Agent)
(module)
append() (Stream.Stream method)
(Stream.StreamArray 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)
G
get_contents_after_column_value() (Stream.Stream method)
get_contents_after_time() (Stream.StreamArray method)
get_index_for_column_value() (Stream.Stream method)
get_last_n() (Stream.Stream method)
get_latest() (Stream.Stream method)
get_latest_n() (Stream.Stream method)
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)
is_empty() (Stream.Stream method)
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 Stream)
(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)
(in module Stream)
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)
Read the Docs
v: latest
Versions
latest
distributed
Downloads
pdf
htmlzip
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.