Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
Not applicable
Description
FileBasedSink has this function:
/**
* Returns a coder for the writer result type.
*/
public Coder<WriteT> getWriterResultCoder() {
return null;
}
It returns null by default, but in practice if this happens then building the pipeline will crash with a NullPointerException. Now that we can make backward-incompatible changes, just make it abstract and force implementations to add this method. (All existing implementations override it already.)