def _encode_transformed_data_batch(
    data: Tuple[pa.RecordBatch, Dict[str, pa.Array]],
    coder: example_coder.RecordBatchToExamplesEncoder) -> List[bytes]:
  """Produces a list of serialized tf.Examples from transformed data."""
  # Drop unary pass-through features that are not relevant for this testing
  # framework.
  record_batch, _ = data
  return coder.encode(record_batch)
Produces a list of serialized tf.Examples from transformed data.
tensorflow_transform/beam/tft_unit.py