org.apache.flink.test.util

Class TestProcessBuilder

java.lang.Object

org.apache.flink.test.util.TestProcessBuilder

public class TestProcessBuilder
extends Object

Utility class wrapping ProcessBuilder and pre-configuring it with common options.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestProcessBuilder.TestProcess Process with it's processOutput.

Constructor Summary

Constructors

Constructor and Description
TestProcessBuilder(String mainClass)

Method Summary

Modifier and Type	Method and Description
TestProcessBuilder	addConfigAsMainClassArgs(Configuration config)
TestProcessBuilder	addJvmArg(String arg)
TestProcessBuilder	addMainClassArg(String arg)
TestProcessBuilder	setJvmMemory(MemorySize jvmMemory)
TestProcessBuilder.TestProcess	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestProcessBuilder

public TestProcessBuilder(String mainClass)
                   throws IOException

Throws:

IOException

Method Detail

start

public TestProcessBuilder.TestProcess start()
                                     throws IOException

Throws:

IOException

setJvmMemory

public TestProcessBuilder setJvmMemory(MemorySize jvmMemory)

addJvmArg

public TestProcessBuilder addJvmArg(String arg)

addMainClassArg

public TestProcessBuilder addMainClassArg(String arg)

addConfigAsMainClassArgs

public TestProcessBuilder addConfigAsMainClassArgs(Configuration config)