Class LocalBulkWriter

  • All Implemented Interfaces:
    java.lang.AutoCloseable
    Direct Known Subclasses:
    RemoteBulkWriter

    public class LocalBulkWriter
    extends BulkWriter
    implements java.lang.AutoCloseable
    • Constructor Detail

      • LocalBulkWriter

        public LocalBulkWriter​(LocalBulkWriterParam bulkWriterParam)
                        throws java.io.IOException
        Throws:
        java.io.IOException
    • Method Detail

      • appendRow

        public void appendRow​(com.alibaba.fastjson.JSONObject rowData)
                       throws java.io.IOException,
                              java.lang.InterruptedException
        Overrides:
        appendRow in class BulkWriter
        Throws:
        java.io.IOException
        java.lang.InterruptedException
      • commit

        public void commit​(boolean async)
                    throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • getBatchFiles

        public java.util.List<java.util.List<java.lang.String>> getBatchFiles()
      • close

        public void close()
                   throws java.lang.Exception
        Specified by:
        close in interface java.lang.AutoCloseable
        Throws:
        java.lang.Exception