Class AbstractBinarySinkFactory

    • Constructor Detail

      • AbstractBinarySinkFactory

        public AbstractBinarySinkFactory()
    • Method Detail

      • createSink

        public Sink createSink​(File outputDir,
                               String outputName)
                        throws IOException
        Create a Sink into a file.
        Specified by:
        createSink in interface SinkFactory
        Parameters:
        outputDir - the not-null output dir.
        outputName - the not-null output name.
        Returns:
        a Sink instance with a file as output.
        Throws:
        IOException - if any.