Package org.voltdb.stream.api

Interface ExecutionContext

public interface ExecutionContext

  • Method Details

    • getPipelineName

      String getPipelineName()
      The name of the pipeline.
      Returns:
      name

    • observer

      org.voltdb.metrics.v1.api.Observer observer()
      Returns:
      thread local observer

    • threadSafeObserver

      org.voltdb.metrics.v1.api.Observer threadSafeObserver()
      Returns:
      observer that can be called from any thread as this implementation is synchronized

    • nextBatchId

      long nextBatchId()
      Method used by the framework, creates unique number that can identify batch of data.
      Returns:
      next unique batch id

    • configurator

      ExecutionContext.ConfigurationContext configurator()
      Operator configuration helper methods
      Returns:
      org.voltdb.stream.api.ExecutionContext.ConfigurationContext

    • execution

      ExecutionContext.StreamExecutionContext execution()
      Returns: