...

Author: george0st

nifi/cql-processor/nifi-cql-processors/src/main/java/org/george0st/processors/cql/processor/CqlProcessor.java

@@ -42,9 +42,4 @@ protected String whereItems(String[] whereItems){
         }
         return prepareItems.toString();
     }
-
-//    protected abstract long execute(String fileName) throws IOException;
-//    protected abstract long executeContent(String data) throws IOException;
-//    protected abstract long executeContent(byte[] byteArray) throws IOException;
-
 }

nifi/cql-processor/nifi-cql-processors/src/main/java/org/george0st/processors/cql/processor/CsvCqlWrite.java

@@ -23,6 +23,7 @@ public class CsvCqlWrite extends CqlProcessor {
 
     /**
      * Write core
+     *
      * @param reader        The reader (from different inputs)
      * @return              The amount of write rows
      * @throws IOException