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

Interface CellValueCodec.FieldEncoder

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.FieldEncoder extends Serializable
Reads one field of a row as the bytes of a cell.

  • Method Summary

    Modifier and Type
    Method
    Description
    byte[]
    encode(org.apache.flink.table.data.RowData row, int pos)
    Encodes the field at pos.

  • Method Details

    • encode

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