Merge pull request #108 from george0st/changes

Yugabyte image & Cleaning

Author: george0st

nifi/cql-processor/dockers/yugabyte.sh

@@ -0,0 +1,6 @@
+#!/bin/sh
+
+docker network create testnet
+docker pull yugabytedb/yugabyte:2024.2.2.2-b2
+docker run --name yugabyte -p 9042:9042 -p 7199:7199 -d --network testnet yugabytedb/yugabyte:2024.2.2.2-b2
+

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

@@ -111,10 +111,10 @@ public class GetCQL extends AbstractProcessor {
             .expressionLanguageSupported(ExpressionLanguageScope.ENVIRONMENT)
             .build();
 
-//    Fetch Size
-//    Max Rows Per Flow File
-//    Ouptput Batch Size
-
+    //  TOBE: Future extension for addition properties
+    //    Fetch Size
+    //    Max Rows Per Flow File
+    //    Output Batch Size
 
     //  endregion All Properties
 

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

@@ -92,7 +92,7 @@ public class PutCQL extends AbstractProcessor {
     public static final PropertyDescriptor BATCH_SIZE = new PropertyDescriptor
             .Builder()
             .name("Batch Size")
-            .description("Size of batch for data ingest (in one operation).")
+            .description("Batch size for data ingest (in one operation).")
             .required(false)
             .defaultValue("200")
             .addValidator(StandardValidators.POSITIVE_LONG_VALIDATOR)
@@ -149,6 +149,10 @@ protected void init(final ProcessorInitializationContext context) {
         relationships = Set.of(REL_SUCCESS, REL_FAILURE);
     }
 
+    /**
+     * Mapping old and new properties for migration support
+     * @param config
+     */
     @Override
     public void migrateProperties(final PropertyConfiguration config) {
         //  support property migration

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/CsvCqlRead.java

@@ -36,7 +36,6 @@ private long executeCore(Writer writer) throws IOException {
         ResultSet rs;
 
         //  execute CQL
-        //rs = session.execute(selectStatementSql(session, ((SetupRead)setup).columnNames, ((SetupRead)setup).whereClause));
         rs = session.execute(selectStatementSql(session, (SetupRead)setup));
 
         //  get columns

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