Trait

org.apache.predictionio.workflow

FakeRun

Related Doc: package workflow

Permalink

trait FakeRun extends EngineFactory with Evaluation with EngineParamsGenerator

FakeRun allows user to implement custom function under the exact environment as other PredictionIO workflow.

Useful for developing new features. Only need to extend this trait and implement a function: (SparkContext => Unit). For example, the code below can be run with pio eval HelloWorld.

object HelloWorld extends FakeRun {
  // func defines the function pio runs, must have signature (SparkContext => Unit).
  func = f

  def f(sc: SparkContext): Unit {
    val logger = Logger[this.type]
    logger.info("HelloWorld")
  }
}
Annotations
@Experimental()
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FakeRun
  2. EngineParamsGenerator
  3. Evaluation
  4. Deployment
  5. EngineFactory
  6. AnyRef
  7. 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. var _engine: BaseEngine[_, _, _, _]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    Deployment
  5. var _evaluator: BaseEvaluator[_, _, _, _, _ <: BaseEvaluatorResult]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    Evaluation
  6. var _evaluatorSet: Boolean

    Permalink
    Attributes
    protected[this]
    Definition Classes
    Evaluation
  7. def apply(): BaseEngine[_, _, _, _]

    Permalink

    Returns the Engine of this Deployment

    Returns the Engine of this Deployment

    Definition Classes
    DeploymentEngineFactory
  8. final def asInstanceOf[T0]: T0

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

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  10. def engineEvaluator: (BaseEngine[_, _, _, _], BaseEvaluator[_, _, _, _, _])

    Permalink

    Gets the tuple of the Engine and the implementation of org.apache.predictionio.core.BaseEvaluator

    Gets the tuple of the Engine and the implementation of org.apache.predictionio.core.BaseEvaluator

    Definition Classes
    Evaluation
  11. def engineEvaluator_=[EI, Q, P, A, R <: BaseEvaluatorResult](engineEvaluator: (BaseEngine[EI, Q, P, A], BaseEvaluator[EI, Q, P, A, R])): Unit

    Permalink

    Sets both an Engine and an implementation of org.apache.predictionio.core.BaseEvaluator for this Evaluation

    Sets both an Engine and an implementation of org.apache.predictionio.core.BaseEvaluator for this Evaluation

    EI

    Evaluation information class

    Q

    Query class

    P

    Predicted result class

    A

    Actual result class

    R

    Metric result class

    engineEvaluator

    A tuple an Engine and an implementation of org.apache.predictionio.core.BaseEvaluator

    Definition Classes
    Evaluation
  12. def engineMetric: (BaseEngine[_, _, _, _], Metric[_, _, _, _, _])

    Permalink

    Returns both the Engine and the implementation of Metric for this Evaluation

    Returns both the Engine and the implementation of Metric for this Evaluation

    Definition Classes
    Evaluation
  13. def engineMetric_=[EI, Q, P, A](engineMetric: (BaseEngine[EI, Q, P, A], Metric[EI, Q, P, A, _])): Unit

    Permalink

    Sets both an Engine and an implementation of Metric for this Evaluation

    Sets both an Engine and an implementation of Metric for this Evaluation

    EI

    Evaluation information class

    Q

    Query class

    P

    Predicted result class

    A

    Actual result class

    engineMetric

    A tuple of Engine and an implementation of Metric

    Definition Classes
    Evaluation
  14. def engineMetrics_=[EI, Q, P, A](engineMetrics: (BaseEngine[EI, Q, P, A], Metric[EI, Q, P, A, _], Seq[Metric[EI, Q, P, A, _]])): Unit

    Permalink

    Sets an Engine, an implementation of Metric, and sequence of implementations of Metric for this Evaluation

    Sets an Engine, an implementation of Metric, and sequence of implementations of Metric for this Evaluation

    EI

    Evaluation information class

    Q

    Query class

    P

    Predicted result class

    A

    Actual result class

    engineMetrics

    A tuple of Engine, an implementation of Metric and sequence of implementations of Metric

    Definition Classes
    Evaluation
  15. def engineParams(key: String): EngineParams

    Permalink

    Override this method to programmatically return engine parameters.

    Override this method to programmatically return engine parameters.

    Definition Classes
    EngineFactory
  16. def engineParamsList: Seq[EngineParams]

    Permalink

    Returns the list of EngineParams of this EngineParamsGenerator.

    Returns the list of EngineParams of this EngineParamsGenerator.

    Definition Classes
    EngineParamsGenerator
  17. def engineParamsList_=(l: Seq[EngineParams]): Unit

    Permalink

    Sets the list of EngineParams of this EngineParamsGenerator.

    Sets the list of EngineParams of this EngineParamsGenerator.

    Definition Classes
    EngineParamsGenerator
  18. var engineSet: Boolean

    Permalink
    Attributes
    protected[this]
    Definition Classes
    Deployment
  19. def engine_=[EI, Q, P, A](engine: BaseEngine[EI, Q, P, A]): Unit

    Permalink

    Sets the Engine for this Deployment

    Sets the Engine for this Deployment

    EI

    Evaluation information class

    Q

    Query class

    P

    Predicted result class

    A

    Actual result class

    engine

    An implementation of Engine

    Definition Classes
    Deployment
  20. var epList: Seq[EngineParams]

    Permalink
    Attributes
    protected[this]
    Definition Classes
    EngineParamsGenerator
  21. var epListSet: Boolean

    Permalink
    Attributes
    protected[this]
    Definition Classes
    EngineParamsGenerator
  22. final def eq(arg0: AnyRef): Boolean

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

    Permalink
    Definition Classes
    AnyRef → Any
  24. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  25. def func: (SparkContext) ⇒ Unit

    Permalink
  26. def func_=(f: (SparkContext) ⇒ Unit): Unit

    Permalink
  27. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  28. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  29. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  30. final def ne(arg0: AnyRef): Boolean

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

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

    Permalink
    Definition Classes
    AnyRef
  33. def runner: FakeRunner

    Permalink
  34. def runner_=(r: FakeRunner): Unit

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

    Permalink
    Definition Classes
    AnyRef
  36. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  37. final def wait(): Unit

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

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from EngineParamsGenerator

Inherited from Evaluation

Inherited from Deployment

Inherited from EngineFactory

Inherited from AnyRef

Inherited from Any

Ungrouped