com.alpine.plugin.core.spark.templates

TemplatedSparkDataFrameGUINode

abstract class TemplatedSparkDataFrameGUINode[StorageType <: IOBase] extends OperatorGUINode[HdfsTabularDataset, StorageType]

Control the GUI of your Spark job, through this you can specify any visualization for the output of your job, and what params the user will need to specify.

Linear Supertypes
OperatorGUINode[HdfsTabularDataset, StorageType], AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. TemplatedSparkDataFrameGUINode
  2. OperatorGUINode
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TemplatedSparkDataFrameGUINode()

Abstract Value Members

  1. abstract def onPlacement(operatorDialog: OperatorDialog, operatorDataSourceManager: OperatorDataSourceManager, operatorSchemaManager: OperatorSchemaManager): Unit

    Define actions to be performed when the operator GUI node is placed in the workflow.

    Define actions to be performed when the operator GUI node is placed in the workflow. This involves defining the property dialog content and/or refining what the output schema is supposed to be like. E.g., if the output is a tabular dataset, provide some outline about the output schema (partial or complete).

    operatorDialog

    The operator dialog where the operator could add input text boxes, etc. to define UI for parameter inputs.

    operatorDataSourceManager

    This contains that available data-sources (filtered for hadoop or database depending on the operator runtime class) that could be used by the operator at runtime.

    operatorSchemaManager

    This can be used to provide information about the nature of the output/input schemas. E.g., provide the output schema.

    Definition Classes
    OperatorGUINode

Concrete 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. final def eq(arg0: AnyRef): Boolean

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

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

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

    Definition Classes
    AnyRef → Any
  12. def getOperatorStatus(context: OperatorDesignContext): OperatorStatus

    Since Alpine 6.

    Since Alpine 6.3, SDK 1.9.

    This is called to get the current status of the operator, i.e. whether it is valid, information about the expected runtime output, and error messages to display in the properties window.

    This is intended to replace onInputOrParameterChange, as we want to be able to pass more general metadata between operators instead of only TabularSchema.

    The default implementation calls onInputOrParameterChange, to maintain compatibility with old operators.

    context

    contains information about the input operators, the current parameters, and the available data-sources.

    returns

    the current status of the operator.

    Definition Classes
    OperatorGUINode
  13. def hashCode(): Int

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

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

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

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

    Definition Classes
    AnyRef
  18. def onInputOrParameterChange(inputSchemas: Map[String, TabularSchema], params: OperatorParameters, operatorSchemaManager: OperatorSchemaManager): OperatorStatus

    This will be called by the default implementation of getOperatorStatus.

    This will be called by the default implementation of getOperatorStatus.

    As of Alpine 6.3, SDK 1.9, this is no longer called by the Alpine Engine.

    inputSchemas

    If the connected inputs contain tabular schemas, this is where they can be accessed, each with unique Ids.

    params

    The current parameter values of the operator.

    operatorSchemaManager

    This should be used to change the input/output schema, etc.

    returns

    A status object about whether the inputs and/or parameters are valid. The default implementation assumes that the connected inputs and/or parameters are valid.

    Attributes
    protected
    Definition Classes
    OperatorGUINode
  19. def onOutputVisualization(params: OperatorParameters, output: StorageType, visualFactory: VisualModelFactory): VisualModel

    This is kept only for old operators.

    This is kept only for old operators. New ones should implement OperatorRuntime#createVisualResults, which has more things available. If neither are implemented, Alpine will generate default a visualization.

    This is invoked for GUI to customize the operator output visualization after the operator finishes running. Each output should have associated default visualization, but the developer can customize it here.

    params

    The parameter values to the operator.

    output

    This is the output from running the operator.

    visualFactory

    For creating visual models.

    returns

    The visual model to be sent to the GUI for visualization.

    Definition Classes
    OperatorGUINode
  20. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  21. def toString(): String

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from OperatorGUINode[HdfsTabularDataset, StorageType]

Inherited from AnyRef

Inherited from Any

Ungrouped