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


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

RecordBuilder for PipelineState instances.

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description

Field Summary

Fields
Modifier and Type	Field	Description
`public RetryState`	`retryState`
`public RetryState.Builder`	`retryStateBuilder`
`public int`	`maxFlowSleepDuration`
`public ExceptionEnvelope`	`pendingPlatformError`
`public ExceptionEnvelope.Builder`	`pendingPlatformErrorBuilder`
`public List<SecureHash>`	`cpkFileHashes`

Constructor Summary

Constructors
Constructor	Description

Enum Constant Summary

Enum Constants
Enum Constant	Description

Method Summary

Modifier and Type	Method	Description
`RetryState`	`getRetryState()`	Gets the value of the 'retryState' field.
`PipelineState.Builder`	`setRetryState(RetryState value)`	Sets the value of the 'retryState' field.
`RetryState.Builder`	`getRetryStateBuilder()`	Gets the Builder instance for the 'retryState' field and creates one if it doesn't exist yet.
`PipelineState.Builder`	`setRetryStateBuilder(RetryState.Builder value)`	Sets the Builder instance for the 'retryState' field Optional retry information for a failed flow event.
`int`	`getMaxFlowSleepDuration()`	Gets the value of the 'maxFlowSleepDuration' field.
`PipelineState.Builder`	`setMaxFlowSleepDuration(int value)`	Sets the value of the 'maxFlowSleepDuration' field.
`ExceptionEnvelope`	`getPendingPlatformError()`	Gets the value of the 'pendingPlatformError' field.
`PipelineState.Builder`	`setPendingPlatformError(ExceptionEnvelope value)`	Sets the value of the 'pendingPlatformError' field.
`ExceptionEnvelope.Builder`	`getPendingPlatformErrorBuilder()`	Gets the Builder instance for the 'pendingPlatformError' field and creates one if it doesn't exist yet.
`PipelineState.Builder`	`setPendingPlatformErrorBuilder(ExceptionEnvelope.Builder value)`	Sets the Builder instance for the 'pendingPlatformError' field Used for platform generated errors reported back to user code.
`List<SecureHash>`	`getCpkFileHashes()`	Gets the value of the 'cpkFileHashes' field.
`PipelineState.Builder`	`setCpkFileHashes(List<SecureHash> value)`	Sets the value of the 'cpkFileHashes' field.
`boolean`	`hasRetryState()`	Checks whether the 'retryState' field has been set.
`boolean`	`hasRetryStateBuilder()`	Checks whether the 'retryState' field has an active Builder instance Optional retry information for a failed flow event.
`PipelineState.Builder`	`clearRetryState()`	Clears the value of the 'retryState' field.
`boolean`	`hasMaxFlowSleepDuration()`	Checks whether the 'maxFlowSleepDuration' field has been set.
`PipelineState.Builder`	`clearMaxFlowSleepDuration()`	Clears the value of the 'maxFlowSleepDuration' field.
`boolean`	`hasPendingPlatformError()`	Checks whether the 'pendingPlatformError' field has been set.
`boolean`	`hasPendingPlatformErrorBuilder()`	Checks whether the 'pendingPlatformError' field has an active Builder instance Used for platform generated errors reported back to user code.
`PipelineState.Builder`	`clearPendingPlatformError()`	Clears the value of the 'pendingPlatformError' field.
`boolean`	`hasCpkFileHashes()`	Checks whether the 'cpkFileHashes' field has been set.
`PipelineState.Builder`	`clearCpkFileHashes()`	Clears the value of the 'cpkFileHashes' field.
`PipelineState`	`build()`

Methods inherited from class org.apache.avro.data.RecordBuilderBase
equals, hashCode
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
- Method Detail
  - getRetryState
```
 RetryState getRetryState()
```
    Gets the value of the 'retryState' field. Optional retry information for a failed flow event. Setting this field marks the flow as retrying.
  - setRetryState
```
 PipelineState.Builder setRetryState(RetryState value)
```
    Sets the value of the 'retryState' field. Optional retry information for a failed flow event. Setting this field marks the flow as retrying.
    
    Parameters:
    
    value - The value of 'retryState'.
  - getRetryStateBuilder
```
 RetryState.Builder getRetryStateBuilder()
```
    Gets the Builder instance for the 'retryState' field and creates one if it doesn't exist yet. Optional retry information for a failed flow event. Setting this field marks the flow as retrying.
  - setRetryStateBuilder
```
 PipelineState.Builder setRetryStateBuilder(RetryState.Builder value)
```
    Sets the Builder instance for the 'retryState' field Optional retry information for a failed flow event. Setting this field marks the flow as retrying.
    
    Parameters:
    
    value - The builder instance that must be set.
  - getMaxFlowSleepDuration
```
 int getMaxFlowSleepDuration()
```
    Gets the value of the 'maxFlowSleepDuration' field. The maximum time a flow can sleep, before a Wakeup event is generated (milliseconds)
  - setMaxFlowSleepDuration
