Class FlowState.Builder

  • All Implemented Interfaces:
    org.apache.avro.data.RecordBuilder

    
    public class FlowState.Builder
    extends SpecificRecordBuilderBase<T> implements RecordBuilder<T>
                        

    RecordBuilder for FlowState instances.

    • Constructor Detail

    • Method Detail

      • getFiber

         ByteBuffer getFiber()

        Gets the value of the 'fiber' field. Flow execution state, serialized at the point the flow was suspended.

      • setFiber

         FlowState.Builder setFiber(ByteBuffer value)

        Sets the value of the 'fiber' field. Flow execution state, serialized at the point the flow was suspended.

        Parameters:
        value - The value of 'fiber'.
      • getSessions

         List<SessionState> getSessions()

        Gets the value of the 'sessions' field. The current open sessions created by/for the executing flow.

      • getFlowStackItems

         List<FlowStackItem> getFlowStackItems()

        Gets the value of the 'flowStackItems' field. Used to track calls to sub-flows and their relationship to sessions.

      • getWaitingFor

         WaitingFor getWaitingFor()

        Gets the value of the 'waitingFor' field. What this flow requires in order to continue execution. For flows that have not started executing, null.

      • setWaitingFor

         FlowState.Builder setWaitingFor(WaitingFor value)

        Sets the value of the 'waitingFor' field. What this flow requires in order to continue execution. For flows that have not started executing, null.

        Parameters:
        value - The value of 'waitingFor'.
      • getWaitingForBuilder

         WaitingFor.Builder getWaitingForBuilder()

        Gets the Builder instance for the 'waitingFor' field and creates one if it doesn't exist yet. What this flow requires in order to continue execution. For flows that have not started executing, null.

      • setWaitingForBuilder

         FlowState.Builder setWaitingForBuilder(WaitingFor.Builder value)

        Sets the Builder instance for the 'waitingFor' field What this flow requires in order to continue execution. For flows that have not started executing, null.

        Parameters:
        value - The builder instance that must be set.
      • getSuspendCount

         int getSuspendCount()

        Gets the value of the 'suspendCount' field. Number of times the fiber has suspended.

      • setSuspendCount

         FlowState.Builder setSuspendCount(int value)

        Sets the value of the 'suspendCount' field. Number of times the fiber has suspended.

        Parameters:
        value - The value of 'suspendCount'.
      • getSuspendedOn

         String getSuspendedOn()

        Gets the value of the 'suspendedOn' field. What the previous request was that caused the flow to suspend. Null if no suspension has happened. Used for diagnostic purposes.

      • setSuspendedOn

         FlowState.Builder setSuspendedOn(String value)

        Sets the value of the 'suspendedOn' field. What the previous request was that caused the flow to suspend. Null if no suspension has happened. Used for diagnostic purposes.

        Parameters:
        value - The value of 'suspendedOn'.
      • hasFiber

         boolean hasFiber()

        Checks whether the 'fiber' field has been set. Flow execution state, serialized at the point the flow was suspended.

      • clearFiber

         FlowState.Builder clearFiber()

        Clears the value of the 'fiber' field. Flow execution state, serialized at the point the flow was suspended.

      • hasFlowStartContext

         boolean hasFlowStartContext()

        Checks whether the 'flowStartContext' field has been set. Context data captured when the flow was started.

      • hasFlowStartContextBuilder

         boolean hasFlowStartContextBuilder()

        Checks whether the 'flowStartContext' field has an active Builder instance Context data captured when the flow was started.

      • hasExternalEventState

         boolean hasExternalEventState()

        Checks whether the 'externalEventState' field has been set. Active external event request. Null if there are no requests in progress.

      • hasExternalEventStateBuilder

         boolean hasExternalEventStateBuilder()

        Checks whether the 'externalEventState' field has an active Builder instance Active external event request. Null if there are no requests in progress.

      • hasSessions

         boolean hasSessions()

        Checks whether the 'sessions' field has been set. The current open sessions created by/for the executing flow.

      • clearSessions

         FlowState.Builder clearSessions()

        Clears the value of the 'sessions' field. The current open sessions created by/for the executing flow.

      • hasFlowStackItems

         boolean hasFlowStackItems()

        Checks whether the 'flowStackItems' field has been set. Used to track calls to sub-flows and their relationship to sessions.

      • hasWaitingFor

         boolean hasWaitingFor()

        Checks whether the 'waitingFor' field has been set. What this flow requires in order to continue execution. For flows that have not started executing, null.

      • hasWaitingForBuilder

         boolean hasWaitingForBuilder()

        Checks whether the 'waitingFor' field has an active Builder instance What this flow requires in order to continue execution. For flows that have not started executing, null.

      • clearWaitingFor

         FlowState.Builder clearWaitingFor()

        Clears the value of the 'waitingFor' field. What this flow requires in order to continue execution. For flows that have not started executing, null.

      • hasSuspendCount

         boolean hasSuspendCount()

        Checks whether the 'suspendCount' field has been set. Number of times the fiber has suspended.

      • hasSuspendedOn

         boolean hasSuspendedOn()

        Checks whether the 'suspendedOn' field has been set. What the previous request was that caused the flow to suspend. Null if no suspension has happened. Used for diagnostic purposes.

      • clearSuspendedOn

         FlowState.Builder clearSuspendedOn()

        Clears the value of the 'suspendedOn' field. What the previous request was that caused the flow to suspend. Null if no suspension has happened. Used for diagnostic purposes.