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