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);
    }
  }
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
Obtaining a reference on the dummy source which is used to feed a pipeline<br / > Direction : Stage - > Container