```
 PipelineState.Builder setMaxFlowSleepDuration(int value)
```
    Sets the value of the 'maxFlowSleepDuration' field. The maximum time a flow can sleep, before a Wakeup event is generated (milliseconds)
    
    Parameters:
    
    value - The value of 'maxFlowSleepDuration'.
  - getPendingPlatformError
```
 ExceptionEnvelope getPendingPlatformError()
```
    Gets the value of the 'pendingPlatformError' field. Used for platform generated errors reported back to user code.
  - setPendingPlatformError
```
 PipelineState.Builder setPendingPlatformError(ExceptionEnvelope value)
```
    Sets the value of the 'pendingPlatformError' field. Used for platform generated errors reported back to user code.
    
    Parameters:
    
    value - The value of 'pendingPlatformError'.
  - getPendingPlatformErrorBuilder
```
 ExceptionEnvelope.Builder getPendingPlatformErrorBuilder()
```
    Gets the Builder instance for the 'pendingPlatformError' field and creates one if it doesn't exist yet. Used for platform generated errors reported back to user code.
  - setPendingPlatformErrorBuilder
```
 PipelineState.Builder setPendingPlatformErrorBuilder(ExceptionEnvelope.Builder value)
```
    Sets the Builder instance for the 'pendingPlatformError' field Used for platform generated errors reported back to user code.
    
    Parameters:
    
    value - The builder instance that must be set.
  - getCpkFileHashes
```
 List<SecureHash> getCpkFileHashes()
```
    Gets the value of the 'cpkFileHashes' field. Array of stored cpkFileHashes from the Virtual Node.
  - setCpkFileHashes
```
 PipelineState.Builder setCpkFileHashes(List<SecureHash> value)
```
    Sets the value of the 'cpkFileHashes' field. Array of stored cpkFileHashes from the Virtual Node.
    
    Parameters:
    
    value - The value of 'cpkFileHashes'.
  - hasRetryState
```
 boolean hasRetryState()
```
    Checks whether the 'retryState' field has been set. Optional retry information for a failed flow event. Setting this field marks the flow as retrying.
  - hasRetryStateBuilder
```
 boolean hasRetryStateBuilder()
```
    Checks whether the 'retryState' field has an active Builder instance Optional retry information for a failed flow event. Setting this field marks the flow as retrying.
  - clearRetryState
```
 PipelineState.Builder clearRetryState()
```
    Clears the value of the 'retryState' field. Optional retry information for a failed flow event. Setting this field marks the flow as retrying.
  - hasMaxFlowSleepDuration
```
 boolean hasMaxFlowSleepDuration()
```
    Checks whether the 'maxFlowSleepDuration' field has been set. The maximum time a flow can sleep, before a Wakeup event is generated (milliseconds)
  - clearMaxFlowSleepDuration
```
 PipelineState.Builder clearMaxFlowSleepDuration()
```
    Clears the value of the 'maxFlowSleepDuration' field. The maximum time a flow can sleep, before a Wakeup event is generated (milliseconds)
  - hasPendingPlatformError
```
 boolean hasPendingPlatformError()
```
    Checks whether the 'pendingPlatformError' field has been set. Used for platform generated errors reported back to user code.
  - hasPendingPlatformErrorBuilder
```
 boolean hasPendingPlatformErrorBuilder()
```
    Checks whether the 'pendingPlatformError' field has an active Builder instance Used for platform generated errors reported back to user code.
  - clearPendingPlatformError
```
 PipelineState.Builder clearPendingPlatformError()
```
    Clears the value of the 'pendingPlatformError' field. Used for platform generated errors reported back to user code.
  - hasCpkFileHashes
```
 boolean hasCpkFileHashes()
```
    Checks whether the 'cpkFileHashes' field has been set. Array of stored cpkFileHashes from the Virtual Node.
  - clearCpkFileHashes
```
 PipelineState.Builder clearCpkFileHashes()
```
    Clears the value of the 'cpkFileHashes' field. Array of stored cpkFileHashes from the Virtual Node.
  - build
```
 PipelineState build()
```

Class PipelineState.Builder

Nested Class Summary

Field Summary

Constructor Summary

Enum Constant Summary

Method Summary

Methods inherited from class org.apache.avro.data.RecordBuilderBase

Methods inherited from class java.lang.Object

Constructor Detail

Method Detail

getRetryState

setRetryState

getRetryStateBuilder

setRetryStateBuilder

getMaxFlowSleepDuration

setMaxFlowSleepDuration

getPendingPlatformError

setPendingPlatformError

getPendingPlatformErrorBuilder

setPendingPlatformErrorBuilder

getCpkFileHashes

setCpkFileHashes

hasRetryState

hasRetryStateBuilder

clearRetryState

hasMaxFlowSleepDuration

clearMaxFlowSleepDuration

hasPendingPlatformError

hasPendingPlatformErrorBuilder

clearPendingPlatformError

hasCpkFileHashes

clearCpkFileHashes

build