class_docstr: Provides access to read and write statistics proto to record files.
class_docstr_tok: ["Provides","access","to","read","and","write","statistics","proto","to","record","files","."]
docstr: Gets a beam IO sink for writing sharded statistics protos.
docstr_tok: ["Gets","a","beam","IO","sink","for","writing","sharded","statistics","protos","."]
code: def record_sink_impl(
      self, output_path_prefix: str
  ) -> beam.PTransform:
      """Gets a beam IO sink for writing sharded statistics protos."""
      raise NotImplementedError
  
imports: from typing import Callable, Iterable, Iterator, Optional, Type, TypeVar
  import apache_beam
  import tensorflow
  from google.protobuf import message
  from tensorflow_metadata.proto.v0 import statistics_pb2
label_desc: Use image node_id 1 for calling the StatisticsIOProvider obj's underlying member method code with example usage: obj.record_sink_impl(output_path_prefix) without return types