Package org.apache.wayang.profiler.util

Class ProfilingUtils

java.lang.Object

org.apache.wayang.profiler.util.ProfilingUtils

public class ProfilingUtils
extends Object

Utilities to fake Wayang internals etc..

Method Summary

Modifier and Type	Method	Description
static JavaExecutor	fakeJavaExecutor()	Provides a JavaExecutor.
static Job	fakeJob(String... udfJars)	Provides a Job.
static SparkExecutor	fakeSparkExecutor(String... udfJars)	Provides a SparkExecutor.
static void	sleep(long millis)	Puts the current Thread to sleep for a given number of milliseconds.

Methods inherited from class java.lang.Object

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

Method Details

fakeJob

public static Job fakeJob(String... udfJars)

Provides a Job.

Parameters:

udfJars - paths to JAR files needed to run the UDFs (see ReflectionUtils.getDeclaringJar(Class))

fakeSparkExecutor

public static SparkExecutor fakeSparkExecutor(String... udfJars)

Provides a SparkExecutor.

Parameters:

udfJars - paths to JAR files needed to run the UDFs (see ReflectionUtils.getDeclaringJar(Class))

fakeJavaExecutor

public static JavaExecutor fakeJavaExecutor()

Provides a JavaExecutor.

sleep

public static void sleep(long millis)

Puts the current Thread to sleep for a given number of milliseconds. Notifies the user via the System.out.