Class FlowTimeout

  • 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 FlowTimeout
    extends SpecificRecordBase implements SpecificRecord
                        

    Represents of a flow timeout instruction.

    • Constructor Detail

      • FlowTimeout

        FlowTimeout()
        Default constructor.
      • FlowTimeout

        FlowTimeout(String checkpointStateKey, Instant timeoutDateTime)
        All-args constructor.
        Parameters:
        checkpointStateKey - Key for the state record that is storing the checkpoint.
        timeoutDateTime - The new value for timeoutDateTime