Method encode

tools/shuffle_tfrecords_beam.py:112–114

(self, value)

    return zlib.compress(in_stream.read_all(nested))

  def encode(self, value):
    assert isinstance(value, bytes), (value, type(value))
    return zlib.decompress(value)

  def decode(self, encoded):
    return zlib.compress(encoded)