pyflink.common.serialization.RowDataBulkWriterFactory# class RowDataBulkWriterFactory(j_bulk_writer_factory, row_type)[source]# 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()