Interface DefaultResumableRun.StateCodec<S>

Enclosing class:
DefaultResumableRun<S>

public static interface DefaultResumableRun.StateCodec<S>
Encodes / decodes the run's state to bytes for checkpoint persistence. Implementations choose the format (JSON, protobuf, Java serialization, …); the framework is opaque to it.
  • Method Summary

    Modifier and Type
    Method
    Description
    decode(byte[] bytes)
     
    byte[]
    encode(S state)
     
  • Method Details

    • encode

      byte[] encode(S state)
    • decode

      S decode(byte[] bytes)