org.apache.spark.ml

Interface MLEvents

All Superinterfaces:

org.apache.spark.internal.Logging

public interface MLEvents
extends org.apache.spark.internal.Logging

A small trait that defines some methods to send MLEvent.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging

org.apache.spark.internal.Logging.SparkShellLoggingFilter

Method Summary

Modifier and Type	Method and Description
org.apache.spark.scheduler.LiveListenerBus	listenerBus()
void	logEvent(MLEvent event) Log MLEvent to send.
<M extends Model<M>> M	withFitEvent(Estimator<M> estimator, Dataset<?> dataset, scala.Function0<M> func)
<T> T	withLoadInstanceEvent(MLReader<T> reader, String path, scala.Function0<T> func)
void	withSaveInstanceEvent(MLWriter writer, String path, scala.Function0<scala.runtime.BoxedUnit> func)
Dataset<Row>	withTransformEvent(Transformer transformer, Dataset<?> input, scala.Function0<Dataset<Row>> func)

Methods inherited from interface org.apache.spark.internal.Logging

$init$, initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, initLock, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, uninitialize

Method Detail

listenerBus

org.apache.spark.scheduler.LiveListenerBus listenerBus()

logEvent

void logEvent(MLEvent event)

Log MLEvent to send. By default, it emits a debug-level log.

Parameters:

event - (undocumented)

withFitEvent

<M extends Model<M>> M withFitEvent(Estimator<M> estimator,
                                    Dataset<?> dataset,
                                    scala.Function0<M> func)

withLoadInstanceEvent

<T> T withLoadInstanceEvent(MLReader<T> reader,
                            String path,
                            scala.Function0<T> func)

withSaveInstanceEvent

void withSaveInstanceEvent(MLWriter writer,
                           String path,
                           scala.Function0<scala.runtime.BoxedUnit> func)

withTransformEvent

Dataset<Row> withTransformEvent(Transformer transformer,
                                Dataset<?> input,
                                scala.Function0<Dataset<Row>> func)