class_docstr: Bridge between Beam coder and Flink coder for the top-level LengthPrefixCoder.
class_docstr_tok: ["Bridge","between","Beam","coder","and","Flink","coder","for","the","top-level","LengthPrefixCoder","."]
code: def encode_to_stream(
      self, value, out_stream: create_OutputStream, nested
  ):
      self._output_stream.reset_output_stream(out_stream)
  
      self._value_coder.encode_to_stream(
          value, self._data_output_stream
      )
      self._output_stream.write(self._data_output_stream.get())
      self._data_output_stream.clear()
  
imports: from typing import Any
  from apache_beam.coders.coder_impl import StreamCoderImpl, create_InputStream, create_OutputStream
  from pyflink.fn_execution.stream_slow import OutputStream
  from pyflink.fn_execution.beam.beam_stream_slow import BeamInputStream, BeamTimeBasedOutputStream
label_desc: Use image node_id 2 for calling the FlinkLengthPrefixCoderBeamWrapper obj's underlying member method code with example usage: obj.encode_to_stream(value, out_stream, nested) without return types