CerebralCortex Kernel
stable
Contents:
CerebralCortex Core
CerebralCortex Data importer
CerebralCortex Algorithms
CerebralCortex Test Suite
CerebralCortex Kernel
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
|
W
A
add_annotation() (Metadata method)
,
[1]
add_dataDescriptor() (Metadata method)
,
[1]
add_ingestion_log() (DataIngestionHandler method)
add_input_stream() (Metadata method)
,
[1]
add_module() (Metadata method)
,
[1]
add_scanned_files() (DataIngestionHandler method)
assign_column_names_types() (in module cerebralcortex.data_importer.data_parsers.util)
assign_column_names_types_strict() (in module cerebralcortex.data_importer.data_parsers.util)
B
BlueprintStorage (class in cerebralcortex.core.data_manager.raw.storage_blueprint)
C
CacheHandler (class in cerebralcortex.core.data_manager.sql.cache_handler)
CCLogging (class in cerebralcortex.core.log_manager.logging)
cerebralcortex (module)
cerebralcortex.algorithms (module)
cerebralcortex.algorithms.gps (module)
cerebralcortex.algorithms.gps.gps_clustering (module)
cerebralcortex.core (module)
cerebralcortex.core.config_manager (module)
cerebralcortex.core.config_manager.config (module)
cerebralcortex.core.config_manager.config_handler (module)
cerebralcortex.core.data_manager (module)
cerebralcortex.core.data_manager.object (module)
cerebralcortex.core.data_manager.object.data (module)
cerebralcortex.core.data_manager.object.storage_filesystem (module)
cerebralcortex.core.data_manager.object.storage_minio (module)
cerebralcortex.core.data_manager.raw (module)
cerebralcortex.core.data_manager.raw.data (module)
cerebralcortex.core.data_manager.raw.storage_blueprint (module)
cerebralcortex.core.data_manager.raw.storage_filesystem (module)
cerebralcortex.core.data_manager.raw.storage_hdfs (module)
cerebralcortex.core.data_manager.raw.stream_handler (module)
cerebralcortex.core.data_manager.sql (module)
cerebralcortex.core.data_manager.sql.cache_handler (module)
cerebralcortex.core.data_manager.sql.data (module)
cerebralcortex.core.data_manager.sql.data_ingestion_handler (module)
cerebralcortex.core.data_manager.sql.kafka_offsets_handler (module)
cerebralcortex.core.data_manager.sql.stream_handler (module)
cerebralcortex.core.data_manager.sql.users_handler (module)
cerebralcortex.core.data_manager.time_series (module)
cerebralcortex.core.data_manager.time_series.data (module)
cerebralcortex.core.data_manager.time_series.influxdb_handler (module)
cerebralcortex.core.datatypes (module)
cerebralcortex.core.datatypes.datastream (module)
cerebralcortex.core.log_manager (module)
cerebralcortex.core.log_manager.log_handler (module)
cerebralcortex.core.log_manager.logging (module)
cerebralcortex.core.messaging_manager (module)
cerebralcortex.core.messaging_manager.kafka_handler (module)
cerebralcortex.core.messaging_manager.messaging_queue (module)
cerebralcortex.core.metadata_manager (module)
cerebralcortex.core.metadata_manager.stream (module)
cerebralcortex.core.metadata_manager.stream.data_descriptor (module)
cerebralcortex.core.metadata_manager.stream.metadata (module)
cerebralcortex.core.metadata_manager.stream.module_info (module)
cerebralcortex.core.metadata_manager.user (module)
cerebralcortex.core.metadata_manager.user.user (module)
cerebralcortex.core.util (module)
cerebralcortex.core.util.datetime_helper_methods (module)
cerebralcortex.core.util.spark_helper (module)
cerebralcortex.data_importer (module)
cerebralcortex.data_importer.data_parsers (module)
cerebralcortex.data_importer.data_parsers.csv_parser (module)
cerebralcortex.data_importer.data_parsers.mcerebrum (module)
cerebralcortex.data_importer.data_parsers.util (module)
cerebralcortex.data_importer.ingest (module)
cerebralcortex.data_importer.metadata_parsers (module)
cerebralcortex.data_importer.metadata_parsers.mcerebrum (module)
cerebralcortex.data_importer.util (module)
cerebralcortex.data_importer.util.directory_scanners (module)
cerebralcortex.data_importer.util.helper_methods (module)
cerebralcortex.kernel (module)
cerebralcortex.modules (module)
cerebralcortex.modules.mprov (module)
cerebralcortex.modules.mprov.connection (module)
cerebralcortex.test_suite (module)
cerebralcortex.test_suite.test_kafka (module)
cerebralcortex.test_suite.test_main (module)
cerebralcortex.test_suite.test_object_storage (module)
cerebralcortex.test_suite.test_sql_storage (module)
cerebralcortex.test_suite.test_stream (module)
cerebralcortex.test_suite.util (module)
cerebralcortex.test_suite.util.data_helper (module)
close() (SqlData method)
collect() (DataStream method)
,
[1]
COMPLETE (DataSet attribute)
compute() (DataStream method)
,
[1]
compute_average() (DataStream method)
,
[1]
compute_max() (DataStream method)
,
[1]
compute_min() (DataStream method)
,
[1]
compute_sqrt() (DataStream method)
,
[1]
compute_stddev() (DataStream method)
,
[1]
compute_sum() (DataStream method)
,
[1]
compute_variance() (DataStream method)
,
[1]
ConfigHandler (class in cerebralcortex.core.config_manager.config_handler)
Configuration (class in cerebralcortex.core.config_manager.config)
connect() (Kernel method)
,
[1]
convert_json_to_metadata_obj() (in module cerebralcortex.data_importer.metadata_parsers.mcerebrum)
create_bucket() (FileSystemStorage method)
(Kernel method)
,
[1]
(MinioHandler method)
create_direct_kafka_stream() (KafkaHandler method)
create_pool() (SqlData method)
create_user() (Kernel method)
,
[1]
(UserHandler method)
create_windows() (DataStream method)
,
[1]
CRITICAL (LogTypes attribute)
csv_data_parser() (in module cerebralcortex.data_importer.data_parsers)
(in module cerebralcortex.data_importer.data_parsers.csv_parser)
D
data (DataStream attribute)
,
[1]
DataDescriptor (class in cerebralcortex.core.metadata_manager.stream)
(class in cerebralcortex.core.metadata_manager.stream.data_descriptor)
DataIngestionHandler (class in cerebralcortex.core.data_manager.sql.data_ingestion_handler)
DataSet (class in cerebralcortex.core.data_manager.raw.stream_handler)
DataStream (class in cerebralcortex.core.datatypes)
(class in cerebralcortex.core.datatypes.datastream)
DataStreamTest (class in cerebralcortex.test_suite.test_stream)
DEBUG (LogTypes attribute)
delete_user() (Kernel method)
,
[1]
(UserHandler method)
dir_scanner() (in module cerebralcortex.data_importer.util.directory_scanners)
drop_column() (DataStream method)
,
[1]
E
encrypt_user_password() (Kernel method)
,
[1]
(UserHandler method)
ERROR (LogTypes attribute)
EXCEPTION (LogTypes attribute)
execute() (SqlData method)
F
FileSystemStorage (class in cerebralcortex.core.data_manager.object.storage_filesystem)
(class in cerebralcortex.core.data_manager.raw.storage_filesystem)
filter() (DataStream method)
,
[1]
filter_user() (DataStream method)
,
[1]
filter_version() (DataStream method)
,
[1]
from_json() (DataDescriptor method)
,
[1]
(ModuleMetadata method)
,
[1]
from_json_file() (Metadata method)
,
[1]
from_json_sql() (Metadata method)
,
[1]
G
gen_phone_battery_data() (in module cerebralcortex.test_suite.util.data_helper)
gen_phone_battery_data2() (in module cerebralcortex.test_suite.util.data_helper)
gen_phone_battery_metadata() (in module cerebralcortex.test_suite.util.data_helper)
gen_random_pass() (Kernel method)
,
[1]
(UserHandler method)
get_all_users() (Kernel method)
,
[1]
(UserHandler method)
get_bucket_objects() (FileSystemStorage method)
(Kernel method)
,
[1]
(MinioHandler method)
get_buckets() (FileSystemStorage method)
(Kernel method)
,
[1]
(MinioHandler method)
get_cache_value() (CacheHandler method)
(Kernel method)
,
[1]
get_centermost_point() (in module cerebralcortex.algorithms.gps.gps_clustering)
get_files_list() (DataIngestionHandler method)
get_hash() (Metadata method)
,
[1]
get_hash_by_json() (Metadata method)
,
[1]
get_ingestion_stats() (DataIngestionHandler method)
get_kafka_offsets() (KafkaOffsetsHandler method)
(Kernel method)
,
[1]
get_metadata() (DataStream method)
,
[1]
get_object() (FileSystemStorage method)
(Kernel method)
,
[1]
(MinioHandler method)
get_object_stats() (FileSystemStorage method)
(Kernel method)
,
[1]
(MinioHandler method)
get_or_create_sc() (in module cerebralcortex.core.util.spark_helper)
get_platform_metadata() (in module cerebralcortex.data_importer.metadata_parsers.mcerebrum)
get_processed_files_list() (DataIngestionHandler method)
get_stream() (Kernel method)
,
[1]
(StreamHandler method)
get_stream_info_by_hash() (Kernel method)
,
[1]
(StreamHandler method)
get_stream_metadata() (Kernel method)
,
[1]
(StreamHandler method)
get_stream_metadata_hash() (Kernel method)
,
[1]
(StreamHandler method)
get_stream_name() (Kernel method)
,
[1]
(StreamHandler method)
get_stream_versions() (Kernel method)
,
[1]
(StreamHandler method)
get_timezone() (in module cerebralcortex.core.util.datetime_helper_methods)
get_user_id() (Kernel method)
,
[1]
(UserHandler method)
get_user_metadata() (Kernel method)
,
[1]
(UserHandler method)
get_user_name() (Kernel method)
,
[1]
(UserHandler method)
get_user_settings() (Kernel method)
,
[1]
(UserHandler method)
get_window() (in module cerebralcortex.core.datatypes.datastream)
gps_clusters() (in module cerebralcortex.algorithms)
(in module cerebralcortex.algorithms.gps)
(in module cerebralcortex.algorithms.gps.gps_clustering)
groupby() (DataStream method)
,
[1]
H
HDFSStorage (class in cerebralcortex.core.data_manager.raw.storage_hdfs)
I
import_dir() (in module cerebralcortex.data_importer)
(in module cerebralcortex.data_importer.ingest)
import_file() (in module cerebralcortex.data_importer)
(in module cerebralcortex.data_importer.ingest)
InfluxdbHandler (class in cerebralcortex.core.data_manager.time_series.influxdb_handler)
is_auth_token_valid() (Kernel method)
,
[1]
(UserHandler method)
is_bucket() (FileSystemStorage method)
(Kernel method)
,
[1]
(MinioHandler method)
is_file_processed() (DataIngestionHandler method)
is_object() (FileSystemStorage method)
(Kernel method)
,
[1]
(MinioHandler method)
is_stream() (Kernel method)
,
[1]
(StreamHandler method)
is_user() (Kernel method)
,
[1]
(UserHandler method)
is_valid() (Metadata method)
,
[1]
isactive (User attribute)
J
join() (DataStream method)
,
[1]
K
kafka_produce_message() (Kernel method)
,
[1]
kafka_subscribe_to_topic() (Kernel method)
,
[1]
KafkaHandler (class in cerebralcortex.core.messaging_manager.kafka_handler)
KafkaOffsetsHandler (class in cerebralcortex.core.data_manager.sql.kafka_offsets_handler)
Kernel (class in cerebralcortex)
(class in cerebralcortex.kernel)
L
limit() (DataStream method)
,
[1]
list_streams() (Kernel method)
,
[1]
(StreamHandler method)
load_file() (ConfigHandler method)
log() (LogHandler method)
LogHandler (class in cerebralcortex.core.log_manager.log_handler)
login_user() (UserHandler method)
LogTypes (class in cerebralcortex.core.log_manager.log_handler)
M
map_stream() (DataStream method)
,
[1]
mcerebrum_data_parser() (in module cerebralcortex.data_importer.data_parsers)
(in module cerebralcortex.data_importer.data_parsers.mcerebrum)
mcerebrum_metadata_parser() (in module cerebralcortex.data_importer.metadata_parsers)
(in module cerebralcortex.data_importer.metadata_parsers.mcerebrum)
MessagingQueue (class in cerebralcortex.core.messaging_manager.messaging_queue)
Metadata (class in cerebralcortex.core.metadata_manager.stream)
(class in cerebralcortex.core.metadata_manager.stream.metadata)
metadata (DataStream attribute)
,
[1]
MinioHandler (class in cerebralcortex.core.data_manager.object.storage_minio)
MISSING_DATA (LogTypes attribute)
ModuleMetadata (class in cerebralcortex.core.metadata_manager.stream)
(class in cerebralcortex.core.metadata_manager.stream.module_info)
N
new_data_descript_frmt() (in module cerebralcortex.data_importer.metadata_parsers.mcerebrum)
new_module_metadata() (in module cerebralcortex.data_importer.metadata_parsers.mcerebrum)
O
ObjectData (class in cerebralcortex.core.data_manager.object.data)
ONLY_DATA (DataSet attribute)
ONLY_METADATA (DataSet attribute)
P
password (User attribute)
plot() (DataStream method)
,
[1]
plot_gps_cords() (DataStream method)
,
[1]
plot_hist() (DataStream method)
,
[1]
plot_stress_bar() (DataStream method)
,
[1]
plot_stress_comparison() (DataStream method)
,
[1]
plot_stress_gantt() (DataStream method)
,
[1]
plot_stress_pie() (DataStream method)
,
[1]
plot_stress_sankey() (DataStream method)
,
[1]
print_stats_table() (in module cerebralcortex.data_importer.ingest)
process_ecg() (in module cerebralcortex.algorithms)
produce_message() (KafkaHandler method)
R
RawData (class in cerebralcortex.core.data_manager.raw.data)
read_file() (BlueprintStorage method)
(FileSystemStorage method)
(HDFSStorage method)
rename_column_name() (in module cerebralcortex.data_importer.util.helper_methods)
rr_interval_feature_extraction() (in module cerebralcortex.algorithms)
run_algorithm() (DataStream method)
,
[1]
S
save_data() (in module cerebralcortex.data_importer.ingest)
save_data_to_influxdb() (InfluxdbHandler method)
(Kernel method)
,
[1]
save_stream() (Kernel method)
,
[1]
(StreamHandler method)
save_stream_metadata() (StreamHandler method)
schema() (DataStream method)
,
[1]
search_stream() (Kernel method)
,
[1]
(StreamHandler method)
set_attribute() (DataDescriptor method)
,
[1]
(ModuleMetadata method)
,
[1]
set_author() (ModuleMetadata method)
,
[1]
set_cache_value() (CacheHandler method)
(Kernel method)
,
[1]
set_description() (Metadata method)
,
[1]
set_name() (DataDescriptor method)
,
[1]
(Metadata method)
,
[1]
(ModuleMetadata method)
,
[1]
set_type() (DataDescriptor method)
,
[1]
set_version() (ModuleMetadata method)
,
[1]
setUp() (TestCerebralCortex method)
show() (DataStream method)
,
[1]
sort() (DataStream method)
,
[1]
SqlData (class in cerebralcortex.core.data_manager.sql.data)
SqlStorageTest (class in cerebralcortex.test_suite.test_sql_storage)
store_or_update_Kafka_offset() (KafkaOffsetsHandler method)
(Kernel method)
,
[1]
StreamHandler (class in cerebralcortex.core.data_manager.raw.stream_handler)
(class in cerebralcortex.core.data_manager.sql.stream_handler)
stress_episodes_estimation() (in module cerebralcortex.algorithms)
stress_prediction() (in module cerebralcortex.algorithms)
subscribe_to_topic() (KafkaHandler method)
summary() (DataStream method)
,
[1]
T
test_00() (TestCerebralCortex method)
test_01_bucket() (TestObjectStorage method)
test_01_is_stream() (SqlStorageTest method)
test_01_produce_message() (TestKafkaMessaging method)
test_01_save_stream() (DataStreamTest method)
test_02_consume_message() (TestKafkaMessaging method)
test_02_get_stream_versions() (SqlStorageTest method)
test_03_bucket_objects() (TestObjectStorage method)
test_03_get_stream_name() (SqlStorageTest method)
test_04_get_stream_metadata_hash() (SqlStorageTest method)
test_05_get_user_id() (SqlStorageTest method)
test_05_map_window_to_stream() (DataStreamTest method)
test_06_get_user_name() (SqlStorageTest method)
test_07_get_all_users() (SqlStorageTest method)
test_08_get_user_metadata() (SqlStorageTest method)
test_09_encrypt_user_password() (SqlStorageTest method)
test_10_connect() (SqlStorageTest method)
test_9999_last() (TestCerebralCortex method)
TestCerebralCortex (class in cerebralcortex.test_suite.test_main)
TestKafkaMessaging (class in cerebralcortex.test_suite.test_kafka)
TestObjectStorage (class in cerebralcortex.test_suite.test_object_storage)
TimeSeriesData (class in cerebralcortex.core.data_manager.time_series.data)
to_json() (Metadata method)
,
[1]
to_pandas() (DataStream method)
,
[1]
token (User attribute)
token_expiry (User attribute)
token_issued_at (User attribute)
U
update_auth_token() (Kernel method)
,
[1]
(UserHandler method)
update_ingestion_log() (DataIngestionHandler method)
update_ingestion_log_status() (DataIngestionHandler method)
update_ingestion_log_status_ignore() (DataIngestionHandler method)
upload_object() (FileSystemStorage method)
(Kernel method)
,
[1]
(MinioHandler method)
upload_object_to_s3() (MinioHandler method)
User (class in cerebralcortex.core.metadata_manager.user.user)
user_id (User attribute)
user_metadata (User attribute)
user_role (User attribute)
UserHandler (class in cerebralcortex.core.data_manager.sql.users_handler)
username (User attribute)
username_checks() (UserHandler method)
W
WARNING (LogTypes attribute)
where() (DataStream method)
,
[1]
window() (DataStream method)
,
[1]
windowing_udf() (in module cerebralcortex.core.datatypes.datastream)
write_file() (BlueprintStorage method)
(FileSystemStorage method)
(HDFSStorage method)
write_pandas_dataframe() (FileSystemStorage method)
(HDFSStorage method)
write_spark_dataframe() (FileSystemStorage method)
(HDFSStorage method)
Read the Docs
v: stable
Versions
latest
stable
Downloads
pdf
html
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.