Package 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.LogStringContext, org.apache.spark.internal.Logging.SparkShellLoggingFilter

  • Method Summary

    Modifier and Type
    Method
    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

    initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isTraceEnabled, log, logBasedOnLevel, logDebug, logDebug, logDebug, logDebug, logError, logError, logError, logError, logInfo, logInfo, logInfo, logInfo, logName, LogStringContext, logTrace, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, logWarning, MDC, org$apache$spark$internal$Logging$$log_, org$apache$spark$internal$Logging$$log__$eq, withLogContext

  • Method Details

    • 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)