public static class ParameterAveragingTrainingMasterStats.ParameterAveragingTrainingMasterStatsHelper
extends java.lang.Object
Constructor and Description |
---|
ParameterAveragingTrainingMasterStatsHelper() |
Modifier and Type | Method and Description |
---|---|
void |
addWorkerStats(SparkTrainingStats workerStats) |
ParameterAveragingTrainingMasterStats |
build() |
void |
logAggregateStartTime() |
void |
logAggregationEndTime() |
void |
logBroadcastEnd() |
void |
logBroadcastStart() |
void |
logCountEnd() |
void |
logCountStart() |
void |
logExportEnd() |
void |
logExportStart() |
void |
logFitEnd(int examplesCount) |
void |
logFitStart() |
void |
logMapPartitionsEnd(int nPartitions) |
void |
logMapPartitionsStart() |
void |
logProcessParamsUpdaterEnd() |
void |
logProcessParamsUpdaterStart() |
void |
logRepartitionEnd() |
void |
logRepartitionStart() |
void |
logSplitEnd() |
void |
logSplitStart() |
public ParameterAveragingTrainingMasterStatsHelper()
public void logExportStart()
public void logExportEnd()
public void logCountStart()
public void logCountEnd()
public void logBroadcastStart()
public void logBroadcastEnd()
public void logRepartitionStart()
public void logRepartitionEnd()
public void logFitStart()
public void logFitEnd(int examplesCount)
public void logSplitStart()
public void logSplitEnd()
public void logMapPartitionsStart()
public void logMapPartitionsEnd(int nPartitions)
public void logAggregateStartTime()
public void logAggregationEndTime()
public void logProcessParamsUpdaterStart()
public void logProcessParamsUpdaterEnd()
public void addWorkerStats(SparkTrainingStats workerStats)
public ParameterAveragingTrainingMasterStats build()