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

Interface CellValueCodec.ElementEncoder

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.ElementEncoder extends Serializable
Reads one element of an array as the bytes of a cell: a MAP family's key or value.

The array counterpart of CellValueCodec.FieldEncoder, writing the same bytes for the same value.

  • Method Summary

    Modifier and Type
    Method
    Description
    byte[]
    encode(org.apache.flink.table.data.ArrayData array, int pos)
    Encodes the element at pos.

  • Method Details

    • encode

      byte[] encode(org.apache.flink.table.data.ArrayData array, int pos)
      Encodes the element at pos.
      Parameters:
      array - the array to read
      pos - the element's position in it
      Returns:
      the cell bytes