Class FlowStartContext
-
- All Implemented Interfaces:
-
java.io.Externalizable
,java.io.Serializable
,java.lang.Comparable
,org.apache.avro.generic.GenericContainer
,org.apache.avro.generic.GenericRecord
,org.apache.avro.generic.IndexedRecord
,org.apache.avro.specific.SpecificRecord
public class FlowStartContext extends SpecificRecordBase implements SpecificRecord
The Start Flow event represents the information needed to initiate a flow.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public class
FlowStartContext.Builder
RecordBuilder for FlowStartContext instances.
-
Field Summary
Fields Modifier and Type Field Description public final static Schema
SCHEMA$
public FlowKey
statusKey
public FlowInitiatorType
initiatorType
public String
requestId
public HoldingIdentity
identity
public String
cpiId
public HoldingIdentity
initiatedBy
public String
flowClassName
public String
startArgs
public KeyValuePairList
contextPlatformProperties
public Instant
createdTimestamp
-
Constructor Summary
Constructors Constructor Description FlowStartContext()
Default constructor. FlowStartContext(FlowKey statusKey, FlowInitiatorType initiatorType, String requestId, HoldingIdentity identity, String cpiId, HoldingIdentity initiatedBy, String flowClassName, String startArgs, KeyValuePairList contextPlatformProperties, Instant createdTimestamp)
All-args constructor.
-
Method Summary
Modifier and Type Method Description FlowKey
getStatusKey()
Gets the value of the 'statusKey' field. void
setStatusKey(FlowKey value)
Sets the value of the 'statusKey' field. FlowInitiatorType
getInitiatorType()
Gets the value of the 'initiatorType' field. void
setInitiatorType(FlowInitiatorType value)
Sets the value of the 'initiatorType' field. String
getRequestId()
Gets the value of the 'requestId' field. void
setRequestId(String value)
Sets the value of the 'requestId' field. HoldingIdentity
getIdentity()
Gets the value of the 'identity' field. void
setIdentity(HoldingIdentity value)
Sets the value of the 'identity' field. String
getCpiId()
Gets the value of the 'cpiId' field. void
setCpiId(String value)
Sets the value of the 'cpiId' field. HoldingIdentity
getInitiatedBy()
Gets the value of the 'initiatedBy' field. void
setInitiatedBy(HoldingIdentity value)
Sets the value of the 'initiatedBy' field. String
getFlowClassName()
Gets the value of the 'flowClassName' field. void
setFlowClassName(String value)
Sets the value of the 'flowClassName' field. String
getStartArgs()
Gets the value of the 'startArgs' field. void
setStartArgs(String value)
Sets the value of the 'startArgs' field. KeyValuePairList
getContextPlatformProperties()
Gets the value of the 'contextPlatformProperties' field. void
setContextPlatformProperties(KeyValuePairList value)
Sets the value of the 'contextPlatformProperties' field. Instant
getCreatedTimestamp()
Gets the value of the 'createdTimestamp' field. void
setCreatedTimestamp(Instant value)
Sets the value of the 'createdTimestamp' field. static Schema
getClassSchema()
static BinaryMessageEncoder<FlowStartContext>
getEncoder()
Return the BinaryMessageEncoder instance used by this class. static BinaryMessageDecoder<FlowStartContext>
getDecoder()
Return the BinaryMessageDecoder instance used by this class. static BinaryMessageDecoder<FlowStartContext>
createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore. ByteBuffer
toByteBuffer()
Serializes this FlowStartContext to a ByteBuffer. static FlowStartContext
fromByteBuffer(ByteBuffer b)
Deserializes a FlowStartContext from a ByteBuffer. SpecificData
getSpecificData()
Schema
getSchema()
Object
get(int field$)
Conversion<out Object>
getConversion(int field)
void
put(int field$, Object value$)
static FlowStartContext.Builder
newBuilder()
Creates a new FlowStartContext RecordBuilder. static FlowStartContext.Builder
newBuilder(FlowStartContext.Builder other)
Creates a new FlowStartContext RecordBuilder by copying an existing Builder. static FlowStartContext.Builder
newBuilder(FlowStartContext other)
Creates a new FlowStartContext RecordBuilder by copying an existing FlowStartContext instance. void
writeExternal(ObjectOutput out)
void
readExternal(ObjectInput in)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, customDecode, customEncode, equals, hashCode, toString
-
Methods inherited from class org.apache.avro.generic.GenericRecord
hasField
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Constructor Detail
-
FlowStartContext
FlowStartContext()
Default constructor.
-
FlowStartContext
FlowStartContext(FlowKey statusKey, FlowInitiatorType initiatorType, String requestId, HoldingIdentity identity, String cpiId, HoldingIdentity initiatedBy, String flowClassName, String startArgs, KeyValuePairList contextPlatformProperties, Instant createdTimestamp)
All-args constructor.- Parameters:
statusKey
- The unique ID for tracking the flow statusinitiatorType
- The type of initiator that started the flowrequestId
- The request ID assigned by the client or session that created the flow.identity
- The identity of the party executing the flow.cpiId
- The CPI ID for the package containing the flow.initiatedBy
- The identity of the party that initiated the flow.flowClassName
- The fully qualified class name of the flow.startArgs
- The body of the request provided when the flow was started if this flow was started via RPC.contextPlatformProperties
- A map of platform context properties made available to the flow which will also be propagated to sub flows, initiated flows and services, associating the entire end to end flow execution path with a notion of a context.createdTimestamp
- The date and time the flow was created.
-
-
Method Detail
-
getStatusKey
FlowKey getStatusKey()
Gets the value of the 'statusKey' field.
-
setStatusKey
void setStatusKey(FlowKey value)
Sets the value of the 'statusKey' field. The unique ID for tracking the flow 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.
-
getRequestId
String getRequestId()
Gets the value of the 'requestId' field.
-
setRequestId
void setRequestId(String value)
Sets the value of the 'requestId' field. The request ID assigned by the client or session that created the flow.
- Parameters:
value
- the value to set.
-
getIdentity
HoldingIdentity getIdentity()
Gets the value of the 'identity' field.
-
setIdentity
void setIdentity(HoldingIdentity value)
Sets the value of the 'identity' field. The identity of the party executing the flow.
- Parameters:
value
- the value to set.
-
setCpiId
void setCpiId(String value)
Sets the value of the 'cpiId' field. The CPI ID for the package containing the flow.
- Parameters:
value
- the value to set.
-
getInitiatedBy
HoldingIdentity getInitiatedBy()
Gets the value of the 'initiatedBy' field.
-
setInitiatedBy
void setInitiatedBy(HoldingIdentity value)
Sets the value of the 'initiatedBy' field. The identity of the party that initiated the flow.
- 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.
-
getStartArgs
String getStartArgs()
Gets the value of the 'startArgs' field.
-
setStartArgs
void setStartArgs(String value)
Sets the value of the 'startArgs' field. The body of the request provided when the flow was started if this flow was started via RPC. Null otherwise.
- Parameters:
value
- the value to set.
-
getContextPlatformProperties
KeyValuePairList getContextPlatformProperties()
Gets the value of the 'contextPlatformProperties' field.
-
setContextPlatformProperties
void setContextPlatformProperties(KeyValuePairList value)
Sets the value of the 'contextPlatformProperties' field. A map of platform context properties made available to the flow which will also be propagated to sub flows, initiated flows and services, associating the entire end to end flow execution path with a notion of a context. Only populated if this flow was started via RPC. Empty otherwise.
- 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 and time the flow was created.
- Parameters:
value
- the value to set.
-
getClassSchema
static Schema getClassSchema()
-
getEncoder
static BinaryMessageEncoder<FlowStartContext> getEncoder()
Return the BinaryMessageEncoder instance used by this class.
-
getDecoder
static BinaryMessageDecoder<FlowStartContext> getDecoder()
Return the BinaryMessageDecoder instance used by this class.
-
createDecoder
static BinaryMessageDecoder<FlowStartContext> 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 FlowStartContext to a ByteBuffer.
-
fromByteBuffer
static FlowStartContext fromByteBuffer(ByteBuffer b)
Deserializes a FlowStartContext from a ByteBuffer.
- Parameters:
b
- a byte buffer holding serialized data for an instance of this class
-
getSpecificData
SpecificData getSpecificData()
-
getSchema
Schema getSchema()
-
getConversion
Conversion<out Object> getConversion(int field)
-
newBuilder
static FlowStartContext.Builder newBuilder()
Creates a new FlowStartContext RecordBuilder.
-
newBuilder
static FlowStartContext.Builder newBuilder(FlowStartContext.Builder other)
Creates a new FlowStartContext RecordBuilder by copying an existing Builder.
- Parameters:
other
- The existing builder to copy.
-
newBuilder
static FlowStartContext.Builder newBuilder(FlowStartContext other)
Creates a new FlowStartContext RecordBuilder by copying an existing FlowStartContext instance.
- Parameters:
other
- The existing instance to copy.
-
writeExternal
void writeExternal(ObjectOutput out)
-
readExternal
void readExternal(ObjectInput in)
-
-
-
-