org.apache.predictionio.workflow

WorkflowUtils

object WorkflowUtils extends Logging

Collection of reusable workflow related utilities.

Linear Supertypes
Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. WorkflowUtils
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. def debug(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  9. def debug(msg: ⇒ Any): Unit

    Attributes
    protected
    Definition Classes
    Logging
  10. def debugString[D](data: D): String

  11. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  13. def error(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  14. def error(msg: ⇒ Any): Unit

    Attributes
    protected
    Definition Classes
    Logging
  15. def extractNameParams(jv: JValue): NameParams

  16. def extractParams(language: EngineLanguage.Value = EngineLanguage.Scala, json: String, clazz: Class[_], jsonExtractor: JsonExtractorOption.JsonExtractorOption, formats: Formats = Utils.json4sDefaultFormats): Params

    Converts a JSON document to an instance of Params.

    Converts a JSON document to an instance of Params.

    language

    Engine's programming language.

    json

    JSON document.

    clazz

    Class of the component that is going to receive the resulting Params instance as a constructor argument.

    jsonExtractor

    JSON extractor option.

    formats

    JSON4S serializers for deserialization.

    Exceptions thrown
    JsonSyntaxException

    Thrown when GSON fails to perform conversion.

    MappingException

    Thrown when JSON4S fails to perform conversion.

  17. def extractSparkConf(root: JValue): List[(String, String)]

  18. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  19. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  20. def getEngine(engine: String, cl: ClassLoader): (EngineLanguage.Value, EngineFactory)

    Obtains an Engine object in Scala, or instantiate an Engine in Java.

    Obtains an Engine object in Scala, or instantiate an Engine in Java.

    engine

    Engine factory name.

    cl

    A Java ClassLoader to look for engine-related classes.

    Exceptions thrown
    ClassNotFoundException

    Thrown when engine factory class does not exist.

    NoSuchMethodException

    Thrown when engine factory's apply() method is not implemented.

  21. def getEngineParamsGenerator(epg: String, cl: ClassLoader): (EngineLanguage.Value, EngineParamsGenerator)

  22. def getEvaluation(evaluation: String, cl: ClassLoader): (EngineLanguage.Value, Evaluation)

  23. def getParamsFromJsonByFieldAndClass(variantJson: JValue, field: String, classMap: Map[String, Class[_]], engineLanguage: EngineLanguage.Value, jsonExtractor: JsonExtractorOption.JsonExtractorOption): (String, Params)

  24. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  25. def info(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  26. def info(msg: ⇒ Any): Unit

    Attributes
    protected
    Definition Classes
    Logging
  27. def isDebugEnabled: Boolean

    Attributes
    protected
    Definition Classes
    Logging
  28. def isErrorEnabled: Boolean

    Attributes
    protected
    Definition Classes
    Logging
  29. def isInfoEnabled: Boolean

    Attributes
    protected
    Definition Classes
    Logging
  30. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  31. def isTraceEnabled: Boolean

    Attributes
    protected
    Definition Classes
    Logging
  32. def isWarnEnabled: Boolean

    Attributes
    protected
    Definition Classes
    Logging
  33. def javaObjectToJValue(params: AnyRef): JValue

    Converts Java (non-Scala) objects to a JSON4S JValue.

    Converts Java (non-Scala) objects to a JSON4S JValue.

    params

    The Java object to be converted.

  34. def logger: Logger

    Attributes
    protected
    Definition Classes
    Logging
  35. def loggerName: String

    Attributes
    protected
    Definition Classes
    Logging
  36. def modifyLogging(verbose: Boolean): Unit

  37. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  38. final def notify(): Unit

    Definition Classes
    AnyRef
  39. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  40. def pioEnvVars: Map[String, String]

    Grab environmental variables that starts with 'PIO_'.

  41. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  42. def thirdPartyClasspaths: Seq[String]

  43. def thirdPartyConfFiles: Seq[String]

    Detect third party software configuration files to be submitted as extras to Apache Spark.

    Detect third party software configuration files to be submitted as extras to Apache Spark. This makes sure all executors receive the same configuration.

  44. def thirdPartyJars: Seq[URI]

  45. def toString(): String

    Definition Classes
    AnyRef → Any
  46. def trace(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  47. def trace(msg: ⇒ Any): Unit

    Attributes
    protected
    Definition Classes
    Logging
  48. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  50. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  51. def warn(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  52. def warn(msg: ⇒ Any): Unit

    Attributes
    protected
    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped