class_docstr: Custom coder for Arrow record batches.
code: def encode(self, value: pa.RecordBatch) -> bytes:
      sink = pa.BufferOutputStream()
      writer = pa.ipc.new_stream(
          sink, value.schema, options=_ARROW_CODER_IPC_OPTIONS
      )
      writer.write_batch(value)
      writer.close()
      return sink.getvalue().to_pybytes()
  
file_path: data-validation/tensorflow_data_validation/types.py
imports: from typing import Callable, Dict, Iterable, List, Optional, Text, Tuple
  import apache_beam
  import numpy
  import pyarrow
  from tensorflow_data_validation.utils import path
label_desc: Use image node_id 1 for calling the _ArrowRecordBatchCoder obj's underlying member method code with example usage: obj.encode(value) and returns: sink