Package | Description |
---|---|
org.apache.pig.backend.hadoop.executionengine.spark | |
org.apache.pig.tools.pigstats.spark |
Constructor and Description |
---|
JobGraphBuilder(SparkOperPlan plan,
Map<Class<? extends PhysicalOperator>,RDDConverter> convertMap,
SparkPigStats sparkStats,
JavaSparkContext sparkContext,
JobMetricsListener jobMetricsListener,
String jobGroupID,
org.apache.hadoop.mapred.JobConf jobConf,
PigContext pc) |
Modifier and Type | Method and Description |
---|---|
static void |
SparkStatsUtil.addFailJobStats(String jobID,
POStore poStore,
SparkOperator sparkOperator,
SparkPigStats sparkPigStats,
Exception e) |
static void |
SparkStatsUtil.waitForJobAddStats(int jobID,
POStore poStore,
SparkOperator sparkOperator,
JobMetricsListener jobMetricsListener,
JavaSparkContext sparkContext,
SparkPigStats sparkPigStats) |
Copyright © 2007-2017 The Apache Software Foundation