public class StatsUtils
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
StatsUtils.StartTimeComparator |
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_MAX_TIMELINE_SIZE_MS |
Modifier and Type | Method and Description |
---|---|
static void |
exportStats(java.util.List<EventStats> list,
java.lang.String outputPath,
java.lang.String delimiter,
org.apache.spark.SparkContext sc) |
static void |
exportStats(java.util.List<EventStats> list,
java.lang.String outputDirectory,
java.lang.String filename,
java.lang.String delimiter,
org.apache.spark.SparkContext sc) |
static void |
exportStatsAsHTML(SparkTrainingStats sparkTrainingStats,
long maxTimelineSizeMs,
java.io.OutputStream outputStream)
Generate and export a HTML representation (including charts, etc) of the Spark training statistics
This overload is for writing to an output stream |
static void |
exportStatsAsHtml(SparkTrainingStats sparkTrainingStats,
long maxTimelineSizeMs,
java.lang.String path,
org.apache.spark.SparkContext sc)
Generate and export a HTML representation (including charts, etc) of the Spark training statistics
Note: exporting is done via Spark, so the path here can be a local file, HDFS, etc. |
static void |
exportStatsAsHTML(SparkTrainingStats sparkTrainingStats,
java.io.OutputStream outputStream)
Generate and export a HTML representation (including charts, etc) of the Spark training statistics
This overload is for writing to an output stream |
static void |
exportStatsAsHtml(SparkTrainingStats sparkTrainingStats,
java.lang.String path,
org.apache.spark.api.java.JavaSparkContext sc) |
static void |
exportStatsAsHtml(SparkTrainingStats sparkTrainingStats,
java.lang.String path,
org.apache.spark.SparkContext sc)
Generate and export a HTML representation (including charts, etc) of the Spark training statistics
Note: exporting is done via Spark, so the path here can be a local file, HDFS, etc. |
static java.lang.String |
getDurationAsString(java.util.List<EventStats> list,
java.lang.String delim) |
public static final long DEFAULT_MAX_TIMELINE_SIZE_MS
public static void exportStats(java.util.List<EventStats> list, java.lang.String outputDirectory, java.lang.String filename, java.lang.String delimiter, org.apache.spark.SparkContext sc) throws java.io.IOException
java.io.IOException
public static void exportStats(java.util.List<EventStats> list, java.lang.String outputPath, java.lang.String delimiter, org.apache.spark.SparkContext sc) throws java.io.IOException
java.io.IOException
public static java.lang.String getDurationAsString(java.util.List<EventStats> list, java.lang.String delim)
public static void exportStatsAsHtml(SparkTrainingStats sparkTrainingStats, java.lang.String path, org.apache.spark.api.java.JavaSparkContext sc) throws java.lang.Exception
java.lang.Exception
public static void exportStatsAsHtml(SparkTrainingStats sparkTrainingStats, java.lang.String path, org.apache.spark.SparkContext sc) throws java.lang.Exception
sparkTrainingStats
- Stats to generate HTML page forpath
- Path to export. May be local or HDFSsc
- Spark contextjava.lang.Exception
- IO errors or error generating HTML filepublic static void exportStatsAsHtml(SparkTrainingStats sparkTrainingStats, long maxTimelineSizeMs, java.lang.String path, org.apache.spark.SparkContext sc) throws java.lang.Exception
sparkTrainingStats
- Stats to generate HTML page forpath
- Path to export. May be local or HDFSmaxTimelineSizeMs
- maximum amount of activity to show in a single timeline plot (multiple plots will be used if training exceeds this amount of time)sc
- Spark contextjava.lang.Exception
- IO errors or error generating HTML filepublic static void exportStatsAsHTML(SparkTrainingStats sparkTrainingStats, java.io.OutputStream outputStream) throws java.lang.Exception
sparkTrainingStats
- Stats to generate HTML page forjava.lang.Exception
- IO errors or error generating HTML filepublic static void exportStatsAsHTML(SparkTrainingStats sparkTrainingStats, long maxTimelineSizeMs, java.io.OutputStream outputStream) throws java.lang.Exception
sparkTrainingStats
- Stats to generate HTML page formaxTimelineSizeMs
- maximum amount of activity to show in a single timeline plot (multiple plots will be used if training exceeds this amount of time)java.lang.Exception
- IO errors or error generating HTML file