Packages

object Serializer

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Serializer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. val ContextClassLoader: ClassLoader
  2. val Mirror: Mirror
  3. def getPath(baseDir: Path, i: Int): Path
  4. def makeQualifiedPath(sc: SparkContext, path: String): Path
  5. def read[A](is: InputStream)(implicit ttag: scala.reflect.api.JavaUniverse.TypeTag[A]): A
  6. def readFromHDFS[O](sc: SparkContext, path: Path)(implicit ttag: scala.reflect.api.JavaUniverse.TypeTag[O]): O

    Loads the object from the given path.

    Loads the object from the given path.

    path

    The main path for model to load the object from.

    returns

    The loaded object.

  7. def typeToSerializer[T](tpe: scala.reflect.api.JavaUniverse.Type, sparkSession: SparkSession): Serializer[T]
  8. def typeToTypeTag[T](tpe: scala.reflect.api.JavaUniverse.Type): scala.reflect.api.JavaUniverse.TypeTag[T]
  9. def write[A](o: A, outputStream: OutputStream)(implicit ttag: scala.reflect.api.JavaUniverse.TypeTag[A]): Unit
  10. def writeMLWritable(stage: MLWritable, outputPath: Path, overwrite: Boolean): Unit
  11. def writeToHDFS[O](sc: SparkContext, obj: O, outputPath: Path, overwrite: Boolean)(implicit ttag: scala.reflect.api.JavaUniverse.TypeTag[O]): Unit

    Writes the object to the given path.

    Writes the object to the given path.

    obj

    The object to write.

    outputPath

    Where to write the object