public class PipelineStatsUtils
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONTEXT |
static java.lang.String |
COUNTERS |
static java.lang.String |
EMPTY_COUNTER |
static java.lang.String |
EVENTS |
static java.lang.String |
OTHER |
static java.lang.String |
PIPELINE |
static java.lang.String |
PIPELINE_COMPLETE |
static java.lang.String |
PIPELINE_IN |
static java.lang.String |
PIPELINE_OUT |
static java.lang.String |
STAGE |
static java.lang.String |
STAGES |
static java.lang.String |
STATS |
Constructor and Description |
---|
PipelineStatsUtils() |
Modifier and Type | Method and Description |
---|---|
static java.util.Map<java.lang.String,java.lang.Object> |
extractPipelineStats(MetricRegistry registry,
java.util.List<java.lang.String> pipelineStages,
java.util.List<com.lucidworks.apollo.common.models.HistoryEvent> events) |
static java.util.List<java.lang.String> |
getPipelineStagesForStats(Pipeline<PipelineDocument> pipeline,
com.lucidworks.apollo.pipeline.index.config.transform.FieldMappingConfig fieldMappingConfig) |
public static final java.lang.String STAGE
public static final java.lang.String COUNTERS
public static final java.lang.String STAGES
public static final java.lang.String OTHER
public static final java.lang.String STATS
public static final java.lang.String EVENTS
public static final java.lang.String PIPELINE
public static final java.lang.String CONTEXT
public static final java.lang.String EMPTY_COUNTER
public static final java.lang.String PIPELINE_IN
public static final java.lang.String PIPELINE_OUT
public static final java.lang.String PIPELINE_COMPLETE
public static java.util.Map<java.lang.String,java.lang.Object> extractPipelineStats(MetricRegistry registry, java.util.List<java.lang.String> pipelineStages, java.util.List<com.lucidworks.apollo.common.models.HistoryEvent> events)
registry
- pipelineStages
- events
- public static java.util.List<java.lang.String> getPipelineStagesForStats(Pipeline<PipelineDocument> pipeline, com.lucidworks.apollo.pipeline.index.config.transform.FieldMappingConfig fieldMappingConfig)
pipeline
- fieldMappingConfig
- optional