Constructor Detail

• FlowMapperState

  FlowMapperState()

  Default constructor.

• FlowMapperState

  FlowMapperState(String flowId, Long expiryTime, FlowMapperStateType status)

  All-args constructor.

  Parameters:

  flowId - The key on which inbound events should be forwarded to on the flow event topic.

  expiryTime - The time at which this state will be set to null.

  status - The status of a session.

Method Detail

• getFlowId

   String getFlowId()

  Gets the value of the 'flowId' field.

• setFlowId

   void setFlowId(String value)

  Sets the value of the 'flowId' field. The key on which inbound events should be forwarded to on the flow event topic.

  Parameters:

  value - the value to set.

• getExpiryTime

   Long getExpiryTime()

  Gets the value of the 'expiryTime' field.

• setExpiryTime

   void setExpiryTime(Long value)

  Sets the value of the 'expiryTime' field. The time at which this state will be set to null. This is only set for closed sessions.

  Parameters:

  value - the value to set.

• getStatus

   FlowMapperStateType getStatus()

  Gets the value of the 'status' field.

• setStatus

   void setStatus(FlowMapperStateType value)

  Sets the value of the 'status' field. The status of a session. OPEN for ongoing sessions. CLOSING for sessions which are finished and the expiryTime has been set. ERROR for sessions which have closed due to error.

  Parameters:

  value - the value to set.

• getClassSchema

   static Schema getClassSchema()

• getEncoder

   static BinaryMessageEncoder<FlowMapperState> getEncoder()

  Return the BinaryMessageEncoder instance used by this class.

• getDecoder

   static BinaryMessageDecoder<FlowMapperState> getDecoder()

  Return the BinaryMessageDecoder instance used by this class.

• createDecoder

   static BinaryMessageDecoder<FlowMapperState> 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 FlowMapperState to a ByteBuffer.

• fromByteBuffer

   static FlowMapperState fromByteBuffer(ByteBuffer b)

  Deserializes a FlowMapperState 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$)

• put

   void put(int field$, Object value$)

• newBuilder

   static FlowMapperState.Builder newBuilder()

  Creates a new FlowMapperState RecordBuilder.

• newBuilder

   static FlowMapperState.Builder newBuilder(FlowMapperState.Builder other)

  Creates a new FlowMapperState RecordBuilder by copying an existing Builder.

  Parameters:

  other - The existing builder to copy.

• newBuilder

   static FlowMapperState.Builder newBuilder(FlowMapperState other)

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

  Parameters:

  other - The existing instance to copy.

• writeExternal

   void writeExternal(ObjectOutput out)

• readExternal

   void readExternal(ObjectInput in)

• customEncode

   void customEncode(Encoder out)

• customDecode

   void customDecode(ResolvingDecoder in)