class_docstr: PulsarWriter
class_docstr_tok: ["PulsarWriter"]
docstr: Flush the queued messages, it will wait async write operations completed.
docstr_tok: ["Flush","the","queued","messages",",","it","will","wait","async","write","operations","completed","."]
code: def flush(self):
      """Flush the queued messages, it will wait async write operations completed."""
      return core_ops.io_pulsar_writable_flush(self._resource)
  
imports: import tensorflow
  from tensorflow_io.python.ops import core_ops
label_desc: Use image node_id 3 for calling the PulsarWriter obj's underlying member method code with example usage: obj.flush() and returns: core_ops