EventStream.data package¶
Submodules¶
- EventStream.data.config module
- EventStream.data.config.DatasetConfig
- measurement_configs
- min_valid_column_observations
- min_valid_vocab_element_observations
- min_true_float_frequency
- min_unique_numerical_observations
- outlier_detector_config
- center_and_scale
- save_dir
- agg_by_time_scale
- Raises
- agg_by_time_scale
- center_and_scale
- from_dict
- measurement_configs
- min_events_per_subject
- min_true_float_frequency
- min_unique_numerical_observations
- min_valid_column_observations
- min_valid_vocab_element_observations
- outlier_detector_config
- save_dir
- to_dict
- EventStream.data.config.DatasetSchema
- EventStream.data.config.InputDFSchema
- input_df
- type
- event_type
- subject_id_col
- ts_col
- start_ts_col
- end_ts_col
- ts_format
- start_ts_format
- end_ts_format
- data_schema
- start_data_schema
- end_data_schema
- must_have
- Raises
- columns_to_load
- data_schema
- end_data_schema
- end_ts_col
- end_ts_format
- event_type
- input_df
- is_static
- must_have
- start_data_schema
- start_ts_col
- start_ts_format
- subject_id_col
- ts_col
- ts_format
- type
- unified_end_schema
- unified_eq_schema
- unified_event_schema
- unified_schema
- unified_start_schema
- EventStream.data.config.MeasurementConfig
- name
- modality
- temporality
- observation_rate_over_cases
- observation_rate_per_case
- functor
- vocabulary
- values_column
- measurement_metadata
- modifiers
- Raises
- FUNCTORS
- PREPROCESSING_METADATA_COLUMNS
- add_empty_metadata
- add_missing_mandatory_metadata_cols
- cache_measurement_metadata
- describe
- drop
- from_dict
- functor
- is_dropped
- is_numeric
- measurement_metadata
- modality
- modifiers
- name
- observation_rate_over_cases
- observation_rate_per_case
- temporality
- to_dict
- uncache_measurement_metadata
- values_column
- vocabulary
- EventStream.data.config.PytorchDatasetConfig
- save_dir
- max_seq_len
- min_seq_len
- seq_padding_side
- subsequence_sampling_strategy
- train_subset_size
- train_subset_seed
- tuning_subset_size
- tuning_subset_seed
- task_df_name
- do_include_subject_id
- do_include_subsequence_indices
- do_include_start_time_min
- Raises
- DL_reps_dir
- cache_for_epochs
- cached_task_dir
- do_include_start_time_min
- do_include_subject_id
- do_include_subsequence_indices
- from_dict
- max_seq_len
- measurement_config_fp
- measurement_configs
- min_seq_len
- raw_task_df_fp
- save_dir
- seq_padding_side
- subsequence_sampling_strategy
- task_df_name
- task_info_fp
- tensorized_cached_dir
- tensorized_cached_files
- to_dict
- train_subset_seed
- train_subset_size
- tuning_subset_seed
- tuning_subset_size
- vocabulary_config
- vocabulary_config_fp
- EventStream.data.config.SeqPaddingSide
- EventStream.data.config.SubsequenceSamplingStrategy
- EventStream.data.config.VocabularyConfig
- EventStream.data.config.DatasetConfig
- EventStream.data.data_embedding_layer module
- EventStream.data.dataset_base module
- EventStream.data.dataset_base.INPUT_DF_T
- EventStream.data.dataset_base.DF_T
- EventStream.data.dataset_base.DatasetBase
- Parameters
- DF_SAVE_FORMAT
- DYNAMIC_MEASUREMENTS_FN
- EVENTS_FN
- SUBJECTS_FN
- build_DL_cached_representation
- build_event_and_measurement_dfs
- build_subjects_dfs
- cache_deep_learning_representation
- cache_flat_representation
- describe
- dynamic_measurements_df
- dynamic_measurements_fp
- dynamic_numerical_columns
- events_df
- events_fp
- fit_measurements
- has_static_measurements
- held_out_dynamic_measurements_df
- held_out_events_df
- held_out_subjects_df
- load
- measurement_configs
- measurement_idxmaps
- measurement_vocabs
- preprocess
- save
- split
- subjects_df
- subjects_fp
- time_dependent_numerical_columns
- train_dynamic_measurements_df
- train_events_df
- train_subjects_df
- transform_measurements
- tuning_dynamic_measurements_df
- tuning_events_df
- tuning_subjects_df
- unified_measurements_idxmap
- unified_measurements_vocab
- unified_vocabulary_flat
- unified_vocabulary_idxmap
- unified_vocabulary_offsets
- visualize
- vocabulary_config
- EventStream.data.dataset_polars module
- EventStream.data.pytorch_dataset module
- EventStream.data.pytorch_dataset.PytorchDataset
- EventStream.data.pytorch_dataset.to_int_index
- EventStream.data.time_dependent_functor module
- EventStream.data.types module
- EventStream.data.types.DataModality
- EventStream.data.types.InputDFType
- EventStream.data.types.InputDataType
- EventStream.data.types.NumericDataModalitySubtype
- EventStream.data.types.PytorchBatch
- event_mask
- time_delta
- time
- static_indices
- static_measurement_indices
- dynamic_indices
- dynamic_measurement_indices
- dynamic_values
- dynamic_values_mask
- start_time
- start_idx
- end_idx
- subject_id
- stream_labels
- batch_size
- convert_to_DL_DF
- device
- dynamic_indices
- dynamic_measurement_indices
- dynamic_values
- dynamic_values_mask
- end_idx
- event_mask
- get
- items
- keys
- last_sequence_element_unsqueezed
- n_data_elements
- n_static_data_elements
- repeat_batch_elements
- sequence_length
- split_repeated_batch
- start_idx
- start_time
- static_indices
- static_measurement_indices
- stream_labels
- subject_id
- time
- time_delta
- values
- EventStream.data.types.TemporalityType
- EventStream.data.types.de_pad
- EventStream.data.visualize module
- EventStream.data.visualize.Visualizer
- subset_size
- subset_random_seed
- static_covariates
- plot_by_time
- time_unit
- plot_by_age
- age_col
- dob_col
- n_age_buckets
- Raises
- age_col
- dob_col
- n_age_buckets
- plot
- plot_by_age
- plot_by_time
- plot_counts_over_age
- plot_counts_over_time
- plot_events_per_patient
- plot_static_variables_breakdown
- static_covariates
- subset_random_seed
- subset_size
- time_unit
- EventStream.data.visualize.Visualizer
- EventStream.data.vocabulary module