Uses of Class
org.apache.pig.backend.hadoop.executionengine.spark.JobStatisticCollector

Packages that use JobStatisticCollector

Package	Description
org.apache.pig.backend.hadoop.executionengine.spark
org.apache.pig.tools.pigstats.spark

Uses of JobStatisticCollector in org.apache.pig.backend.hadoop.executionengine.spark

Constructors in org.apache.pig.backend.hadoop.executionengine.spark with parameters of type JobStatisticCollector

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)

Uses of JobStatisticCollector in org.apache.pig.tools.pigstats.spark

Methods in org.apache.pig.tools.pigstats.spark with parameters of type JobStatisticCollector

Modifier and Type	Method and Description
void	SparkPigStats.addFailJobStats(POStore poStore, SparkOperator sparkOperator, java.lang.String jobId, JobStatisticCollector jobStatisticCollector, JavaSparkContext sparkContext, java.lang.Exception e)
void	SparkPigStats.addJobStats(POStore poStore, SparkOperator sparkOperator, int jobId, JobStatisticCollector jobStatisticCollector, JavaSparkContext sparkContext)
void	SparkJobStats.addOutputInfo(POStore poStore, boolean success, JobStatisticCollector jobStatisticCollector)
void	SparkJobStats.collectStats(JobStatisticCollector jobStatisticCollector)
static void	SparkStatsUtil.waitForJobAddStats(int jobID, POStore poStore, SparkOperator sparkOperator, JobStatisticCollector jobStatisticCollector, JavaSparkContext sparkContext, SparkPigStats sparkPigStats)