-
Type:
Improvement
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: Not applicable
-
Fix Version/s: 0.4.0
-
Component/s: sdk-java-core
-
Labels:
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.)