Working version control proxy RxJava integrated with NiFi
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 7 additions, 7 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/CustomFullGroupbyOperator.java 2 additions, 2 deletions...com/jarvis/processors/edge/CustomFullGroupbyOperator.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/CustomGroupingOperator.java 2 additions, 2 deletions...va/com/jarvis/processors/edge/CustomGroupingOperator.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/CustomMapOperator.java 18 additions, 13 deletions...in/java/com/jarvis/processors/edge/CustomMapOperator.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/CustomOperator.java 21 additions, 36 deletions.../main/java/com/jarvis/processors/edge/CustomOperator.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/MyProcessor.java 83 additions, 32 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 63 additions, 0 deletions...n/java/com/jarvis/processors/edge/OutputQueueWrapper.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/PingMeshKryo.java 18 additions, 11 deletions...rc/main/java/com/jarvis/processors/edge/PingMeshKryo.java
- myprocessor/edge-processor/nifi-edge-processors/src/main/java/com/jarvis/processors/edge/QueueWrapper.java 45 additions, 14 deletions...rc/main/java/com/jarvis/processors/edge/QueueWrapper.java
- myprocessor/edge-processor/nifi-edge-processors/target/classes/com/jarvis/processors/edge/CustomFullGroupbyOperator.class 0 additions, 0 deletions...om/jarvis/processors/edge/CustomFullGroupbyOperator.class
- myprocessor/edge-processor/nifi-edge-processors/target/classes/com/jarvis/processors/edge/CustomGroupingOperator.class 0 additions, 0 deletions...s/com/jarvis/processors/edge/CustomGroupingOperator.class
- 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
Loading
Please register or sign in to comment