Class Checkpoint.Builder

  • All Implemented Interfaces:
    org.apache.avro.data.RecordBuilder

    
    public class Checkpoint.Builder
    extends SpecificRecordBuilderBase<T> implements RecordBuilder<T>
                        

    RecordBuilder for Checkpoint instances.

    • Constructor Detail

    • Method Detail

      • getFlowId

         String getFlowId()

        Gets the value of the 'flowId' field. Internal, globally unique key for a flow instance.

      • setFlowId

         Checkpoint.Builder setFlowId(String value)

        Sets the value of the 'flowId' field. Internal, globally unique key for a flow instance.

        Parameters:
        value - The value of 'flowId'.
      • getInitialPlatformVersion

         int getInitialPlatformVersion()

        Gets the value of the 'initialPlatformVersion' field. The platform version at the time the flow was started.

      • setInitialPlatformVersion

         Checkpoint.Builder setInitialPlatformVersion(int value)

        Sets the value of the 'initialPlatformVersion' field. The platform version at the time the flow was started.

        Parameters:
        value - The value of 'initialPlatformVersion'.
      • getPipelineState

         PipelineState getPipelineState()

        Gets the value of the 'pipelineState' field. State required by the pipeline, e.g. to support retries.

      • getPipelineStateBuilder

         PipelineState.Builder getPipelineStateBuilder()

        Gets the Builder instance for the 'pipelineState' field and creates one if it doesn't exist yet. State required by the pipeline, e.g. to support retries.

      • getFlowState

         FlowState getFlowState()

        Gets the value of the 'flowState' field. Current flow execution state. Null if the flow has not yet been started, for example in the face of a retry-able error.

      • setFlowState

         Checkpoint.Builder setFlowState(FlowState value)

        Sets the value of the 'flowState' field. Current flow execution state. Null if the flow has not yet been started, for example in the face of a retry-able error.

        Parameters:
        value - The value of 'flowState'.
      • getFlowStateBuilder

         FlowState.Builder getFlowStateBuilder()

        Gets the Builder instance for the 'flowState' field and creates one if it doesn't exist yet. Current flow execution state. Null if the flow has not yet been started, for example in the face of a retry-able error.

      • setFlowStateBuilder

         Checkpoint.Builder setFlowStateBuilder(FlowState.Builder value)

        Sets the Builder instance for the 'flowState' field Current flow execution state. Null if the flow has not yet been started, for example in the face of a retry-able error.

        Parameters:
        value - The builder instance that must be set.
      • getFlowMetricsState

         String getFlowMetricsState()

        Gets the value of the 'flowMetricsState' field. Internal storage for recording flow metrics

      • setFlowMetricsState

         Checkpoint.Builder setFlowMetricsState(String value)

        Sets the value of the 'flowMetricsState' field. Internal storage for recording flow metrics

        Parameters:
        value - The value of 'flowMetricsState'.
      • hasFlowId

         boolean hasFlowId()

        Checks whether the 'flowId' field has been set. Internal, globally unique key for a flow instance.

      • hasInitialPlatformVersion

         boolean hasInitialPlatformVersion()

        Checks whether the 'initialPlatformVersion' field has been set. The platform version at the time the flow was started.

      • hasPipelineState

         boolean hasPipelineState()

        Checks whether the 'pipelineState' field has been set. State required by the pipeline, e.g. to support retries.

      • hasPipelineStateBuilder

         boolean hasPipelineStateBuilder()

        Checks whether the 'pipelineState' field has an active Builder instance State required by the pipeline, e.g. to support retries.

      • hasFlowState

         boolean hasFlowState()

        Checks whether the 'flowState' field has been set. Current flow execution state. Null if the flow has not yet been started, for example in the face of a retry-able error.

      • hasFlowStateBuilder

         boolean hasFlowStateBuilder()

        Checks whether the 'flowState' field has an active Builder instance Current flow execution state. Null if the flow has not yet been started, for example in the face of a retry-able error.

      • clearFlowState

         Checkpoint.Builder clearFlowState()

        Clears the value of the 'flowState' field. Current flow execution state. Null if the flow has not yet been started, for example in the face of a retry-able error.

      • hasFlowMetricsState

         boolean hasFlowMetricsState()

        Checks whether the 'flowMetricsState' field has been set. Internal storage for recording flow metrics

      • hasCustomState

         boolean hasCustomState()

        Checks whether the 'customState' field has been set. Internal storage for pipeline extensions.

      • hasCustomStateBuilder

         boolean hasCustomStateBuilder()

        Checks whether the 'customState' field has an active Builder instance Internal storage for pipeline extensions.