DataWriterFactory

DataWriterFactory is a contract…​FIXME

package org.apache.spark.sql.sources.v2.writer;

public interface DataWriterFactory<T> extends Serializable {
  DataWriter<T> createDataWriter(int partitionId, int attemptNumber);
}
Note

DataWriterFactory is an Evolving contract that is evolving towards becoming a stable API, but is not a stable API yet and can change from one feature release to another release.

In other words, using the contract is as treading on thin ice.
Table 1. DataWriterFactory Contract
Method Description

createDataWriter

Gives the DataWriter for a partition ID and attempt number

Used when:

results matching ""

    No results matching ""