Package org.voltdb.stream.api

Interface ExecutionContext.StreamExecutionContext

Enclosing interface:
ExecutionContext
public static interface ExecutionContext.StreamExecutionContext

  • Method Details

    • cancel

      default void cancel()

    • isCanceled

      default boolean isCanceled()

    • traceValue

      default void traceValue(String name, Object value)
      In test environment the named value will be collected so those named values can be later examined. In other environments this method has no effect.
      Parameters:
      name - of the trace
      value - to collect

    • trace

      void trace(String format, Object... params)
      A logging helper method. See String.format(String, Object...).
      Parameters:
      format - of the trace
      params - zero or more params that will be passed to formatting method

    • nanoTime

      long nanoTime()
      Returns:
      current nano time counted from Epoch

    • nextCommitResult

      CompletableCommitResult nextCommitResult()
      Creates and manages CompletableCommitResult. Such result is needed when commit is asynchronous, and we don't want to block execution of the thread that is calling commit method. The result will be invalidated after DEFAULT_ASYNC_COMMIT_TIMEOUT, which may result with halting stream processing. The default timeout can be modified in runtime by setting a property
      Returns:
      CompletableCommitResult

    • nextCommitResult

      CompletableCommitResult nextCommitResult(Duration awaitTimeout)
      Creates and manages CompletableCommitResult. Such result is needed when commit is asynchronous, and we don't want to block execution of the thread that is calling commit method. The result will be invalidated after DEFAULT_ASYNC_COMMIT_TIMEOUT, which may result with halting stream processing.
      Parameters:
      awaitTimeout - custom timeout to wait
      Returns:
      CompletableCommitResult

    • emit

      default void emit(String sinkName, Object message)
      Emits a message into named sink after receiving exception. A sink can be registered using ExceptionHandlerBuilder.addNamedSink(String, VoltStreamSink) and ExceptionHandlerBuilder.addNamedSink(String, VoltStreamSinkConfigurator).

      Note: This method is not designed to route messages between sinks, as those additional, named sinks cannot be guarded for failure.

      Parameters:
      sinkName -
      message -