pyflink.common.serialization.Encoder

class Encoder(j_encoder)

Encoder is used by the file sink to perform the actual writing of the incoming elements to the files in a bucket.

Methods

simple_string_encoder([charset_name])

A simple Encoder that uses toString() on the input elements and writes them to the output bucket file separated by newline.