org.apache.beam.runners.apex

Class ApexYarnLauncher.ProcessWatcher

java.lang.Object

org.apache.beam.runners.apex.ApexYarnLauncher.ProcessWatcher

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

ApexYarnLauncher

public static class ApexYarnLauncher.ProcessWatcher
extends java.lang.Object
implements java.lang.Runnable

Starts a command and waits for it to complete.

Constructor Summary

Constructors

Constructor and Description
ProcessWatcher(java.lang.Process p)

Method Summary

Modifier and Type	Method and Description
boolean	isFinished()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessWatcher

public ProcessWatcher(java.lang.Process p)

Method Detail

isFinished

public boolean isFinished()

run

public void run()

Specified by:

run in interface java.lang.Runnable