cluster-bootstrap-api/src/main/java/com/streamsets/pipeline/BootstrapCluster.java
public static /*PipelineStartResult*/ Object startPipeline(Runnable postBatchRunnable) throws Exception {
    BootstrapCluster.initialize();
    ClassLoader originalClassLoader = Thread.currentThread().getContextClassLoader();
    try {
      Thread.currentThread().setContextClassLoader(containerCL);
      Class embeddedPipelineFactoryClz = Class.forName("com.streamsets.datacollector.EmbeddedDataCollectorFactory", true,
        containerCL);
      Method createPipelineMethod = embeddedPipelineFactoryClz.getMethod("startPipeline", Runnable.class);
      return createPipelineMethod.invoke(null, postBatchRunnable);
    } catch (Exception ex) {
      String msg = "Error trying to create pipeline: " + ex;
      throw new IllegalStateException(msg, ex);
    } finally {
      Thread.currentThread().setContextClassLoader(originalClassLoader);
    }
  }
public static /*PipelineStartResult*/ Object startPipeline(Runnable postBatchRunnable) throws Exception {
    BootstrapCluster.initialize();
    ClassLoader originalClassLoader = Thread.currentThread().getContextClassLoader();
    try {
      Thread.currentThread().setContextClassLoader(containerCL);
      Class embeddedPipelineFactoryClz = Class.forName("com.streamsets.datacollector.EmbeddedDataCollectorFactory", true,
        containerCL);
      Method createPipelineMethod = embeddedPipelineFactoryClz.getMethod("startPipeline", Runnable.class);
      return createPipelineMethod.invoke(null, postBatchRunnable);
    } catch (Exception ex) {
      String msg = "Error trying to create pipeline: " + ex;
      throw new IllegalStateException(msg, ex);
    } finally {
      Thread.currentThread().setContextClassLoader(originalClassLoader);
    }
  }
Obtaining a reference on the dummy source which is used to feed a pipeline<br/>
Direction: Stage -> Container
@param postBatchRunnable runnable to run after each batch is finished
@return a source object associated with the newly created pipeline
@throws Exception