Constructor Detail

• FlowStatus

  FlowStatus()

  Default constructor.

• FlowStatus

  FlowStatus(FlowKey key, FlowInitiatorType initiatorType, String flowId, String flowClassName, FlowStates flowStatus, String result, ExceptionEnvelope error, String processingTerminatedReason, Instant createdTimestamp, Instant lastUpdateTimestamp)

  All-args constructor.

  Parameters:

  key - The unique ID for the status

  initiatorType - The type of initiator that started the flow

  flowId - The unique flow ID

  flowClassName - The fully qualified class name of the flow

  flowStatus - The current processing status of a flow

  result - Optional result, this contains the result from the flow will only be set if the flow status is 'COMPLETED'

  error - Optional error message, this will be set if the flow status is 'FAILED'

  processingTerminatedReason - Optional message indicating reasoning why processing a flow has been terminated.

  createdTimestamp - The date the flow was created.

  lastUpdateTimestamp - The date and time this status update was published.

Method Detail

• getKey

   FlowKey getKey()

  Gets the value of the 'key' field.

• setKey

   void setKey(FlowKey value)

  Sets the value of the 'key' field. The unique ID for the status

  Parameters:

  value - the value to set.

• getInitiatorType

   FlowInitiatorType getInitiatorType()

  Gets the value of the 'initiatorType' field.

• setInitiatorType

   void setInitiatorType(FlowInitiatorType value)

  Sets the value of the 'initiatorType' field. The type of initiator that started the flow

  Parameters:

  value - the value to set.

• getFlowId

   String getFlowId()

  Gets the value of the 'flowId' field.

• setFlowId

   void setFlowId(String value)

  Sets the value of the 'flowId' field. The unique flow ID

  Parameters:

  value - the value to set.

• getFlowClassName

   String getFlowClassName()

  Gets the value of the 'flowClassName' field.

• setFlowClassName

   void setFlowClassName(String value)

  Sets the value of the 'flowClassName' field. The fully qualified class name of the flow

  Parameters:

  value - the value to set.

• getFlowStatus

   FlowStates getFlowStatus()

  Gets the value of the 'flowStatus' field.

• setFlowStatus

   void setFlowStatus(FlowStates value)

  Sets the value of the 'flowStatus' field. The current processing status of a flow

  Parameters:

  value - the value to set.

• getResult

   String getResult()

  Gets the value of the 'result' field.

• setResult

   void setResult(String value)

  Sets the value of the 'result' field. Optional result, this contains the result from the flow will only be set if the flow status is 'COMPLETED'

  Parameters:

  value - the value to set.

• getError

   ExceptionEnvelope getError()

  Gets the value of the 'error' field.

• setError

   void setError(ExceptionEnvelope value)

  Sets the value of the 'error' field. Optional error message, this will be set if the flow status is 'FAILED'

  Parameters:

  value - the value to set.

• getProcessingTerminatedReason

   String getProcessingTerminatedReason()

  Gets the value of the 'processingTerminatedReason' field.

• setProcessingTerminatedReason

   void setProcessingTerminatedReason(String value)

  Sets the value of the 'processingTerminatedReason' field. Optional message indicating reasoning why processing a flow has been terminated.

  Parameters:

  value - the value to set.

• getCreatedTimestamp

   Instant getCreatedTimestamp()

  Gets the value of the 'createdTimestamp' field.

• setCreatedTimestamp

   void setCreatedTimestamp(Instant value)

  Sets the value of the 'createdTimestamp' field. The date the flow was created.

  Parameters:

  value - the value to set.

• getLastUpdateTimestamp

   Instant getLastUpdateTimestamp()

  Gets the value of the 'lastUpdateTimestamp' field.

• setLastUpdateTimestamp

   void setLastUpdateTimestamp(Instant value)

  Sets the value of the 'lastUpdateTimestamp' field. The date and time this status update was published.

  Parameters:

  value - the value to set.

• getClassSchema

   static Schema getClassSchema()

• getEncoder

   static BinaryMessageEncoder<FlowStatus> getEncoder()

  Return the BinaryMessageEncoder instance used by this class.

• getDecoder

   static BinaryMessageDecoder<FlowStatus> getDecoder()

  Return the BinaryMessageDecoder instance used by this class.

• createDecoder

   static BinaryMessageDecoder<FlowStatus> createDecoder(SchemaStore resolver)

  Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.

  Parameters:

  resolver - a SchemaStore used to find schemas by fingerprint

• toByteBuffer

   ByteBuffer toByteBuffer()

  Serializes this FlowStatus to a ByteBuffer.

• fromByteBuffer

   static FlowStatus fromByteBuffer(ByteBuffer b)

  Deserializes a FlowStatus from a ByteBuffer.

  Parameters:

  b - a byte buffer holding serialized data for an instance of this class

• getSpecificData

   SpecificData getSpecificData()

• getSchema

   Schema getSchema()

• get

   Object get(int field$)

• getConversion

   Conversion<out Object> getConversion(int field)

• put

   void put(int field$, Object value$)

• newBuilder

   static FlowStatus.Builder newBuilder()

  Creates a new FlowStatus RecordBuilder.

• newBuilder

   static FlowStatus.Builder newBuilder(FlowStatus.Builder other)

  Creates a new FlowStatus RecordBuilder by copying an existing Builder.

  Parameters:

  other - The existing builder to copy.

• newBuilder

   static FlowStatus.Builder newBuilder(FlowStatus other)

  Creates a new FlowStatus RecordBuilder by copying an existing FlowStatus instance.

  Parameters:

  other - The existing instance to copy.

• writeExternal

   void writeExternal(ObjectOutput out)

• readExternal

   void readExternal(ObjectInput in)