class_docstr: Custom coder for Arrow record batches.
code: def decode(self, encoded: bytes) -> pa.RecordBatch:
      reader = pa.ipc.open_stream(encoded)
      result = reader.read_next_batch()
      try:
          reader.read_next_batch()
      except StopIteration:
          pass
      else:
          raise ValueError(
              "Expected only one RecordBatch in the stream."
          )
      return result
  
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 2 for calling the _ArrowRecordBatchCoder obj's underlying member method code with example usage: obj.decode(encoded) and returns: result