MetricsServiceImpl.java 文件源码

@SuppressWarnings("unchecked")
private <T> Func6<MetricId<T>, Long, Long, Integer, Order, Integer, Observable<Row>> getDataPointFinder(
        MetricType<T> metricType) {
    Func6<MetricId<T>, Long, Long, Integer, Order, Integer, Observable<Row>> finder;
    finder = (Func6<MetricId<T>, Long, Long, Integer, Order, Integer, Observable<Row>>) dataPointFinders
            .get(metricType);
    if (finder == null) {
        throw new UnsupportedOperationException(metricType.getText());
    }
    return finder;
}