pyflink.common.serialization.RowDataBulkWriterFactory

class RowDataBulkWriterFactory(j_bulk_writer_factory, row_type)

A ～BulkWriterFactory that receives records with RowData type. This is for indicating that Row record from Python must be first converted to RowData.

Methods

get_java_object()
get_row_type()