From 72710dc25537dcdc7186aac9dededda3e228ac97 Mon Sep 17 00:00:00 2001 From: liuy <37787198+LiuyCodes@users.noreply.github.com> Date: Fri, 16 May 2025 11:21:28 +0800 Subject: [PATCH] =?UTF-8?q?feat(nifi):=20=E5=A2=9E=E5=8A=A0=E6=B5=81?= =?UTF-8?q?=E7=A8=8B=E7=BB=84=E7=9B=B8=E5=85=B3API=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E5=B9=B6=E4=BC=98=E5=8C=96=E5=8F=82=E6=95=B0=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 新增流程组查询、创建、删除和启动/停止的API接口 - 添加流程组绑定参数上下文的接口 - 优化参数处理，支持直接传入对象作为请求体 -重构部分代码以提高可维护性 --- .../hzya/frame/nifi/client/NifiClient.java | 9 +++ .../BindParameterContextsJoin11.java | 15 +++++ .../Component11.java | 15 +++++ .../ParameterContext11.java | 8 +++ .../joinbindparametercontexts/Revision11.java | 17 +++++ .../model/joinprocessgroups/Component7.java | 11 ++++ .../joinprocessgroups/ProcessGroupStatus.java | 16 +++++ .../joinprocessgroups/ProcessGroupsJoin.java | 18 ++++++ .../model/joinprocessgroups/Revision5.java | 8 +++ .../Revision10.java | 17 +++++ .../StartOrStopProcessGroupsInfoJoin10.java | 16 +++++ .../model/processgroupid/Connections.java | 2 +- .../nifi/model/processgroupid/InputPorts.java | 2 +- .../nifi/model/processgroupid/Labels.java | 2 +- .../model/processgroupid/OutputPorts.java | 2 +- .../nifi/model/processgroupid/Processors.java | 2 +- .../{Revision.java => Revision2.java} | 2 +- .../model/processgrouproot/ProcessGroups.java | 2 +- .../{Revision.java => Revision3.java} | 2 +- .../ParameterContextsResult.java | 2 +- .../{Revision.java => Revision4.java} | 2 +- .../ProcessgroupsResult.java | 8 +++ .../AggregateSnapshot9.java | 43 +++++++++++++ .../resultprocessgroupsinfo/Component9.java | 41 ++++++++++++ .../resultprocessgroupsinfo/Permissions9.java | 15 +++++ .../resultprocessgroupsinfo/Position9.java | 15 +++++ .../ProcessGroupsInfoResult9.java | 40 ++++++++++++ .../ProcessingPerformanceStatus9.java | 19 ++++++ .../resultprocessgroupsinfo/Revision9.java | 14 ++++ .../resultprocessgroupsinfo/Status9.java | 20 ++++++ .../resultprocessgroupsinfo/Variables9.java | 14 ++++ .../frame/nifi/service/NifiApiService.java | 60 +++++++++++++++--- .../hzya/frame/nifi/client/NifiClient.class | Bin 9499 -> 11786 bytes .../frame/nifi/model/ProcessorConfig.class | Bin 2925 -> 0 bytes .../model/processgrouproot/Component.class | Bin 18645 -> 0 bytes .../processgrouproot/ProcessGroups.class | Bin 15810 -> 15816 bytes .../model/processgrouproot/Revision.class | Bin 1516 -> 0 bytes .../frame/nifi/service/NifiApiService.class | Bin 1493 -> 6299 bytes 38 files changed, 441 insertions(+), 18 deletions(-) create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/BindParameterContextsJoin11.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Component11.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/ParameterContext11.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Revision11.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Component7.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupStatus.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupsJoin.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Revision5.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/Revision10.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/StartOrStopProcessGroupsInfoJoin10.java rename fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/{Revision.java => Revision2.java} (80%) rename fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/{Revision.java => Revision3.java} (81%) rename fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/{Revision.java => Revision4.java} (85%) create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroups/ProcessgroupsResult.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/AggregateSnapshot9.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Component9.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Permissions9.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Position9.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessGroupsInfoResult9.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessingPerformanceStatus9.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Revision9.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Status9.java create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Variables9.java delete mode 100644 fw-nifi/target/classes/com/hzya/frame/nifi/model/ProcessorConfig.class delete mode 100644 fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Component.class delete mode 100644 fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Revision.class diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java index 58748595..5b307b48 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java @@ -86,6 +86,15 @@ public class NifiClient { }); } + public T put(String path, Object requestBody, Class responseType) throws IOException { + String jsonBody = objectMapper.writeValueAsString(requestBody); + RequestBody body = RequestBody.create(jsonBody, MediaType.get("application/json; charset=utf-8")); + return executeRequestWithRetry(() -> { + Request request = new Request.Builder().url(config.getApiUrl() + path).put(body).header("Authorization", "Bearer " + accessToken.get()).build(); + return executeRequest(request, responseType); + }); + } + private T executeRequestWithRetry(IOExceptionRunnable runnable) throws IOException { int maxRetries = 2; for (int attempt = 0; attempt < maxRetries; attempt++) { diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/BindParameterContextsJoin11.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/BindParameterContextsJoin11.java new file mode 100644 index 00000000..df0ada05 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/BindParameterContextsJoin11.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.joinbindparametercontexts; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 11:1:46 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class BindParameterContextsJoin11 { + private Revision11 revision; + private Component11 component; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Component11.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Component11.java new file mode 100644 index 00000000..b539d353 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Component11.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.joinbindparametercontexts; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 11:1:46 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Component11 { + private String id; + private ParameterContext11 parameterContext; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/ParameterContext11.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/ParameterContext11.java new file mode 100644 index 00000000..8a697d39 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/ParameterContext11.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.joinbindparametercontexts; + +import lombok.Data; + +@Data +public class ParameterContext11 { + private String id; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Revision11.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Revision11.java new file mode 100644 index 00000000..8ee88871 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinbindparametercontexts/Revision11.java @@ -0,0 +1,17 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.joinbindparametercontexts; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 11:1:46 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Revision11 { + private String version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Component7.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Component7.java new file mode 100644 index 00000000..9407181b --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Component7.java @@ -0,0 +1,11 @@ +package com.hzya.frame.nifi.model.joinprocessgroups; + +import com.hzya.frame.nifi.model.resultparametercontexts.Parameters; +import lombok.Data; + +import java.util.List; + +@Data +public class Component7 { + private String name; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupStatus.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupStatus.java new file mode 100644 index 00000000..a5879565 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupStatus.java @@ -0,0 +1,16 @@ +package com.hzya.frame.nifi.model.joinprocessgroups; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joinprocessgroups + * @Project：fw-nifi + * @name：ProcessGroupStatus + * @Date：2025/5/15 10:43 + * @Filename：ProcessGroupStatus + */ +@Data +public class ProcessGroupStatus { + private String name; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupsJoin.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupsJoin.java new file mode 100644 index 00000000..53859ac0 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/ProcessGroupsJoin.java @@ -0,0 +1,18 @@ +package com.hzya.frame.nifi.model.joinprocessgroups; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.joinprocessgroups + * @Project：fw-nifi + * @name：ProcessGroupsJoin + * @Date：2025/5/15 10:43 + * @Filename：ProcessGroupsJoin + */ +@Data +public class ProcessGroupsJoin { + private Revision5 revision; +// private ProcessGroupStatus status; + private Component7 component; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Revision5.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Revision5.java new file mode 100644 index 00000000..57282cde --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinprocessgroups/Revision5.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.joinprocessgroups; + +import lombok.Data; + +@Data +public class Revision5 { + private int version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/Revision10.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/Revision10.java new file mode 100644 index 00000000..3d20c070 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/Revision10.java @@ -0,0 +1,17 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.joinstartorstopprocessgroup; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 10:47:3 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Revision10 { + private String version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/StartOrStopProcessGroupsInfoJoin10.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/StartOrStopProcessGroupsInfoJoin10.java new file mode 100644 index 00000000..cdeef740 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinstartorstopprocessgroup/StartOrStopProcessGroupsInfoJoin10.java @@ -0,0 +1,16 @@ +package com.hzya.frame.nifi.model.joinstartorstopprocessgroup; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 10:47:3 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class StartOrStopProcessGroupsInfoJoin10 { + private String id; + private String state; + private Revision10 revision; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java index 455a6a43..719a6768 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class Connections { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Permissions permissions; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java index b29862ef..5aa0208e 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class InputPorts { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java index 0de5546c..96c4fa7c 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java @@ -4,7 +4,7 @@ import lombok.Data; @Data public class Labels { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java index 9c8baab4..18a113bb 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class OutputPorts { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java index 2a8f9a1c..0f331fbd 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class Processors { - private Revision revision; + private Revision2 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision2.java similarity index 80% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision2.java index bff55741..f5002140 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision2.java @@ -3,6 +3,6 @@ package com.hzya.frame.nifi.model.processgroupid; import lombok.Data; @Data -public class Revision { +public class Revision2 { private int version; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java index fbebef08..dae13221 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java @@ -6,7 +6,7 @@ import java.util.List; @Data public class ProcessGroups { - private Revision revision; + private Revision3 revision; private String id; private String uri; private Position position; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision3.java similarity index 81% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision3.java index b152031a..03366b7f 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision3.java @@ -3,6 +3,6 @@ package com.hzya.frame.nifi.model.processgrouproot; import lombok.Data; @Data -public class Revision { +public class Revision3 { private String version; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java index 0f7ae0a1..c769bec7 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java @@ -4,7 +4,7 @@ import lombok.Data; @Data public class ParameterContextsResult { - private Revision revision; + private Revision4 revision; private String id; private String uri; private Permissions permissions; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision4.java similarity index 85% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision4.java index e8a518bf..955ec15a 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Revision4.java @@ -3,7 +3,7 @@ package com.hzya.frame.nifi.model.resultparametercontexts; import lombok.Data; @Data -public class Revision { +public class Revision4 { private int version; private String lastModifier; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroups/ProcessgroupsResult.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroups/ProcessgroupsResult.java new file mode 100644 index 00000000..82934f6b --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroups/ProcessgroupsResult.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.resultprocessgroups; + +import lombok.Data; + +@Data +public class ProcessgroupsResult { + private String id; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/AggregateSnapshot9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/AggregateSnapshot9.java new file mode 100644 index 00000000..d2b5381c --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/AggregateSnapshot9.java @@ -0,0 +1,43 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class AggregateSnapshot9 { + private String id; + private String name; + private String flowFilesIn; + private String bytesIn; + private String input; + private String flowFilesQueued; + private String bytesQueued; + private String queued; + private String queuedCount; + private String queuedSize; + private String bytesRead; + private String read; + private String bytesWritten; + private String written; + private String flowFilesOut; + private String bytesOut; + private String output; + private String flowFilesTransferred; + private String bytesTransferred; + private String transferred; + private String bytesReceived; + private String flowFilesReceived; + private String received; + private String bytesSent; + private String flowFilesSent; + private String sent; + private String activeThreadCount; + private String terminatedThreadCount; + private String processingNanos; + private ProcessingPerformanceStatus9 processingPerformanceStatus; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Component9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Component9.java new file mode 100644 index 00000000..9d77f58d --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Component9.java @@ -0,0 +1,41 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Component9 { + private String id; + private String parentGroupId; + private Position9 position; + private String name; + private String comments; + private Variables9 variables; + private String flowfileConcurrency; + private String flowfileOutboundPolicy; + private String defaultFlowFileExpiration; + private String defaultBackPressureObjectThreshold; + private String defaultBackPressureDataSizeThreshold; + private String runningCount; + private String stoppedCount; + private String invalidCount; + private String disabledCount; + private String activeRemotePortCount; + private String inactiveRemotePortCount; + private String upToDateCount; + private String locallyModifiedCount; + private String staleCount; + private String locallyModifiedAndStaleCount; + private String syncFailureCount; + private String localInputPortCount; + private String localOutputPortCount; + private String publicInputPortCount; + private String publicOutputPortCount; + private String inputPortCount; + private String outputPortCount; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Permissions9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Permissions9.java new file mode 100644 index 00000000..78ca1b5a --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Permissions9.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Permissions9 { + private String canRead; + private String canWrite; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Position9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Position9.java new file mode 100644 index 00000000..67d28144 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Position9.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Position9 { + private String x; + private String y; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessGroupsInfoResult9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessGroupsInfoResult9.java new file mode 100644 index 00000000..f0276e1d --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessGroupsInfoResult9.java @@ -0,0 +1,40 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +import java.util.List; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class ProcessGroupsInfoResult9 { + private Revision9 revision; + private String id; + private String uri; + private Position9 position; + private Permissions9 permissions; + private List bulletins; + private Component9 component; + private Status9 status; + private String runningCount; + private String stoppedCount; + private String invalidCount; + private String disabledCount; + private String activeRemotePortCount; + private String inactiveRemotePortCount; + private String upToDateCount; + private String locallyModifiedCount; + private String staleCount; + private String locallyModifiedAndStaleCount; + private String syncFailureCount; + private String localInputPortCount; + private String localOutputPortCount; + private String publicInputPortCount; + private String publicOutputPortCount; + private String inputPortCount; + private String outputPortCount; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessingPerformanceStatus9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessingPerformanceStatus9.java new file mode 100644 index 00000000..17ac6b85 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/ProcessingPerformanceStatus9.java @@ -0,0 +1,19 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class ProcessingPerformanceStatus9 { + private String identifier; + private String cpuDuration; + private String contentReadDuration; + private String contentWriteDuration; + private String sessionCommitDuration; + private String garbageCollectionDuration; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Revision9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Revision9.java new file mode 100644 index 00000000..714a89c3 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Revision9.java @@ -0,0 +1,14 @@ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Revision9 { + private String version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Status9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Status9.java new file mode 100644 index 00000000..bb0de5c9 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Status9.java @@ -0,0 +1,20 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class Status9 { + private String id; + private String name; + private String statsLastRefreshed; + private AggregateSnapshot9 aggregateSnapshot; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Variables9.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Variables9.java new file mode 100644 index 00000000..c3268e00 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultprocessgroupsinfo/Variables9.java @@ -0,0 +1,14 @@ +/** + * Copyright 2025 bejson.com + */ +package com.hzya.frame.nifi.model.resultprocessgroupsinfo; + +/** + * Auto-generated: 2025-05-16 9:47:26 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +public class Variables9 { + +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java index 5241fd01..5ff590a4 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java @@ -2,10 +2,15 @@ package com.hzya.frame.nifi.service; import cn.hutool.core.util.StrUtil; import com.hzya.frame.nifi.client.NifiClient; +import com.hzya.frame.nifi.model.joinbindparametercontexts.BindParameterContextsJoin11; import com.hzya.frame.nifi.model.joinparametercontexts.ParameterContextsJoin; +import com.hzya.frame.nifi.model.joinprocessgroups.ProcessGroupsJoin; +import com.hzya.frame.nifi.model.joinstartorstopprocessgroup.StartOrStopProcessGroupsInfoJoin10; import com.hzya.frame.nifi.model.processgroupid.ProcessGroupsId; import com.hzya.frame.nifi.model.processgrouproot.ProcessGroupsRoot; import com.hzya.frame.nifi.model.resultparametercontexts.ParameterContextsResult; +import com.hzya.frame.nifi.model.resultprocessgroups.ProcessgroupsResult; +import com.hzya.frame.nifi.model.resultprocessgroupsinfo.ProcessGroupsInfoResult9; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -39,14 +44,17 @@ public class NifiApiService { } /** - * 查询全部流程组或指定流程组 + * 查询全部流程 */ - public Object queryFlowProcessGroupsRoot(String flowGroupId) throws Exception { - if (flowGroupId != null) { - return client.get(StrUtil.format("/flow/process-groups/{}", flowGroupId), ProcessGroupsId.class); - } else { - return client.get("/flow/process-groups/root", ProcessGroupsRoot.class); - } + public ProcessGroupsRoot queryFlowProcessGroupsRoot() throws Exception { + return client.get("/flow/process-groups/root", ProcessGroupsRoot.class); + } + + /** + * 查询指定流程 + */ + public ProcessGroupsId queryFlowProcessGroupsRoot(String flowGroupId) throws Exception { + return client.get(StrUtil.format("/flow/process-groups/{}", flowGroupId), ProcessGroupsId.class); } /** @@ -78,9 +86,45 @@ public class NifiApiService { } /** - * 删除参数上下文,待query参数 + * 删除参数上下文 */ public ParameterContextsResult deleteParameterContexts(String id, Map queryParams) throws Exception { return client.delete(StrUtil.format("/parameter-contexts/{}", id), queryParams, ParameterContextsResult.class); } + + /** + * 查询流程组详情 + */ + public ProcessGroupsInfoResult9 getProcessGroups(String processGroups) throws Exception { + return client.get(StrUtil.format("/process-groups/{}", processGroups), ProcessGroupsInfoResult9.class); + } + + /** + * 创建流程组 + */ + public ProcessgroupsResult createProcessGroups(String parentGroupId, ProcessGroupsJoin processGroupsJoin) throws Exception { + return client.post(StrUtil.format("/process-groups/{}/process-groups", parentGroupId), processGroupsJoin, ProcessgroupsResult.class); + } + + /** + * 删除流程组 + */ + public ProcessGroupsInfoResult9 deleteProcessGroups(String parentGroupId, Map queryParams) throws Exception { + return client.delete(StrUtil.format("/process-groups/{}", parentGroupId), queryParams, ProcessGroupsInfoResult9.class); + } + + /** + * 启动或停止流程组 + */ + public ProcessGroupsInfoResult9 startOrStopProcessGroups(StartOrStopProcessGroupsInfoJoin10 startOrStopProcessGroupsInfoJoin10) throws Exception { + return client.put(StrUtil.format("/flow/process-groups/{}", startOrStopProcessGroupsInfoJoin10.getId()), startOrStopProcessGroupsInfoJoin10, ProcessGroupsInfoResult9.class); + } + + /** + * 给流程组绑定参数上下文环境、或者给流程组更新上下文环境 + */ + public ProcessGroupsInfoResult9 bindParameterContexts(BindParameterContextsJoin11 bindParameterContextsJoin) throws Exception { + String id = bindParameterContextsJoin.getComponent().getId(); + return client.put(StrUtil.format("/process-groups/{}", id), bindParameterContextsJoin, ProcessGroupsInfoResult9.class); + } } \ No newline at end of file diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient.class b/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient.class index 0030e6c2c31d599691112a61dd4f22156261ee3b..a9679050bc41dfcc46d50d49535522f6707b2894 100644 GIT binary patch literal 11786 zcmcgy3w%`Nl|N@PGj}q%kT5(nfII_2APfj14i6y_1Pnn)f<=7vX6A+rOlIOd2w>Ox zMk`7y3W_Ldp=qrTurT4F#%^0`)xNa5>+ZU{-CcvY-L3muEKPBmXg}VLZqW6pGW;!K5AIQ&X`T5X~pMR2{ zU&)Yv_S3)6uchN74<;bj&S@lH|5}Xpe^cn+{WOT)_tAgI^FI~(FFy^X-^j;r<>z;P z`fvJJq5o0n6CeHFPs8a`KaHR>0U~x|754bq%ZiVEelBLepG#N`5c9wQxiEmsc#xk1 zJXn5)KzAM*pdv0W;o&^OPtWp5bkOetw9;5JB`55Qp@jkBb(@dV= z4MuEvvVaH2KXvUQ6VY))#edN3Ysjt0%%U>)A;_2i~#Sg$e0&t>wrq|li;Mm;Xl8?;SYFq4kPM6+-vnZ)WrEuCnMhJ%ZY$7;Py8!bIOp6}NQmKsI5N*Yzyqu}jXk5IxEt=E> zYG67q8jq$IFr_D*AE<>vJTJ&5uVHf6BqC6*v^E;o>oToPda}XveV{fG)?#b4WK_Pb zMt8a;3L;!wSXINnhW|}h1BJ2`db%YMxkeM3z>g3v2fxxlWKA>`#mtN1@kH7H1ATL9 z6Up_#RGXk^FsnV0+!$=qwRkGntcBBw#(BPIa^xJ7Vr+M~g{COzCdZ(k)B@ zN1r7Rekb)*TOyv)8@9ATt3i%2=8VSPaH5WJ7V^V-51!Z1VDQXu8wC7n<~4*I11+r< z^uro+y2+SSY)GU4!m@LVS(7`KI|nQ!N&V)Go=R6IB3pW*VaGgr`a$%xy4{Vyi;ll*>fN+W|Fb$Of(kJ zlM08K6zc=K#I{{RWMeW`VRga&B1kb^+HAYZ z+A^Tl1^Q+^oJs4JU$2d(TUP7oB&e~nk1*Ifwp0{IScP|_OW$lqfM_DYLlY5LZwQ__bBrECxj-Z7%%mQ<=!2P+?lvm(L2O;{L$pbjy%%iyq#% zC>}vdM3ic=LTHJVHYJ0hT0or;HS?>H!t}`EWHNzFeWA5qdciySI;6p#o@Sao$!50Y z{eJExJ9?Ti!j}uC5>9dj#cC_Sif65eBXKt0Z3LmY3P(_%pLK zV)sB~k44TZWXL3EmasE{r)f)CsNq^y4c5i=b_?&~Ry`8c%=9qWR(nOR5sI%@xJ98~ zAeqFp)~1M7f&El5i>bCy$m*rK0M}2jORd?>h*&Wb!K-J>CCHvR4UjD=X5=*j1{Kq> z2kH}w=tR+Vm}+f}*)KOE--f|Ie1qn@*a za>e^6_J45S_U_J?y6=6WyW{@u?YlmDdHdM&-@06N_Srvg$-4ok}OQHnSQ_m3nzg8E-9B_!gDF!~p6g`i{c4s{CcXjcGIr z@K`i#6lFol%5%qrTeM_KPtVV!o2%x4g(~gj+d)N@@8CNz&s{Rl-FUf2;cY74D;D0T z@>lqNmACT)DnH0O%J{3L9{ySxKcwk zn4;2m=}%GITjuU~@${Xqz#XOw#1}7icHi51YS+Q;W7!Y4J#hNPN2X1ihO)|RJPRb? zvzKXv%<$@~-S-|mwfDB}{T-&@spppuks7@Hg@R5Hk|BGVn@*Oq9}6*A4EvR7U&f@a>WNWeb78* z1&x!8O3(8lm7d_2U^h;CX>8Xj312FIhY#a)Bf(IzYf)ve5(_p$gQ`XAjbmV-xxGrx zja6YYS<5dj=u&6z%<;WYpqD-UNBsbN3iXkYgx(k?EIQ9l--k-iz+?Daw zO}Ty7QzO(CazIVTaD4A!eNH1R=|>V=fy)SOz3%7lGD23*O2E=WE@Zw3^HFy)ZR=<0 z>rCO+k`7~Xhp^AgDF8l2g!_5%g7T|98BObJv{*)8l*$1&(dnu_F~?dLI|t?vEKvH$ z^%M9Y$Fq3_L<&euw%Z)Eohy)kpK0&s0K33$aQfu)dq8yj0n^liJ~Zys&c04dqo3pxCputcd7Pg|t;2!m^i9|0S zTV!xhHb)QKTt3SudksIE;W?6En|UP}Nq!0CPZhoOvjT*1hHcKojocEfjv~>dGOcb70KF)S{DrH=aVyS4VK4Tn_nlsQ2@gGJMV`oQ<2m(06 zv4jwHfEJ0=XWH752%|dS%^fn0!n`L~B_N=b7E;{c9vENOScQ!dEOG|e8O^y{b8NEt z?F<&Zaz|fdbLA0`oPHMC1}=HTt?3;i#V~X!?3X+5E1bTzmUD2V9||~GnDaNT^rR3p z(8e{#$Vto2l{J-CGjTy`(quWHjy3j299hsh2H>7si$}C%MA(Qb03`J^HY~Ym4h}A+ zw$8!UAb>M^(z@!t`-S%277GYx#OV#0!aq{^4gRr8zeIsde@E}B^tVzf|Ac?4(%(qi zU(4A@>EVeLf*=%Bc!0$cL>8=bPs+< zk%HfG5WI*=X*>;~3M!`wXrGAIi)kBrE6r)?Ub+uoSin%1jWXMf4TC4=BO_ zf-Qt=2%`J(#|urjjw zXb@}(1O{hm$O#&{7QLmNG%QOOWa+{zm3Pp%+7mQlZEoC1jGL0Bi}1jJP8!v92x}58 zqAT(Dtwo06{U7A%M^HD(`U4z!^iK#$Na zqkjPHrbn^%V;HO2Eql=NI9l9jnQ4Gs?1BhkFj+L&i>@c=NlTZ<$pe^)CIB;KYL>=^ z+~w}TxT7@wC{=_!(6HQ7bsP@wspCLHuX*IB`813c7`iSnC$e>&VCy=8_R&*@FDDpU z7eQ_WJq=6TkS?WX=<84;Z;6cBgB5yO0@{cr`+8WjAJ!b`3)zXiv^J4l{KrK00DZ$k z_I*4B**c4L0N9hIi%seY?~c->EKLr%r=FytQ_J0Jvs8KQaWIaK(Nq_eyR%f4rD@^= z!v#Ux7`H*tVStQi1&yIP?8%ihn^w_6s&}}e&UQte?TR|;pl=$ksIy!#2E_grJqK+U z(m;A1PBC2}#D?}5|AIYUoFc^b5r0Cn6?(C-i#jkQPq>3{(V_Dt+;rPob5odvyAH%z z2g+RUuyTTJ<^L1mTyi^TI+-#3az+96_yvCWbsGXr>*qW`j57;ExrvWWvk3?keJrGuvfYU`{7p z-UUAu(_qBtnFv%X@h>TcLrsa|)l`PxF#01H(M$tqJw~+v$tdFZ2AWJUNW^I#C8&nl zAe(~p&D4Mdl!44G2-p(oWs5f;F&##*^FaD0ggs;s{MSxdLD54_5h;2N5_KBN3$_yK*I0=}aLiaZy5WZ|j5V%vh0p?yTx9Aw5Vy@$m8+g@Z z>B^7?FN^okXeXXaEOwje`0_3YE9D-fqpL#Rs*^Oj+(yyfW%`OX?$jM1nZ?9sk1aB4M>UQ5g1mt|nS`OLtQ+fXcRGuqmLzob#w zJrl8K2!+WYP;EFY9t-x*r-v|ZC-%=nnBf78-f2KL3$qW${68?_=s*-TC+UaAzSv{K zxrbh-9|2B6lIxwsrA3ms?2A?^{*>k`^oBxjD)iPF%FZT)!r8ZQ$xGeIc+m zaGgBX1+JIJ4S^f+$kI)9!Y~lPWLU_}U;%O_s1x-CE+O;e-1;W-x#9T;Xru2cA zddPc%n%9zF}TGx2Yu;xky%YY^#Oh5phYqY#v^a+Srf z9vuq(708SKO`f@hrG?~$!zNJ&Q%Rxu9b|ReWF21SlEW>4k`(YPSn0vDp)ZOdA_)sk zhD8G#axYBW?gk8UAb^^j2jN@xmMp=l<#BH^lcHIDf3ysa#58!Tm?u#{c(zkA^G*|3C` z(^U=|R@pYJvf*E4*|5BC8w7L{a9o>MHk==e*7U~_eX{5ZFk;~!k43l;`YeuV>yJ%+ zkZU#^bJ_oyV?d|BH#Xis*!Kkgh;K>Gaw(BQag_GTJ$Zn>jf;uZyb#Y~ev^O3Z&A4r hS&CN1RUcxi{4w7K*l(rQ+c3o53$5OZ?A}rA`UBjmXK4Tc delta 4186 zcmZ`+33yc175>j`@6DT+Z6=Tm31JO}kPtDTI1rYwMIgaIf&?NskRb#@5|arSL`GRe z5pj9e7Fie)@g$?sm?-XZz2& zcXrj^H#c_r(`R1*FkbF7uo|Z{eBXcrr@V;Zv}%5!njfm>6@$%>RP$rS@~VN?@VX-W z#LWZXu*O2oe(L4=&ounpKn70f_=W1vX!xap0r-`g{8}|<4g3bb)na%OpUGgbqj*Ox=2VpS_FY1QrBsc^YcfHT zOEtMn5U`%o14jam4;;oD0%v0+D!9yg$(L!J2>7i#jKGl!_j7WjMK2KtKD73GcgO@Q z-#DEjd*z2K|1W|+&I8?n`T z*t~dB8?H667VAtjW4(zMw3@gHTTL9paZ}1jz&yul-Z`tlsTqU;J7ANm@-%9SsPQ9O`Ol8NuDQ2 zFK=y)c0}95ZIzMen%0JnG>=rKOI4aC3rx9Es!i<0K1~*yvPfzyBX#7kNhWqmEv++U zv0O#QC5o}m#Mh`bM^)Bcso9=y;4wj|^<-+H_pKYZCVtl0)EwtVS!$h2omaR_>IG(P zOSqGA+nY8;8Z^1ul;yHQlWR-~%SufqnzBk7tj%fJ197iJG+Av*qjJj{++s=-J@`Oc zwsWnlvyP>W8s99n0&izWq`f7)K2oO1dQ)0(Twsi93wLyEY;A8SGo@ASUo345m~vq_ zm{lgw$~&8y8zSwdT&p&ul!RBUiga|8L|fNIT1;t|4ik3?@nFtqZHY!&qQx~`Z4pyC zWrJ0dUP+^_vmQ+!GqFoHDVJYQ_zW!`YRYEi=x5~yI@*p-bGW6kWKp!esijeqEvCfe zMiq#gEHfk5zf-DA*(w`M9K<)3lebw@GrEqvp0P`u+hvEfA`o;&k-+D*>~qV^OEA@aoQHiY^$v)GEp@v$kYU^}5@_?Hv(8k@Z?&fOT*{(0V?5S-?wh zPj73gZCC7_sx2na19t~AthS)fstDfXaj#S^v0e_olTKgXD!Wa5mtM!W@g3{+K@((; zrRSXSXmW=j-&&B9Wj&PRvFdV*=0#Wn0T28N)g1X1uI-y+dUn$6Xv-+Xio{S2_%b&UP&IE1^vn zQ}#Ga$9T-dC76X$til9akAd7ii_~q{ZcA@SYP5s9y>NVlnHp}+BWWjYp~_uWU0$AT zq>>Iyv=13dC8=VcF)6qeyKH(2Zo_VhxSe#fZ)Fcx?%;}xD+RWBUI({;%t(6rPLl4z z-AW|a?t`1=(x-(_Lo2cxhXt*)A*QWIsx5m444O8OrYPr5Nig^6li#OLJ}lfr=_))* zGbi`u;7ioj#ocMR7hk5Rer*-k9&%l%ErX%7U1YK8SNSVEm*pp+vV@Z=?{Jqnrwq=0 z1f7LPF>1_lTqHOYat+RPHSC937<3)Q=zZ`6T_+AB-Ct-eA6^hEsOv^X-BI}cW8%mR zy5ktkK8|d~U36l*Qx5d(?nXhKzxXJ|o}gSW0)$xsgS-F>d9S*lKv0f!w)07^B*y|q z=t^=`)6#{6VU}NoTI;b7&2QF%H{l)@>(GcSPf6sS2eH};56`pS9pRI4)<+`-f5wZ&eNI#^dx|P# z(AHY|%4z$mkVpX2!i5G>R#Uk~CgmEYPZRl?$+;GbnW9nVpTd~J{NiNdDD-zG&3Ca} ze4R6i**0dt(ZjtC4F`yJJD2+Ha)1|)GJ^Y;vsbvxW5_S@m&P%EAJXjc1djJYa~*)o z`8YWe`X=(P-PT1Vu_`;g#YCm^{jsE%J#c0_r-_|rbmBI0I#kW3rIahruveDvWomgS z@6zMo>!M0RE_!U@KIAE!^}_LT!jQ{Zgrf2yhoLwoh1@DFgYKd@CWk!5Cov@GI*IIo zB$pjPAfyFdK`oA{2cW4X>tOz%m`(7K;O!>_^%D$xHQlv@DV%`{x;xQFsbGw%-^}?s zR$etvKztN|4X$JmiP@~fr3~g|I;DcnSi?TSz1eotc%D9)0eu|1VjQM2cb~wwZ1C>w z^W9!Ni9>W9Jz`gg^TDfDRP9pWT?_9gDAn+khQmD=35^lfa74q?i8T$+Xo#zjANDzW zxXFD!LyXHdt-{`(0q^-#MFcOA1dH#p<%h-cNz(f(&rzl(A7B*1h&r~=H6|ll>YsKD z)8~)r4PH5e$3U@~%!tR3>7Us*pOvUC$1uCH8*^BADw2B=>{pQNpPS%`V;;ji-(TsU z7DttTf&WU?Rr?pJZjrx+T^zMl3QUZ30!$&7gxo=w4X2U>oFa+xwwQ-1!c}oB@z*6M zOB0e5z!Z%LTNd(kqrNWaIgG21VmSe&g>;3nVL|svWGOD$n-3WoDEughoA%>&Nx{(p{_j>fGA zZ4mM`Af-tVdZZZ7;{}4SlsHsZl7qsI+rV_%;M)mr4`q66(45flqK!NSMNo8c5=}NC zrZA}}8eXz7`AhU)`15>p`;FH7Ecs}AvCFKza-)-sXG>Z?(q*+gpSv}jTzbH%k zt%{?;ZyOa;*Z3D(RaIDAbb(ES?6=G1e6)r5h?|7VSh8lL40DOk{)c0ApN-YDF=1l0 zZJ2|cS`sSirdfUABP(GQt@s{k4xH?JNxsZ^6F+qyHu4|#8jt$NIY6@Dm0fbX+{P#D VA4pes%^%70Hs0Zv7`>0T{|^`mD0%<@ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/ProcessorConfig.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/ProcessorConfig.class deleted file mode 100644 index 15d66f3cb33b18c2b35f4e2f3517b8b89848b5b2..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 2925 zcma)8S#KLv6#mAZ%}Z92rc;`w5Fm+@8cHePG$n26l9HsMDS?))6K4`nYI}@5t|;Oe z@r1+^5)!XeLVbV=QVApkFGb=vQOb8_CYwD-k&<)IJe%`CDyHcC6;rNR|>3w74am93iV>GM8nqSuZ*lUBSMu1;pbrv004ZSQdw2WicpZNXRfO1>-WH2O5Vg&f(=OUcguu zCxjapZbC>-$a%b}V4(GaoNKz}HEDc*OJZY!!Auqo)(QILh*UYlvL{E}HLm95NKh$R zWju>{jB#3a4-au=KkQn~sj@LsaTC@ybWt|bIK~HHfDed@gtP?;j&PUZ`ZWKKHYiL; ztJ)QVRIq*RiXkf4(sso#Iw&Lpq|Y!)o~y!Dn|KK2Co%~J&vU0p z(@FO`|BS?sEzUi$&crFkIoaym7wb%XW1Q7i=Yd#f&P9x~*6MsD)_D?BNCq_**r9}U zXd?Fu67d~76k0?blWvBv9;ctCaMRt6FyH6+7|Dai2qz?pG1wkskmbJ^A45H8jBwbZ z7(?wbh8W|e_!!zjV}x@X#TagnG0Yge^XxHaQ2Cr|hJAgIoA@4@dO!Ck^lzah@8|x2 zzA!nl1tZv!F&8IE3hLBf$XMzl^xQ*s%2KzG+O|j+G@7Ifx}}MY{s_JI&|ztozQ-t2 zFldx1n3f?%W@Kbo<{qPLAw{EXA#J6^C>QN~3~lQU4qEKZX%@ij0047n7( z;p1|KTpDjMk5lL}%zw~nVD>Q%892*7Q+bTTA)ERi77sWAtsGdl4UPgLX?Cl#2#;1LE7s&!AFR%Ze*k9JR&2&LJby9Z-x3mvya zo-U}Ou+&In3c#T%Q_unxu??I|OWRgu3wof^cT_~2UPt3Wx*X;bC7(nE7ualmFbKmX zatXF|9hX^<0K9-Xaw^+>0$0dsxWV`SEpmF${2yRGp+IHx6@?9lqCBDF?mi)cerVeU z+cxTcQDmm?G269ll}5(Ke&b#H7zJHeBfowjCfH=1^6i-Y4V^b0qN}%i3q1l2m)_ox l=eYOuJ{9sA;rl{9D||o677n#O!FxYDvr&%~c2UM?@ju_+(mMbE diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Component.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Component.class deleted file mode 100644 index cf93f7f162be47e5651b40c0031fb5eec32c8c7e..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 18645 zcmeHNd3;>eb-wq_NP3cHw2aoLb!3mMUGlzMS+>E*#KblVHY7j@jHR(PSe_Bm$k^;V z2?+rLfk46%vd|{9SsKh*NYVmrx;KQhq@+k2^ zdFS2pec!w9>78@WedF)^`l)9bW2^ZWD%d_gR?fnF6Pe9qwvai6%&BCyk~xjcIGJr^ zPABsoGTX_VLFT<=c97XgW*3<=$xM)WADOer>?X5^%-LklA@hDRA0Trsne)h;U&cRJ zf#U^aK1B1pki3h?M9J(WGf8HOOpMGvGW*F)lZlhLn9Kn(Gh_~uNsvjBnI&@xnK?4^ zWKv`n$Q&YbDVf7$j*z*G%;jXRpjlm6#;>Yir}8nIUronrY<{iHue15}basQyZ?ySM zHow{CAGY~NY<`Q)KWg)j+5A?Uf86G`+5C2!-(mAl*!)hL-(~Yp+Wc;t-(&Mn+5BFc z-)Hkr+x#;&zu)E$*!)3KeW;9omNP3p#aU>_#nD62k(p>>|H$stTs*OVl(YInvAOwp zG7+2Fnmjm*Vz$paH}xQ~Uo*qM7Tj!mZaOyhJqIfEw=F@R2srlPy!m&LMR!I|WK z(%-$XZ(sZ{XMwqeL;{a|D<+e|>3k|VJ4+8;oyHS~qBHUIX>ck&PtPTN-VmKk#Sg{K ziXBX*ViU=^l%_Ss69po{h1oqxObbs%UZ8#^IT@XqIkGc3g};_7Trr=D(vy>zHV@{M z#MJJraLxRY#N@VUdE z(v9&%Jhh24UvJ+zc)_;f9ptQfM?4YRwQz86Y;F%dM0)Y*=F=~Y9`vWC)n4vNQ@Vr9_TC9{kaF8Qao3GdqSVPtI43LM&AB$jPAi;t-I?&Bnb%{+8Iq44@s8a5tH#h-IVngZyK}OT zMz-f9A_<+An~TjDI>nrhEs|d#BT4G)+@z#;M82ANc^O0`JNG*Ck)G_VBSv0=(w|FS z!JBpNrStNRA``|;r8`%VJW?$}-b;iqmIo}ES6S20o1Zk4!!wAwYk!T`i5YnjxFDsRB<|YJZ8;P36Y#!%13&0 zi5U60l;(L~bb3MMrSsl)iWJBtHloMciB%V^(uobhCC z)2BmNyOOEt*c@JRS_3208`^S2x{e$)w}mYVW)6lV(bG8ADTZe>sGx45R%w(wP%Z(g zW2{g?b)uM99`(|unOOsB`sof4{eYfxW~5m{(j8(>-{>f?G1i(x%S+5$rZ?On$+~x> ztoJsbor=E*q9 zfRhJyMrY;j2j5HNX90UMni!`=1Pj1)bbeZGps<_Tjx}Q9tnE9;v53Gg#qJk-W^A zW3*^;R)uz4eX1I!FIoZiVfK*#+s~#0EKcTPG6&d9fE^?+K_l-3?0q=h3YWhN*<8ARepi0C5(8 zZn})%v~e(OC?p6tnLutSL9A^sT(I*(xZ4dcQci&DG2-$H3Xr(voRWf}>cMb!QBfn= zWkro-7ZxRyQ(7?8JQy}s5QJI=!v)HVlFBJC7{cGoRALYb4u&&D2Irl5$ec0*L>(BO zg&m{#a~YOy1k#uG)D9Ifl^aBG=f=eqp<250?2?1A&|uh8bTG*K0$i}$@h8f>-fHKB zg)oYbwh8Q)hD_ft@;+(ke86|J9DI6|CdsCx20 zf+&xuiSmfDD37R&@`&OnkEoCGh!QD}sFL!CLMe}^mGX#kiQ_4ZQ#psd1!p5TavV$g zA7}h)682HpQZ>jv20x(vTiM5P#;It+=90g`tgm{=WkxdUtby$Fl5Hay_1Qr7d&%WS zGU~d4T;e5H7|B=<4CGQTxzb3+I$|J~dC37I8S9UMYy2de z4+e6Lm)u|^qwg?~YrW(~BN_dQfgJLZn~Y@iIR%C;hNJd{}AUAl) zEk-i>F$1~LOKvri(Z?CcO8bSz4?lHE^!vK`Hr!S+cBHN$Le%$%K@Al09X* zal2SaYAapIq?CNxJj?Q8C8VrPN-jvrZ<-~mij|~|fh&1PN`A{MSzW9o?J-=*OQqzu z&5||6O44@4l{_pZf6pvgTdXAQd|b&RQu6oBlA&THX%pp2UM3}B3}WJ|G4dXDD@7MT zE5#D0i$F^>sLNTB1zIJR0<=m*oTUVcXwXt8k_B2Vx&c}(mO0%7TBbqW&ay1f8qovL z8qw?Y5U5v!dYs-Y&|1+4&|1;&^bx3EgZdo2*Y4}PP7DCFP7FE&1RB(!0eZwPXuTN1 z>3T8j$UGR27 zk9oeuT8C9VO79c>DfSZk9tv24|3daMzRy}L;-6sO$C!`x`_Ev11<%h;_YbkZhF8LN z`g_C)jK7 z0_+FAd)e#og6wtQo$N>Os_@Hoiv1W~H81rg*c2cx8M!?CU}JV;Enjs;T_x$Z@F)Qz0FJDt?*sWe#uMWt@Pc;Ug2f%R{0)cFL4{* zYTtA0F{Z=-)V>*BTW#{B2vxrX3v;&u4+zlU8=X1~d*%6R=-tg(zY;GfOkV$I4e z|9@9Ll4E-g>2EwQq51IB&(iuM!Um)@eKsngu7j$9<*f!xeKjgcR|Dkt%lKQl?aa&6 z&d?9Z7{Z4re9^U77plr|&FDt|m~2|wYDT9~s_mMAM_Ad=QFh8jG#(Lt3OIfpv8j9zkL+D{7$#zQ8p=F{}hDzNKIvd665oI!jrbe^M(xF~q%aHAc(CR2wpD33hbUB(; zo(}bk3K^oEZYYor4T+!(p%2omU^+A`s${6j4WTE}inUHO$qtHd(*m9q>xnxz_i1C%jUYvYz5$cxCK1>p|WH&t_k; zZs1Gcm9yuqIA02{g1u(#;t_b2>{r$*-VG1`iN$K>%isn13jP-Ffmg+M@E`GBc-4GA zf06gWtKrx2M|nTIT7EyjgAc$9@hA8pJ_xUlf0v)nhv3!opYbhx7+!-_&b#>tyhba+ zEBJDFP1a`ibG`yzvvnSpo|W(%Yk@t>(#%aOeI|*hqi-KxdYFgxb1^OcY=(^k_c+P=()Gu6>CDxSpRXr?x4)P~ zz!mfV>Fjt{5_%fgJ{%?g3i8&`? zVwop)!sPVyT29dPGBZ4pih7c*CvK9Nd7fZVJ=L}oI@Qc5fyM@eMoZM^Z8|gZkH9vXkI z^6@LkcxZ?6`v|jB`H&qC?Na^#`DZF0AMM9O6UxWevhmRSl#ib`#zSW*e}w$q%EvDn zPW0_EceiSf{fls`)Th04co5aXeXls`s(RQdSXVLY@~`J2g~RQ?w7r(lkzd{Wi(`DGzW5YxSaEI3-a?)^GZxM>oBV_F7x#%Rbmc><90n~ig`9_-=irERdXV>uxY5 zkjUj11=MM8*%3H6N#c4EFe6LB<3#@z2x+~{l@6?JDEN)JBIG1lXU#hX=O;2wB z6FGHy)(NWK^1Lm(2dqe3&aUJ?$Q&d5|r}~1%$Vok@%B<<^@&97ceEbp)K}0 z!|)D&A+Re?XYI9+3vMQ4+o;&}Te7o&QMDV@h)!~QhlS_w-I=|`&a{)h(`eQLzS^#6 z1YWcjGPB?{{fcwjmDG1`Qg&YM&qOyeCJrJkaOppIH*pRpO&mp^i4)SwAun)b?`hm@ zy0v9VL-%I)TujBJi78wsjJ%2S=p*~vxe?Bf2zQh@thA-3&mPzcRVl*nhHP1BqafXylDhE=T{_PEMz4;u{25z7`UympXA}b&V@=78CK1R{_HQMk zM%x-i;{bA$n3{o*8eSqplI@o)p;Gs!%Mo@AjYku_XGzwDf2#=$&;S4c diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/service/NifiApiService.class b/fw-nifi/target/classes/com/hzya/frame/nifi/service/NifiApiService.class index b5d5e42f7d9f089b36e6947ace75021d276101e3..8b751ea721b8d6d147084fe6ae53077c92fbad95 100644 GIT binary patch literal 6299 zcmb_gTT>iG6#j_T5`qRv2qch@tHxm%U|^Zq%*=*hjF))7 zJgViJuRdy(qGgp_4a-w-a9p=n)W!GKG^&jEUUJtl?bJW;2{=8@F{WGov}C7zdLL-lFL$ z7>osQ4d;%j8&a#`tU2uusaflJ!&|iHE@;94&u}PV&s5Ix%oStCbWMsMwk+GzJkz%L z?$vSISy0`qV_FN+=2hESR%Z>(a@BcF_iSfP)xr(xaL%(=O~;rc()I4H;~5$A*zGM7=a{)Ppy!QpzfOak#H`pUJaR;W2wEOJa3x^14iN+rkUgs)<3?9d%U z^Nf)75!>>NyB-PtE z08ubnf&E&vRnU>k&c##mV<#T9(_7Bz9|qvQ>mpv{Wj1H%8McKqKYTHLZEOq}XxB zFAzsb%o9Pe^{cajok58!R^*2mMJnWwEFn=XiZ!UV(8WoRhl1^M?nWYv;7Q6o2V*7uttR+$i697LV2r#arFGws>gk`Vs6(kUR~ zL~gYmmsAzFpF9jiFBoaS| z;6MzFdhfpKH;IQGgXg~MxoLbNNN$f`oyMoQFTOrw8(!)HLDAVw)vh}26+BapP%@)n zxF*2-VHZ8B68JogFYq9NFVpx6UnlSlZNJEQ8hW2o|+;|=gKTSeZM=WS<2Bf!Zh zz{sNJObfqTx^e7Axzs37c$sX-+Aal+MFj;f%Oyl+D(K!w+eM4qut5p9<0>W5iy`+Lru9WTfJCT%6MJ7@>%vAx6i^M^Q5( z0?+W5pd^18V%m#p%%|;q?!nWjM=wWbP{%(Y)&B>S{(;|7_bW$r+$UDn^LsBEun*1H zk7qe*_g8avA4l9Lr7~Uk+^BE>9N?#kAP4!MM+OdYOD~_F=SboIWdCodTSxsbeD;CF zYG6PDr2RDkKtJajI5WV{APxtTj#4qPqeVz+YiMg+N7F+zmI{16BCsV^;E{lZ2`VgD z=#l~x4Syqft$twoPc*lsr0i6w?4uDjxu3?CZ3sFV0qqGv zdkFf<#-Oi4c%_#L6qDH+C6iV*#aKBJ0gRIQT0EJr5k$c;91j351XgxRD@y@)Tq#6! zN|JsV9hiwgc7`@~ViU;M>9=0OFB4KEM|Te!~>&CxMtb&6(n8YOdoJ@D(t^PaWPM8E-O?aeGtzs$C&8D!5{j%v`|5fSKa#%U6|kbokjvo5D1u7smoC z?v$kC5-tazM&ORU1MAqcj;`}ELIYX`H$e9D;zOPkA4RCy8%F6~=F1hLCmE$8UQ1(= SddyIdI$V|C*TOU4I`BWoBm7PP delta 545 zcmYjNxlY4C6r6S9I5wL&I9v%3jzA0!Hwi~WK@ln>1T+W=Oq2o; z0EtUTAkk3J^E-&QCPc{cdS>>$dGmZV{ne8H{C;@@ki((@6+=2&Fl-W6G#njv{yFI7$pW$$FI;uTBP>Pp3{A63^quf~uO7ooUtW9{Nn zNk=0aHMe-M>K<*nd*zZ?=4-JiW;i$^8fH1VkPu2_QqOVZF~_hV-g!psMl6+Mp4biF z4lp>RwuzLvBVNpXab_-^V}KH?v;l)9%?JeuM`6-8MyvpZ9>8#(z?|#@lsjSyTIq~Z z4QO-_3Ft_Y1JLnXjX2tfQJ?S1&`wxoL}UpNq9L8~mdWVU6BE}~;#|7QE1=(Z<30{I z+>)dRN$IAy2fdAiW$KU#?d%7V&OH<>7<`4g707NpBV=ih2;cg$ZW$6&Y2aUcn=D7j o(xHK?fBEfZej6$D(Y$`YjdjzSe<2zxrAScdKgx5kxm+6f0n5Tc4gdfE