When running a pipeline and sinking a file check the extension of the file to be outputted to see that it matches the specified format.
Instead of using an IdentityInterface we could use a specialised interface that records the format of each output.
If it doesn't match, not sure whether to throw a warning or error. Probably an error
When running a pipeline and sinking a file check the extension of the file to be outputted to see that it matches the specified format.
Instead of using an IdentityInterface we could use a specialised interface that records the format of each output.
If it doesn't match, not sure whether to throw a warning or error. Probably an error