public final class BeamStateTranslator extends Object implements StateTranslator
StateTranslator
for Beam.
It provides the translation between the state of job and Beam pipeline.Constructor and Description |
---|
BeamStateTranslator() |
Modifier and Type | Method and Description |
---|---|
Enum |
translateState(JobState.State jobState)
Translate a job state of coral to a corresponding Beam state.
|
public Enum translateState(JobState.State jobState)
translateState
in interface StateTranslator
jobState
- to translate.Copyright © 2018. All rights reserved.