pyflink.datastream.connectors.file_system.StreamingFileSink

class StreamingFileSink(j_obj)

Sink that emits its input elements to FileSystem files within buckets. This is integrated with the checkpointing mechanism to provide exactly once semantics.

When creating the sink a basePath must be specified. The base directory contains one directory for every bucket. The bucket directories themselves contain several part files, with at least one for each parallel subtask of the sink which is writing data to that bucket. These part files contain the actual output data.

Methods

for_bulk_format(base_path, writer_factory)
for_row_format(base_path, encoder)
get_java_function()