Package io.github.flink.gcp.connector.bigtable.table

Interface CellValueCodec.FieldDecoder

All Superinterfaces:
Serializable
Enclosing class:
CellValueCodec
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface @Internal public static interface CellValueCodec.FieldDecoder extends Serializable
Reads the bytes of a cell as one field of a row.

The mirror of CellValueCodec.FieldEncoder, returning Flink's internal data structures ( StringData, DecimalData, TimestampData, boxed primitives) so the result can be placed into a GenericRowData field directly.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    decode(byte[] value)
    Decodes the bytes of a cell.

  • Method Details

    • decode

      @Nullable Object decode(byte[] value)
      Decodes the bytes of a cell.
      Parameters:
      value - the cell bytes
      Returns:
      the field value, in Flink's internal data format