public class JobGroupUtils
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static JobGroupInfo |
getJobGroupInfo(org.apache.spark.SparkContext sparkContext) |
static void |
setJobGroupInfo(org.apache.spark.SparkContext sparkContext,
JobGroupInfo info) |
static <T> T |
withJobGroupInfo(org.apache.spark.api.java.JavaSparkContext sparkContext,
JobGroupInfo info,
java.util.function.Supplier<T> supplier) |
static <T> T |
withJobGroupInfo(org.apache.spark.SparkContext sparkContext,
JobGroupInfo info,
java.util.function.Supplier<T> supplier) |
public static JobGroupInfo getJobGroupInfo(org.apache.spark.SparkContext sparkContext)
public static void setJobGroupInfo(org.apache.spark.SparkContext sparkContext, JobGroupInfo info)
public static <T> T withJobGroupInfo(org.apache.spark.api.java.JavaSparkContext sparkContext, JobGroupInfo info, java.util.function.Supplier<T> supplier)
public static <T> T withJobGroupInfo(org.apache.spark.SparkContext sparkContext, JobGroupInfo info, java.util.function.Supplier<T> supplier)