Object

org.apache.predictionio.workflow

WorkflowUtils

Related Doc: package workflow

Permalink

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
Visibility
  1. Public
  2. All

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

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

    Permalink
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. def clone(): AnyRef

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

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

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

    Permalink
  9. final def eq(arg0: AnyRef): Boolean

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

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

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

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

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

    Permalink

    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.

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

    Permalink
  16. def finalize(): Unit

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

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

    Permalink

    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.

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

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

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

    Permalink
  22. def hashCode(): Int

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

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

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  25. def isDebugEnabled: Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  26. def isErrorEnabled: Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  27. def isInfoEnabled: Boolean

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

    Permalink
    Definition Classes
    Any
  29. def isTraceEnabled: Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  30. def isWarnEnabled: Boolean

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

    Permalink

    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.

  32. def logger: Logger

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  33. def loggerName: String

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

    Permalink
  35. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  36. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  37. final def notifyAll(): Unit

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

    Permalink

    Grab environmental variables that starts with 'PIO_'.

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

    Permalink
    Definition Classes
    AnyRef
  40. def thirdPartyClasspaths: Seq[String]

    Permalink
  41. def thirdPartyConfFiles: Seq[String]

    Permalink

    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.

  42. def thirdPartyJars: Seq[URI]

    Permalink
  43. def toString(): String

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

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

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

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

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

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

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

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped