Class StartFlow
-
- 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 StartFlow 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
StartFlow.Builder
RecordBuilder for StartFlow instances.
-
Field Summary
Fields Modifier and Type Field Description public final static Schema
SCHEMA$
public FlowStartContext
startContext
public String
flowStartArgs
-
Constructor Summary
Constructors Constructor Description StartFlow()
Default constructor. StartFlow(FlowStartContext startContext, String flowStartArgs)
All-args constructor.
-
Method Summary
Modifier and Type Method Description FlowStartContext
getStartContext()
Gets the value of the 'startContext' field. void
setStartContext(FlowStartContext value)
Sets the value of the 'startContext' field. String
getFlowStartArgs()
Gets the value of the 'flowStartArgs' field. void
setFlowStartArgs(String value)
Sets the value of the 'flowStartArgs' field. static Schema
getClassSchema()
static BinaryMessageEncoder<StartFlow>
getEncoder()
Return the BinaryMessageEncoder instance used by this class. static BinaryMessageDecoder<StartFlow>
getDecoder()
Return the BinaryMessageDecoder instance used by this class. static BinaryMessageDecoder<StartFlow>
createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore. ByteBuffer
toByteBuffer()
Serializes this StartFlow to a ByteBuffer. static StartFlow
fromByteBuffer(ByteBuffer b)
Deserializes a StartFlow from a ByteBuffer. SpecificData
getSpecificData()
Schema
getSchema()
Object
get(int field$)
void
put(int field$, Object value$)
static StartFlow.Builder
newBuilder()
Creates a new StartFlow RecordBuilder. static StartFlow.Builder
newBuilder(StartFlow.Builder other)
Creates a new StartFlow RecordBuilder by copying an existing Builder. static StartFlow.Builder
newBuilder(StartFlow other)
Creates a new StartFlow RecordBuilder by copying an existing StartFlow instance. void
writeExternal(ObjectOutput out)
void
readExternal(ObjectInput in)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, customDecode, customEncode, equals, getConversion, 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
-
StartFlow
StartFlow()
Default constructor.
-
StartFlow
StartFlow(FlowStartContext startContext, String flowStartArgs)
All-args constructor.- Parameters:
startContext
- The request ID assigned by the client that created the flow.flowStartArgs
- A client supplied string, passed to the flow when it is started.
-
-
Method Detail
-
getStartContext
FlowStartContext getStartContext()
Gets the value of the 'startContext' field.
-
setStartContext
void setStartContext(FlowStartContext value)
Sets the value of the 'startContext' field. The request ID assigned by the client that created the flow.
- Parameters:
value
- the value to set.
-
getFlowStartArgs
String getFlowStartArgs()
Gets the value of the 'flowStartArgs' field.
-
setFlowStartArgs
void setFlowStartArgs(String value)
Sets the value of the 'flowStartArgs' field. A client supplied string, passed to the flow when it is started. This is used by the client to pass data to a flow.
- Parameters:
value
- the value to set.
-
getClassSchema
static Schema getClassSchema()
-
getEncoder
static BinaryMessageEncoder<StartFlow> getEncoder()
Return the BinaryMessageEncoder instance used by this class.
-
getDecoder
static BinaryMessageDecoder<StartFlow> getDecoder()
Return the BinaryMessageDecoder instance used by this class.
-
createDecoder
static BinaryMessageDecoder<StartFlow> 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 StartFlow to a ByteBuffer.
-
fromByteBuffer
static StartFlow fromByteBuffer(ByteBuffer b)
Deserializes a StartFlow from a ByteBuffer.
- Parameters:
b
- a byte buffer holding serialized data for an instance of this class
-
getSpecificData
SpecificData getSpecificData()
-
getSchema
Schema getSchema()
-
newBuilder
static StartFlow.Builder newBuilder()
Creates a new StartFlow RecordBuilder.
-
newBuilder
static StartFlow.Builder newBuilder(StartFlow.Builder other)
Creates a new StartFlow RecordBuilder by copying an existing Builder.
- Parameters:
other
- The existing builder to copy.
-
newBuilder
static StartFlow.Builder newBuilder(StartFlow other)
Creates a new StartFlow RecordBuilder by copying an existing StartFlow instance.
- Parameters:
other
- The existing instance to copy.
-
writeExternal
void writeExternal(ObjectOutput out)
-
readExternal
void readExternal(ObjectInput in)
-
-
-
-