org.apache.paimon.benchmark.utils

Class AutoClosableProcess.AutoClosableProcessBuilder

java.lang.Object

org.apache.paimon.benchmark.utils.AutoClosableProcess.AutoClosableProcessBuilder

Enclosing class:

AutoClosableProcess

public static final class AutoClosableProcess.AutoClosableProcessBuilder
extends Object

Builder for most sophisticated processes.

Method Summary

Modifier and Type	Method and Description
void	runBlocking()
void	runBlocking(java.time.Duration timeout)
void	runBlockingWithRetry(int maxRetries, java.time.Duration attemptTimeout, java.time.Duration globalTimeout)
AutoClosableProcess	runNonBlocking()
AutoClosableProcess.AutoClosableProcessBuilder	setStderrProcessor(java.util.function.Consumer<String> stderrProcessor)
AutoClosableProcess.AutoClosableProcessBuilder	setStdInputs(String... inputLines)
AutoClosableProcess.AutoClosableProcessBuilder	setStdoutProcessor(java.util.function.Consumer<String> stdoutProcessor)

Methods inherited from class java.lang.Object

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

Method Detail

setStdoutProcessor

public AutoClosableProcess.AutoClosableProcessBuilder setStdoutProcessor(java.util.function.Consumer<String> stdoutProcessor)

setStderrProcessor

public AutoClosableProcess.AutoClosableProcessBuilder setStderrProcessor(java.util.function.Consumer<String> stderrProcessor)

setStdInputs

public AutoClosableProcess.AutoClosableProcessBuilder setStdInputs(String... inputLines)

runBlocking

public void runBlocking()
                 throws IOException

Throws:

IOException

runBlocking

public void runBlocking(java.time.Duration timeout)
                 throws IOException

Throws:

IOException

runBlockingWithRetry

public void runBlockingWithRetry(int maxRetries,
                                 java.time.Duration attemptTimeout,
                                 java.time.Duration globalTimeout)
                          throws IOException

Throws:

IOException

runNonBlocking

public AutoClosableProcess runNonBlocking()
                                   throws IOException

Throws:

IOException