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.
-
-
Field Summary
Fields Modifier and Type Field Description public String
flowId
public int
initialPlatformVersion
public PipelineState
pipelineState
public PipelineState.Builder
pipelineStateBuilder
public FlowState
flowState
public FlowState.Builder
flowStateBuilder
public String
flowMetricsState
public KeyValuePairList
customState
public KeyValuePairList.Builder
customStateBuilder
-
Method Summary
Modifier and Type Method Description String
getFlowId()
Gets the value of the 'flowId' field. Checkpoint.Builder
setFlowId(String value)
Sets the value of the 'flowId' field. int
getInitialPlatformVersion()
Gets the value of the 'initialPlatformVersion' field. Checkpoint.Builder
setInitialPlatformVersion(int value)
Sets the value of the 'initialPlatformVersion' field. PipelineState
getPipelineState()
Gets the value of the 'pipelineState' field. Checkpoint.Builder
setPipelineState(PipelineState value)
Sets the value of the 'pipelineState' field. PipelineState.Builder
getPipelineStateBuilder()
Gets the Builder instance for the 'pipelineState' field and creates one if it doesn't exist yet. Checkpoint.Builder
setPipelineStateBuilder(PipelineState.Builder value)
Sets the Builder instance for the 'pipelineState' field State required by the pipeline, e.g. FlowState
getFlowState()
Gets the value of the 'flowState' field. Checkpoint.Builder
setFlowState(FlowState value)
Sets the value of the 'flowState' field. FlowState.Builder
getFlowStateBuilder()
Gets the Builder instance for the 'flowState' field and creates one if it doesn't exist yet. Checkpoint.Builder
setFlowStateBuilder(FlowState.Builder value)
Sets the Builder instance for the 'flowState' field Current flow execution state. String
getFlowMetricsState()
Gets the value of the 'flowMetricsState' field. Checkpoint.Builder
setFlowMetricsState(String value)
Sets the value of the 'flowMetricsState' field. KeyValuePairList
getCustomState()
Gets the value of the 'customState' field. Checkpoint.Builder
setCustomState(KeyValuePairList value)
Sets the value of the 'customState' field. KeyValuePairList.Builder
getCustomStateBuilder()
Gets the Builder instance for the 'customState' field and creates one if it doesn't exist yet. Checkpoint.Builder
setCustomStateBuilder(KeyValuePairList.Builder value)
Sets the Builder instance for the 'customState' field Internal storage for pipeline extensions. boolean
hasFlowId()
Checks whether the 'flowId' field has been set. Checkpoint.Builder
clearFlowId()
Clears the value of the 'flowId' field. boolean
hasInitialPlatformVersion()
Checks whether the 'initialPlatformVersion' field has been set. Checkpoint.Builder
clearInitialPlatformVersion()
Clears the value of the 'initialPlatformVersion' field. boolean
hasPipelineState()
Checks whether the 'pipelineState' field has been set. boolean
hasPipelineStateBuilder()
Checks whether the 'pipelineState' field has an active Builder instance State required by the pipeline, e.g. Checkpoint.Builder
clearPipelineState()
Clears the value of the 'pipelineState' field. boolean
hasFlowState()
Checks whether the 'flowState' field has been set. boolean
hasFlowStateBuilder()
Checks whether the 'flowState' field has an active Builder instance Current flow execution state. Checkpoint.Builder
clearFlowState()
Clears the value of the 'flowState' field. boolean
hasFlowMetricsState()
Checks whether the 'flowMetricsState' field has been set. Checkpoint.Builder
clearFlowMetricsState()
Clears the value of the 'flowMetricsState' field. boolean
hasCustomState()
Checks whether the 'customState' field has been set. boolean
hasCustomStateBuilder()
Checks whether the 'customState' field has an active Builder instance Internal storage for pipeline extensions. Checkpoint.Builder
clearCustomState()
Clears the value of the 'customState' field. Checkpoint
build()
-
-
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.
-
setPipelineState
Checkpoint.Builder setPipelineState(PipelineState value)
Sets the value of the 'pipelineState' field. State required by the pipeline, e.g. to support retries.
- Parameters:
value
- The value of 'pipelineState'.
-
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.
-
setPipelineStateBuilder
Checkpoint.Builder setPipelineStateBuilder(PipelineState.Builder value)
Sets the Builder instance for the 'pipelineState' field State required by the pipeline, e.g. to support retries.
- Parameters:
value
- The builder instance that must be set.
-
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'.
-
getCustomState
KeyValuePairList getCustomState()
Gets the value of the 'customState' field. Internal storage for pipeline extensions.
-
setCustomState
Checkpoint.Builder setCustomState(KeyValuePairList value)
Sets the value of the 'customState' field. Internal storage for pipeline extensions.
- Parameters:
value
- The value of 'customState'.
-
getCustomStateBuilder
KeyValuePairList.Builder getCustomStateBuilder()
Gets the Builder instance for the 'customState' field and creates one if it doesn't exist yet. Internal storage for pipeline extensions.
-
setCustomStateBuilder
Checkpoint.Builder setCustomStateBuilder(KeyValuePairList.Builder value)
Sets the Builder instance for the 'customState' field Internal storage for pipeline extensions.
- Parameters:
value
- The builder instance that must be set.
-
hasFlowId
boolean hasFlowId()
Checks whether the 'flowId' field has been set. Internal, globally unique key for a flow instance.
-
clearFlowId
Checkpoint.Builder clearFlowId()
Clears the value of the 'flowId' field. 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.
-
clearInitialPlatformVersion
Checkpoint.Builder clearInitialPlatformVersion()
Clears the value of the 'initialPlatformVersion' field. 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.
-
clearPipelineState
Checkpoint.Builder clearPipelineState()
Clears the value of the 'pipelineState' field. 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
-
clearFlowMetricsState
Checkpoint.Builder clearFlowMetricsState()
Clears the value of the 'flowMetricsState' field. 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.
-
clearCustomState
Checkpoint.Builder clearCustomState()
Clears the value of the 'customState' field. Internal storage for pipeline extensions.
-
build
Checkpoint build()
-
-
-
-