public final class PipelineRunner
extends java.lang.Object
Modifier and Type | Method | Description |
---|---|---|
static void |
run(Pipeline pipeline,
Environment env,
java.io.Reader reader,
java.io.Writer writer,
int worker) |
|
static void |
run(Pipeline pipeline,
Environment env,
java.util.concurrent.Callable<java.io.Reader> readerProvider,
java.util.concurrent.Callable<java.io.Writer> writerProvider,
int worker) |
public static void run(Pipeline pipeline, Environment env, java.util.concurrent.Callable<java.io.Reader> readerProvider, java.util.concurrent.Callable<java.io.Writer> writerProvider, int worker) throws java.lang.Exception
java.lang.Exception
public static void run(Pipeline pipeline, Environment env, java.io.Reader reader, java.io.Writer writer, int worker) throws java.io.IOException
java.io.IOException