abstract class Streamlet[Context <: StreamletContext] extends AnyRef

Linear Supertypes
AnyRef, Any
Known Subclasses
AkkaServerStreamlet, AkkaStreamlet
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Streamlet
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Streamlet()

Abstract Value Members

  1. abstract def createContext(config: Config): Context

    Creates a StreamletContext for the appropriate runtime

    Creates a StreamletContext for the appropriate runtime

    Attributes
    protected
  2. abstract def logStartRunnerMessage(buildInfo: String): Unit
  3. abstract def run(context: Context): StreamletExecution

    Runs the streamlet.

  4. abstract def runtime: StreamletRuntime
  5. abstract def shape(): StreamletShape

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def attributes: Set[StreamletAttribute]

    A set of custom attributes that a streamlet can use to activate features in the Cloudflow runtime.

    A set of custom attributes that a streamlet can use to activate features in the Cloudflow runtime.

    Attributes
    protected[cloudflow]
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. def configParameters: IndexedSeq[ConfigParameter]

    Defines a set of configuration parameters that will be used in this streamlet to lookup environment-specific configuration to be provided at deployment time.

  8. implicit final def context: Context

    Returns the StreamletContext in which this streamlet is run.

    Returns the StreamletContext in which this streamlet is run. It can only be accessed when the streamlet is run.

    Attributes
    protected
  9. def customAttributes: Set[StreamletAttribute]

    A set of custom attributes that a streamlet can use to activate features in the Cloudflow runtime.

  10. def defineConfigParameters(): Array[ConfigParameter]

    Java API

    Java API

    Defines configuration parameters that will be used in this streamlet to lookup environment-specific configuration to be provided at deployment time.

  11. def defineCustomAttributes(): Array[StreamletAttribute]

    Java API

    Java API

    Defines a set of custom attributes that a streamlet can use to activate features in the Cloudflow runtime.

  12. def defineVolumeMounts(): Array[VolumeMount]

    Java API Defines volume mounts that can be used by the streamlet to mount a volume in a local path.

  13. def description: String
  14. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  16. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  17. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. final def getContext(): Context

    Java API

    Java API

    Returns the StreamletContext in which this streamlet is run. It can only be accessed when the streamlet is run.

    Attributes
    protected
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. final def inlets: IndexedSeq[Inlet]
  21. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  22. final def jsonDescriptor: String

    JSON-Encoded String representing the descriptor of this streamlet.

  23. def labels: IndexedSeq[String]
  24. lazy val log: Logger
    Attributes
    protected
    Annotations
    @transient()
  25. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  26. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  27. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  28. final def outlets: IndexedSeq[Outlet]
  29. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  30. def toString(): String
    Definition Classes
    AnyRef → Any
  31. def volumeMounts: IndexedSeq[VolumeMount]

    Defines volume mounts that can be used by the streamlet to mount a volume in a local path.

  32. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped