public void create(ModuleDefineHolder moduleDefineHolder,
                       Stream stream,
                       Class<? extends Metrics> metricsClass) throws StorageException {
        this.create(moduleDefineHolder, StreamDefinition.from(stream), metricsClass, MetricStreamKind.OAL);
    }
Create the workers and work flow for OAL metrics.

@param moduleDefineHolder pointer of the module define.
@param stream             definition of the metrics class.
@param metricsClass       data type of the streaming calculation.
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/MetricsStreamProcessor.java