working version with sync queue wrapper (without multiple watermark drains in drainer)
Showing
- myprocessor/cloud-processor/nifi-cloud-nar/target/classes/META-INF/bundled-dependencies/nifi-cloud-processors-1.0-SNAPSHOT.jar 0 additions, 0 deletions...ndled-dependencies/nifi-cloud-processors-1.0-SNAPSHOT.jar
- myprocessor/cloud-processor/nifi-cloud-nar/target/maven-archiver/pom.properties 1 addition, 1 deletion...essor/nifi-cloud-nar/target/maven-archiver/pom.properties
- myprocessor/cloud-processor/nifi-cloud-nar/target/nifi-cloud-nar-1.0-SNAPSHOT.nar 0 additions, 0 deletions...sor/nifi-cloud-nar/target/nifi-cloud-nar-1.0-SNAPSHOT.nar
- myprocessor/cloud-processor/nifi-cloud-processors/target/nifi-cloud-processors-1.0-SNAPSHOT.jar 0 additions, 0 deletions...-processors/target/nifi-cloud-processors-1.0-SNAPSHOT.jar
- myprocessor/cloud-processor/nifi-cloud-processors/target/surefire-reports/TEST-com.jarvis.processors.cloud.MyProcessorTest.xml 4 additions, 4 deletions...orts/TEST-com.jarvis.processors.cloud.MyProcessorTest.xml
- myprocessor/cloud-processor/nifi-cloud-processors/target/surefire-reports/com.jarvis.processors.cloud.MyProcessorTest.txt 1 addition, 1 deletion...e-reports/com.jarvis.processors.cloud.MyProcessorTest.txt
- myprocessor/edge-processor/nifi-edge-nar/target/classes/META-INF/bundled-dependencies/nifi-edge-processors-1.0-SNAPSHOT.jar 0 additions, 0 deletions...undled-dependencies/nifi-edge-processors-1.0-SNAPSHOT.jar
- myprocessor/edge-processor/nifi-edge-nar/target/maven-archiver/pom.properties 1 addition, 1 deletion...cessor/nifi-edge-nar/target/maven-archiver/pom.properties
- myprocessor/edge-processor/nifi-edge-nar/target/nifi-edge-nar-1.0-SNAPSHOT.nar 0 additions, 0 deletions...essor/nifi-edge-nar/target/nifi-edge-nar-1.0-SNAPSHOT.nar
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/CustomMapOperator.java 3 additions, 2 deletions...in/java/com/jarvis/processors/edge/CustomMapOperator.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/CustomOperator.java 4 additions, 4 deletions.../main/java/com/jarvis/processors/edge/CustomOperator.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/MyProcessor.java 9 additions, 2 deletions...src/main/java/com/jarvis/processors/edge/MyProcessor.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/OutputQueueWrapper.java 2 additions, 1 deletion...n/java/com/jarvis/processors/edge/OutputQueueWrapper.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/QueueWrapper.java 71 additions, 25 deletions...rc/main/java/com/jarvis/processors/edge/QueueWrapper.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/SyncQueueWrapper.java 246 additions, 0 deletions...ain/java/com/jarvis/processors/edge/SyncQueueWrapper.java
- myprocessor/edge-processor/nifi-edge-processors/target/classes/com/jarvis/processors/edge/CustomMapOperator$1.class 0 additions, 0 deletions...sses/com/jarvis/processors/edge/CustomMapOperator$1.class
- myprocessor/edge-processor/nifi-edge-processors/target/classes/com/jarvis/processors/edge/CustomMapOperator.class 0 additions, 0 deletions...lasses/com/jarvis/processors/edge/CustomMapOperator.class
- myprocessor/edge-processor/nifi-edge-processors/target/classes/com/jarvis/processors/edge/CustomOperator.class 0 additions, 0 deletions...t/classes/com/jarvis/processors/edge/CustomOperator.class
- myprocessor/edge-processor/nifi-edge-processors/target/classes/com/jarvis/processors/edge/MyProcessor$1.class 0 additions, 0 deletions...et/classes/com/jarvis/processors/edge/MyProcessor$1.class
- myprocessor/edge-processor/nifi-edge-processors/target/classes/com/jarvis/processors/edge/MyProcessor.class 0 additions, 0 deletions...rget/classes/com/jarvis/processors/edge/MyProcessor.class
Loading
Please register or sign in to comment