class FeaturesFallbackReader[T <: HasFeatures] extends MLReader[T]
MLReader that loads a model with params and features, and has a fallback mechanism.
The fallback load will be called in case there is an exception during Spark loading (i.e. missing parameters or features).
Usually, you might want to call loadSavedModel
in the fallbackLoad
method to load a model
with default params.
- T
The type of the model that extends HasFeatures
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- FeaturesFallbackReader
- MLReader
- BaseReadWrite
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
-
new
FeaturesFallbackReader(baseReader: MLReader[T], onRead: (T, String, SparkSession) ⇒ Unit, fallbackLoad: (String, SparkSession) ⇒ T = null)
- baseReader
The default spark reader
- onRead
A function that will be called after the model is loaded, allowing to set a model
- fallbackLoad
A fallback function that will be called in case the main reader fails to load
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
load(path: String): T
- Definition Classes
- FeaturesFallbackReader → MLReader
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
sc: SparkContext
- Attributes
- protected
- Definition Classes
- BaseReadWrite
-
def
session(sparkSession: SparkSession): FeaturesFallbackReader.this.type
- Definition Classes
- MLReader → BaseReadWrite
-
final
def
sparkSession: SparkSession
- Attributes
- protected
- Definition Classes
- BaseReadWrite
-
final
def
sqlContext: SQLContext
- Attributes
- protected
- Definition Classes
- BaseReadWrite
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()