def __init__()

in esrally/metrics.py [0:0]

• 50 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self, d=None):
        self.op_metrics = self.v(d, "op_metrics", default=[])
        self.total_time = self.v(d, "total_time")
        self.total_time_per_shard = self.v(d, "total_time_per_shard", default={})
        self.indexing_throttle_time = self.v(d, "indexing_throttle_time")
        self.indexing_throttle_time_per_shard = self.v(d, "indexing_throttle_time_per_shard", default={})
        self.merge_time = self.v(d, "merge_time")
        self.merge_time_per_shard = self.v(d, "merge_time_per_shard", default={})
        self.merge_count = self.v(d, "merge_count")
        self.refresh_time = self.v(d, "refresh_time")
        self.refresh_time_per_shard = self.v(d, "refresh_time_per_shard", default={})
        self.refresh_count = self.v(d, "refresh_count")
        self.flush_time = self.v(d, "flush_time")
        self.flush_time_per_shard = self.v(d, "flush_time_per_shard", default={})
        self.flush_count = self.v(d, "flush_count")
        self.merge_throttle_time = self.v(d, "merge_throttle_time")
        self.merge_throttle_time_per_shard = self.v(d, "merge_throttle_time_per_shard", default={})
        self.ml_processing_time = self.v(d, "ml_processing_time", default=[])

        self.young_gc_time = self.v(d, "young_gc_time")
        self.young_gc_count = self.v(d, "young_gc_count")
        self.old_gc_time = self.v(d, "old_gc_time")
        self.old_gc_count = self.v(d, "old_gc_count")
        self.zgc_cycles_gc_time = self.v(d, "zgc_cycles_gc_time")
        self.zgc_cycles_gc_count = self.v(d, "zgc_cycles_gc_count")
        self.zgc_pauses_gc_time = self.v(d, "zgc_pauses_gc_time")
        self.zgc_pauses_gc_count = self.v(d, "zgc_pauses_gc_count")

        self.memory_segments = self.v(d, "memory_segments")
        self.memory_doc_values = self.v(d, "memory_doc_values")
        self.memory_terms = self.v(d, "memory_terms")
        self.memory_norms = self.v(d, "memory_norms")
        self.memory_points = self.v(d, "memory_points")
        self.memory_stored_fields = self.v(d, "memory_stored_fields")
        self.dataset_size = self.v(d, "dataset_size")
        self.store_size = self.v(d, "store_size")
        self.translog_size = self.v(d, "translog_size")
        self.segment_count = self.v(d, "segment_count")

        self.total_transform_search_times = self.v(d, "total_transform_search_times")
        self.total_transform_index_times = self.v(d, "total_transform_index_times")
        self.total_transform_processing_times = self.v(d, "total_transform_processing_times")
        self.total_transform_throughput = self.v(d, "total_transform_throughput")

        self.ingest_pipeline_cluster_count = self.v(d, "ingest_pipeline_cluster_count")
        self.ingest_pipeline_cluster_time = self.v(d, "ingest_pipeline_cluster_time")
        self.ingest_pipeline_cluster_failed = self.v(d, "ingest_pipeline_cluster_failed")

        self.disk_usage_total = self.v(d, "disk_usage_total")
        self.disk_usage_inverted_index = self.v(d, "disk_usage_inverted_index")
        self.disk_usage_stored_fields = self.v(d, "disk_usage_stored_fields")
        self.disk_usage_doc_values = self.v(d, "disk_usage_doc_values")
        self.disk_usage_points = self.v(d, "disk_usage_points")
        self.disk_usage_norms = self.v(d, "disk_usage_norms")
        self.disk_usage_term_vectors = self.v(d, "disk_usage_term_vectors")