Package

org.apache.predictionio

workflow

Permalink

package workflow

Ordering
  1. Grouped
  2. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class BatchPredictConfig(inputFilePath: String = "batchpredict-input.json", outputFilePath: String = "batchpredict-output.json", queryPartitions: Option[Int] = None, engineInstanceId: String = "", engineId: Option[String] = None, engineVersion: Option[String] = None, engineVariant: String = "", env: Option[String] = None, verbose: Boolean = false, debug: Boolean = false, jsonExtractor: JsonExtractorOption.JsonExtractorOption = JsonExtractorOption.Both) extends Product with Serializable

    Permalink
  2. case class BindServer() extends Product with Serializable

    Permalink
  3. trait EngineServerPlugin extends AnyRef

    Permalink
  4. class EngineServerPluginContext extends AnyRef

    Permalink
  5. trait FakeRun extends EngineFactory with Evaluation with EngineParamsGenerator

    Permalink

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

    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()
  6. class KryoInstantiator extends ScalaKryoInstantiator

    Permalink
  7. class MasterActor extends Actor with KeyAuthentication with SSLConfiguration

    Permalink
  8. case class NameParams(name: String, params: Option[JValue]) extends Product with Serializable

    Permalink
  9. class NameParamsSerializer extends CustomSerializer[NameParams]

    Permalink
  10. case class PersistentModelManifest(className: String) extends Product with Serializable

    Permalink
  11. class PluginsActor extends Actor

    Permalink
  12. class PredictionServer[Q, P] extends KeyAuthentication

    Permalink
  13. case class ReloadServer() extends Product with Serializable

    Permalink
  14. case class ServerConfig(batch: String = "", engineInstanceId: String = "", engineId: Option[String] = None, engineVersion: Option[String] = None, engineVariant: String = "", env: Option[String] = None, ip: String = "0.0.0.0", port: Int = 8000, feedback: Boolean = false, eventServerIp: String = "0.0.0.0", eventServerPort: Int = 7070, accessKey: Option[String] = None, logUrl: Option[String] = None, logPrefix: Option[String] = None, logFile: Option[String] = None, verbose: Boolean = false, debug: Boolean = false, jsonExtractor: JsonExtractorOption.JsonExtractorOption = JsonExtractorOption.Both) extends Product with Serializable

    Permalink
  15. case class StartServer() extends Product with Serializable

    Permalink
  16. case class StopAfterPrepareInterruption() extends WorkflowInterruption with Product with Serializable

    Permalink
  17. case class StopAfterReadInterruption() extends WorkflowInterruption with Product with Serializable

    Permalink
  18. case class StopServer() extends Product with Serializable

    Permalink
  19. class WorkflowInterruption extends Exception

    Permalink
  20. case class WorkflowParams(batch: String = "", verbose: Int = 2, saveModel: Boolean = true, sparkEnv: Map[String, String] = ..., skipSanityCheck: Boolean = false, stopAfterRead: Boolean = false, stopAfterPrepare: Boolean = false) extends Product with Serializable

    Permalink

    Workflow parameters.

    Workflow parameters.

    batch

    Batch label of the run.

    verbose

    Verbosity level.

    saveModel

    Controls whether trained models are persisted.

    sparkEnv

    Spark properties that will be set in SparkConf.setAll().

    skipSanityCheck

    Skips all data sanity check.

    stopAfterRead

    Stops workflow after reading from data source.

    stopAfterPrepare

    Stops workflow after data preparation.

Value Members

  1. object BatchPredict extends Logging

    Permalink
  2. object CleanupFunctions

    Permalink

    :: DeveloperApi :: Singleton object that collects anonymous functions to be executed to allow the process to end gracefully.

    :: DeveloperApi :: Singleton object that collects anonymous functions to be executed to allow the process to end gracefully.

    For example, the Elasticsearch REST storage client maintains an internal connection pool that must be closed to allow the process to exit.

  3. object CoreWorkflow

    Permalink

    CoreWorkflow handles PredictionIO metadata and environment variables of training and evaluation.

  4. object CreateServer extends Logging

    Permalink
  5. object CreateWorkflow extends Logging

    Permalink
  6. object EngineLanguage extends Enumeration

    Permalink
  7. object EngineServerJson4sSupport

    Permalink
  8. object EngineServerPlugin

    Permalink
  9. object EngineServerPluginContext extends Logging

    Permalink
  10. object EvaluationWorkflow

    Permalink
  11. object JsonExtractor

    Permalink
  12. object JsonExtractorOption extends Enumeration

    Permalink
  13. object KryoInstantiator extends Serializable

    Permalink
  14. object PluginsActor

    Permalink
  15. object SparkWorkflowUtils extends Logging

    Permalink

    Collection of reusable workflow related utilities that touch on Apache Spark.

    Collection of reusable workflow related utilities that touch on Apache Spark. They are separated to avoid compilation problems with certain code.

  16. object Workflow

    Permalink

    Collection of workflow creation methods.

  17. object WorkflowContext extends Logging

    Permalink
  18. object WorkflowUtils extends Logging

    Permalink

    Collection of reusable workflow related utilities.

Workflow

Ungrouped