Class BaseTaskWriter<T>

    • Method Detail

      • setFailure

        protected void setFailure​(java.lang.Throwable throwable)
      • abort

        public void abort()
                   throws java.io.IOException
        Description copied from interface: TaskWriter
        Close the writer and delete the completed files if possible when aborting.
        Specified by:
        abort in interface TaskWriter<T>
        Throws:
        java.io.IOException - if any IO error happen.
      • complete

        public WriteResult complete()
                             throws java.io.IOException
        Description copied from interface: TaskWriter
        Close the writer and get the completed data and delete files.
        Specified by:
        complete in interface TaskWriter<T>
        Returns:
        the completed data and delete files of this task writer.
        Throws:
        java.io.IOException