class_docstr: Encoder is used by the file sink to perform the actual writing of the
  incoming elements to the files in a bucket.
code: def __init__(self, j_encoder):
      self._j_encoder = j_encoder
  
imports: from pyflink.common.utils import JavaObjectWrapper
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 1 to create a new Encoder object from inherited base classes: object with example: obj = Encoder(j_encoder)