cpdbench.examples.Example_Parallelism 

 1from time import sleep
 2
 3from cpdbench.CPDBench import CPDBench
 4import cpdbench.examples.ExampleDatasets as example_datasets
 5import cpdbench.examples.ExampleAlgorithms as example_algorithms
 6import cpdbench.examples.ExampleMetrics as example_metrics
 7
 8cpdb = CPDBench()
 9
10
11@cpdb.dataset
12def get_apple_dataset():
13    sleep(10)
14    return example_datasets.dataset_get_apple_dataset()
15
16
17@cpdb.dataset
18def get_bitcoin_dataset():
19    return example_datasets.dataset_get_bitcoin_dataset()
20
21
22@cpdb.algorithm
23def execute_esst_test(signal):
24    return example_algorithms.algorithm_execute_single_esst(signal)
25
26
27@cpdb.metric
28def calc_accuracy(indexes, scores, ground_truth):
29    return example_metrics.metric_accuracy_in_allowed_windows(indexes, scores, ground_truth, window_size=25)
30
31
32if __name__ == '__main__':
33    cpdb.start()
cpdb = <cpdbench.CPDBench.CPDBench object>
@cpdb.dataset
def get_apple_dataset(): 
12@cpdb.dataset
13def get_apple_dataset():
14    sleep(10)
15    return example_datasets.dataset_get_apple_dataset()
@cpdb.dataset
def get_bitcoin_dataset(): 
18@cpdb.dataset
19def get_bitcoin_dataset():
20    return example_datasets.dataset_get_bitcoin_dataset()
@cpdb.algorithm
def execute_esst_test(signal): 
23@cpdb.algorithm
24def execute_esst_test(signal):
25    return example_algorithms.algorithm_execute_single_esst(signal)
@cpdb.metric
def calc_accuracy(indexes, scores, ground_truth): 
28@cpdb.metric
29def calc_accuracy(indexes, scores, ground_truth):
30    return example_metrics.metric_accuracy_in_allowed_windows(indexes, scores, ground_truth, window_size=25)