alluxio.client.job

Class JobGrpcClientUtils

java.lang.Object

alluxio.client.job.JobGrpcClientUtils

@ThreadSafe
public final class JobGrpcClientUtils
extends Object

Utils for interacting with the job service through a gRPC client.

Method Summary

Modifier and Type	Method and Description
static void	run(JobConfig config, int attempts, AlluxioConfiguration alluxioConf) Runs the specified job and waits for it to finish.

Methods inherited from class java.lang.Object

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

Method Detail

run

public static void run(JobConfig config,
                       int attempts,
                       AlluxioConfiguration alluxioConf)
                throws InterruptedException

Runs the specified job and waits for it to finish. If the job fails, it is retried the given number of times. If the job does not complete in the given number of attempts, an exception is thrown.

Parameters:

config - configuration for the job to run

attempts - number of times to try running the job before giving up

alluxioConf - Alluxio configuration

Throws:

InterruptedException