diff --git a/fw-nifi/pom.xml b/fw-nifi/pom.xml index 5c29d5d9..8168cf66 100644 --- a/fw-nifi/pom.xml +++ b/fw-nifi/pom.xml @@ -19,10 +19,23 @@ base-service ${revision} + + + + + + + + + - mysql - mysql-connector-java - ${mysql-connector-java} + com.squareup.okhttp3 + okhttp + + + + com.fasterxml.jackson.core + jackson-databind diff --git a/fw-nifi/src/main/java/com/hzya/frame/Main.java b/fw-nifi/src/main/java/com/hzya/frame/Main.java deleted file mode 100644 index 16eea576..00000000 --- a/fw-nifi/src/main/java/com/hzya/frame/Main.java +++ /dev/null @@ -1,7 +0,0 @@ -package com.hzya.frame; - -public class Main { - public static void main(String[] args) { - System.out.println("Hello world!"); - } -} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/NifiApplication.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/NifiApplication.java new file mode 100644 index 00000000..f8763903 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/NifiApplication.java @@ -0,0 +1,11 @@ +//package com.hzya.frame.nifi; +// +//import org.springframework.boot.SpringApplication; +//import org.springframework.boot.autoconfigure.SpringBootApplication; +// +//@SpringBootApplication(scanBasePackages = "com.hzya.frame.nifi") +//public class NifiApplication { +// public static void main(String[] args) { +// SpringApplication.run(NifiApplication.class, args); +// } +//} \ No newline at end of file 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 new file mode 100644 index 00000000..9b2f9027 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java @@ -0,0 +1,173 @@ +package com.hzya.frame.nifi.client; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.hzya.frame.nifi.config.NifiServiceConfig; +import okhttp3.*; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.net.ssl.SSLContext; +import javax.net.ssl.SSLSocketFactory; +import javax.net.ssl.TrustManager; +import javax.net.ssl.X509TrustManager; +import java.io.IOException; +import java.nio.charset.StandardCharsets; +import java.security.SecureRandom; +import java.security.cert.X509Certificate; +import java.util.concurrent.atomic.AtomicReference; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.client + * @Project：fw-nifi + * @name：NifiClient + * @Date：2025/5/14 10:00 + * @Filename：NifiClient + */ +@Component +public class NifiClient { + private final NifiServiceConfig config; + private final OkHttpClient httpClient; + private final ObjectMapper objectMapper; + private final AtomicReference accessToken = new AtomicReference<>(); + private volatile long tokenIssueTime; // Token 发行时间（毫秒） + private volatile long tokenExpiration; // Token 过期时间（毫秒） + + @Autowired + public NifiClient(NifiServiceConfig config, OkHttpClient httpClient, ObjectMapper objectMapper) { + this.config = config; + this.httpClient = httpClient; + this.objectMapper = objectMapper; + initializeToken(); + } + + private void initializeToken() { + try { + accessToken.set(getAccessToken()); + tokenIssueTime = System.currentTimeMillis(); + tokenExpiration = tokenIssueTime + (12 * 60 * 60 * 1000); // 默认 12 小时 + System.out.println("令牌已初始化，过期时间：" + new java.util.Date(tokenExpiration)); + } catch (Exception e) { + throw new RuntimeException("初始化NiFi访问令牌失败： " + e.getMessage()); + } + } + + public T get(String path, Class responseType) throws IOException { + return executeRequestWithRetry(() -> { + Request request = new Request.Builder() + .url(config.getApiUrl() + path) + .get() + .header("Authorization", "Bearer " + accessToken.get()). + build(); + return executeRequest(request, responseType); + }); + } + + public T post(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).post(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++) { + try { + checkAndRefreshToken(); + return runnable.run(); + } catch (IOException e) { + if (attempt == maxRetries - 1 || !isTokenExpiredError(e)) { + throw e; + } + System.out.println("令牌可能已过期，请刷新并重试。。。"); + try { + accessToken.set(getAccessToken()); + tokenIssueTime = System.currentTimeMillis(); + tokenExpiration = tokenIssueTime + (12 * 60 * 60 * 1000); // 默认 12 小时 + } catch (Exception ex) { + throw new IOException("刷新令牌失败： " + ex.getMessage(), e); + } + } + } + throw new IOException("已达到最大重试次数"); + } + + private void checkAndRefreshToken() throws IOException { + long currentTime = System.currentTimeMillis(); + if (currentTime > tokenExpiration - 300000) { // 提前 5 分钟刷新 + try { + accessToken.set(getAccessToken()); + tokenIssueTime = System.currentTimeMillis(); + tokenExpiration = tokenIssueTime + (12 * 60 * 60 * 1000); // 默认 12 小时 + System.out.println("令牌已刷新，到期时间： " + new java.util.Date(tokenExpiration)); + } catch (Exception e) { + throw new IOException("刷新令牌失败： " + e.getMessage()); + } + } + } + + private boolean isTokenExpiredError(IOException e) { + // 判断是否为 401 错误（Token 过期） + return e.getMessage().contains("401") || e.getMessage().contains("Unauthorized"); + } + + private T executeRequest(Request request, Class responseType) throws IOException { + try (Response response = httpClient.newCall(request).execute()) { + if (!response.isSuccessful()) { + throw new IOException("意外的响应码: " + response); + } + String responseBody = response.body().string(); + return objectMapper.readValue(responseBody, responseType); + } + } + + public synchronized String getAccessToken() throws Exception { + // 创建信任所有证书的 OkHttpClient +// OkHttpClient client = httpClient.newBuilder().sslSocketFactory(createTrustAllSslSocketFactory(), createTrustAllTrustManager()).hostnameVerifier((hostname, session) -> true).build(); + + MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded"); + RequestBody body = RequestBody.create(mediaType, "username=" + config.getUsername() + "&password=" + config.getPassword()); + Request request = new Request.Builder().url(config.getApiUrl() + "/access/token").post(body).addHeader("Content-Type", "application/x-www-form-urlencoded").addHeader("Accept", "*/*").addHeader("User-Agent", "fw-nifi-client/1.0").addHeader("Connection", "keep-alive").build(); + + try (Response response = httpClient.newCall(request).execute()) { + if (!response.isSuccessful()) { + throw new IOException("获取访问令牌失败，响应码: " + response.code() + " - " + response.message()); + } + byte[] bytes = response.body().bytes(); + String newToken = new String(bytes, StandardCharsets.UTF_8); + return newToken; + } + } + +// private SSLSocketFactory createTrustAllSslSocketFactory() throws Exception { +// SSLContext sslContext = SSLContext.getInstance("SSL"); +// sslContext.init(null, new TrustManager[]{createTrustAllTrustManager()}, new SecureRandom()); +// return sslContext.getSocketFactory(); +// } + +// private X509TrustManager createTrustAllTrustManager() { +// return new X509TrustManager() { +// @Override +// public void checkClientTrusted(X509Certificate[] chain, String authType) { +// } +// +// @Override +// public void checkServerTrusted(X509Certificate[] chain, String authType) { +// } +// +// @Override +// public X509Certificate[] getAcceptedIssuers() { +// return new X509Certificate[0]; +// } +// }; +// } + + // 功能接口，用于重试逻辑 + @FunctionalInterface + private interface IOExceptionRunnable { + T run() throws IOException; + } +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/config/HttpClientConfig.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/config/HttpClientConfig.java new file mode 100644 index 00000000..da9273d1 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/config/HttpClientConfig.java @@ -0,0 +1,59 @@ +package com.hzya.frame.nifi.config; + +import okhttp3.OkHttpClient; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import javax.net.ssl.SSLContext; +import javax.net.ssl.SSLSocketFactory; +import javax.net.ssl.TrustManager; +import javax.net.ssl.X509TrustManager; +import java.security.SecureRandom; +import java.security.cert.X509Certificate; +import java.util.concurrent.TimeUnit; + +/** + * OkHttpClient配置类 + * @Author：liuyang + * @Package：com.hzya.frame.nifi.config + * @Project：fw-nifi + * @name：HttpClientConfig + * @Date：2025/5/14 11:45 + * @Filename：HttpClientConfig + */ +@Configuration +public class HttpClientConfig { + + @Bean + public OkHttpClient okHttpClient() throws Exception { + return new OkHttpClient.Builder().sslSocketFactory(createTrustAllSslSocketFactory(), createTrustAllTrustManager()) + .hostnameVerifier((hostname, session) -> true) + .connectTimeout(60, TimeUnit.SECONDS) // 连接超时时间 + .readTimeout(60, TimeUnit.SECONDS) // 读取超时时间 + .writeTimeout(60, TimeUnit.SECONDS) // 写入超时时间 + .build(); + } + + private SSLSocketFactory createTrustAllSslSocketFactory() throws Exception { + SSLContext sslContext = SSLContext.getInstance("SSL"); + sslContext.init(null, new TrustManager[]{createTrustAllTrustManager()}, new SecureRandom()); + return sslContext.getSocketFactory(); + } + + private X509TrustManager createTrustAllTrustManager() { + return new X509TrustManager() { + @Override + public void checkClientTrusted(X509Certificate[] chain, String authType) { + } + + @Override + public void checkServerTrusted(X509Certificate[] chain, String authType) { + } + + @Override + public X509Certificate[] getAcceptedIssuers() { + return new X509Certificate[0]; + } + }; + } +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/config/JacksonConfig.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/config/JacksonConfig.java new file mode 100644 index 00000000..5229efcb --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/config/JacksonConfig.java @@ -0,0 +1,25 @@ +package com.hzya.frame.nifi.config; + +import com.fasterxml.jackson.databind.ObjectMapper; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.config + * @Project：fw-nifi + * @name：JacksonConfig + * @Date：2025/5/14 11:54 + * @Filename：JacksonConfig + */ +@Configuration +public class JacksonConfig { + + @Bean + public ObjectMapper objectMapper() { + ObjectMapper objectMapper = new ObjectMapper(); + // 可根据需求自定义配置，例如： + objectMapper.findAndRegisterModules(); // 自动注册模块 + return objectMapper; + } +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/config/NifiServiceConfig.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/config/NifiServiceConfig.java new file mode 100644 index 00000000..1a4e1c63 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/config/NifiServiceConfig.java @@ -0,0 +1,49 @@ +package com.hzya.frame.nifi.config; + +import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Configuration; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.config + * @Project：fw-nifi + * @name：NifiConfig + * @Date：2025/5/14 09:59 + * @Filename：NifiConfig + */ +@Configuration +public class NifiServiceConfig { + + @Value("${nifi.api.url:https://192.168.2.233:8443/nifi-api}") + private String apiUrl; + + @Value("${nifi.api.username:hzya}") + private String username; + + @Value("${nifi.api.password:hzya1314*nifi}") + private String password; + + public String getApiUrl() { + return apiUrl; + } + + public void setApiUrl(String apiUrl) { + this.apiUrl = apiUrl; + } + + public String getUsername() { + return username; + } + + public void setUsername(String username) { + this.username = username; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/ProcessorConfig.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/ProcessorConfig.java new file mode 100644 index 00000000..dfe2b68d --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/ProcessorConfig.java @@ -0,0 +1,27 @@ +package com.hzya.frame.nifi.model; + +import com.fasterxml.jackson.annotation.JsonProperty; +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model + * @Project：fw-nifi + * @name：ProcessorConfig + * @Date：2025/5/14 10:01 + * @Filename：ProcessorConfig + */ +@Data +public class ProcessorConfig { + @JsonProperty("name") + private String name; + + @JsonProperty("type") + private String type; + + @JsonProperty("id") + private String id; + + @JsonProperty("state") + private String state; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AggregateSnapshot.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AggregateSnapshot.java new file mode 100644 index 00000000..70b2166e --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AggregateSnapshot.java @@ -0,0 +1,30 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class AggregateSnapshot { + private String id; + private String groupId; + private String name; + private String type; + private String runStatus; + private String executionNode; + private String bytesRead; + private String bytesWritten; + private String read; + private String written; + private String flowFilesIn; + private String bytesIn; + private String input; + private String flowFilesOut; + private String bytesOut; + private String output; + private String taskCount; + private String tasksDurationNanos; + private String tasks; + private String tasksDuration; + private String activeThreadCount; + private String terminatedThreadCount; + private ProcessingPerformanceStatus processingPerformanceStatus; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AllowableValue.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AllowableValue.java new file mode 100644 index 00000000..57200351 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AllowableValue.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class AllowableValue { + private String displayName; + private String value; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AllowableValues.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AllowableValues.java new file mode 100644 index 00000000..f2d87dd8 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AllowableValues.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class AllowableValues { + private AllowableValue allowableValue; + private String canRead; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToIgnore.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToIgnore.java new file mode 100644 index 00000000..5ae2a179 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToIgnore.java @@ -0,0 +1,18 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class AttributesToIgnore { + private String name; + private String displayName; + private String description; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToIgnoreRegex.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToIgnoreRegex.java new file mode 100644 index 00000000..2d78b142 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToIgnoreRegex.java @@ -0,0 +1,18 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class AttributesToIgnoreRegex { + private String name; + private String displayName; + private String description; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToLog.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToLog.java new file mode 100644 index 00000000..b0fce5c7 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToLog.java @@ -0,0 +1,18 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class AttributesToLog { + private String name; + private String displayName; + private String description; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToLogRegex.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToLogRegex.java new file mode 100644 index 00000000..b816e0e9 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/AttributesToLogRegex.java @@ -0,0 +1,19 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class AttributesToLogRegex { + private String name; + private String displayName; + private String description; + private String defaultValue; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Breadcrumb.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Breadcrumb.java new file mode 100644 index 00000000..85ad056a --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Breadcrumb.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Breadcrumb { + private String id; + private String name; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bulletin.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bulletin.java new file mode 100644 index 00000000..73fe3bdf --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bulletin.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Bulletin { + private String id; + private String category; + private String groupId; + private String sourceId; + private String sourceName; + private String level; + private String message; + private String timestamp; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bulletins.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bulletins.java new file mode 100644 index 00000000..9dcc9f55 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bulletins.java @@ -0,0 +1,13 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Bulletins { + private String id; + private String groupId; + private String sourceId; + private String timestamp; + private String canRead; + private Bulletin bulletin; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bundle.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bundle.java new file mode 100644 index 00000000..6361902a --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Bundle.java @@ -0,0 +1,10 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Bundle { + private String group; + private String artifact; + private String version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/CharacterSet.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/CharacterSet.java new file mode 100644 index 00000000..13f23caa --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/CharacterSet.java @@ -0,0 +1,19 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class CharacterSet { + private String name; + private String displayName; + private String description; + private String defaultValue; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Component.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Component.java new file mode 100644 index 00000000..7c099a09 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Component.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Component { + private String id; + private String name; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Component2.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Component2.java new file mode 100644 index 00000000..abbf14f6 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Component2.java @@ -0,0 +1,31 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class Component2 { + private String id; + private String name; + private String versionedComponentId; + private String parentGroupId; + private Position position; + private String type; + private Bundle bundle; + private String state; + private Object style; + private List relationships; + private String supportsParallelProcessing; + private String supportsEventDriven; + private String supportsBatching; + private String supportsSensitiveDynamicProperties; + private String persistsState; + private String restricted; + private String deprecated; + private String executionNodeRestricted; + private String multipleVersionsAvailable; + private String inputRequirement; + private String validationStatus; + private String extensionMissing; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Config.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Config.java new file mode 100644 index 00000000..ce7674f4 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Config.java @@ -0,0 +1,27 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class Config { + private Properties properties; + private Descriptors descriptors; + private String schedulingPeriod; + private String schedulingStrategy; + private String executionNode; + private String penaltyDuration; + private String yieldDuration; + private String bulletinLevel; + private String runDurationMillis; + private String concurrentlySchedulableTaskCount; + private String comments; + private String lossTolerant; + private DefaultConcurrentTasks defaultConcurrentTasks; + private DefaultSchedulingPeriod defaultSchedulingPeriod; + private String retryCount; + private List retriedRelationships; + private String backoffMechanism; + private String maxBackoffPeriod; +} \ 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 new file mode 100644 index 00000000..455a6a43 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Connections.java @@ -0,0 +1,24 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class Connections { + private Revision revision; + private String id; + private String uri; + private Permissions permissions; + private Component component; + private Status status; + private List bends; + private String labelIndex; + private String zIndex; + private String sourceId; + private String sourceGroupId; + private String sourceType; + private String destinationId; + private String destinationGroupId; + private String destinationType; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/DefaultConcurrentTasks.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/DefaultConcurrentTasks.java new file mode 100644 index 00000000..9cf2891d --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/DefaultConcurrentTasks.java @@ -0,0 +1,14 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import com.fasterxml.jackson.annotation.JsonProperty; +import lombok.Data; + +@Data +public class DefaultConcurrentTasks { + @JsonProperty("TIMER_DRIVEN") + private String tIMERDRIVEN; + @JsonProperty("EVENT_DRIVEN") + private String eVENTDRIVEN; + @JsonProperty("CRON_DRIVEN") + private String cRONDRIVEN; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/DefaultSchedulingPeriod.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/DefaultSchedulingPeriod.java new file mode 100644 index 00000000..f7de79fe --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/DefaultSchedulingPeriod.java @@ -0,0 +1,12 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import com.fasterxml.jackson.annotation.JsonProperty; +import lombok.Data; + +@Data +public class DefaultSchedulingPeriod { + @JsonProperty("TIMER_DRIVEN") + private String tIMERDRIVEN; + @JsonProperty("CRON_DRIVEN") + private String cRONDRIVEN; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Descriptors.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Descriptors.java new file mode 100644 index 00000000..aea6f9f2 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Descriptors.java @@ -0,0 +1,37 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import com.fasterxml.jackson.annotation.JsonProperty; +import lombok.Data; + +@Data +public class Descriptors { + @JsonProperty("Log Level") + private LogLevel logLevel; + + @JsonProperty("Log Payload") + private LogPayload logPayload; + + @JsonProperty("Attributes to Log") + private AttributesToLog attributesToLog; + + @JsonProperty("attributes-to-log-regex") + private AttributesToLogRegex attributesToLogRegex; + + @JsonProperty("Attributes to Ignore") + private AttributesToIgnore attributesToIgnore; + + @JsonProperty("attributes-to-ignore-regex") + private AttributesToIgnoreRegex attributesToIgnoreRegex; + + @JsonProperty("Log FlowFile Properties") + private LogFlowFileProperties logFlowFileProperties; + + @JsonProperty("Output Format") + private OutputFormat outputFormat; + + @JsonProperty("Log prefix") + private LogPrefix logprefix; + + @JsonProperty("character-set") + private CharacterSet characterSet; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Destination.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Destination.java new file mode 100644 index 00000000..1b279d5c --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Destination.java @@ -0,0 +1,14 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Destination { + private String id; + private String versionedComponentId; + private String type; + private String groupId; + private String name; + private String running; + private String comments; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Dimensions.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Dimensions.java new file mode 100644 index 00000000..53e28861 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Dimensions.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Dimensions { + private String width; + private String height; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Flow.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Flow.java new file mode 100644 index 00000000..42b137d3 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Flow.java @@ -0,0 +1,17 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class Flow { + private List processGroups; + private List remoteProcessGroups; + private List processors; + private List inputPorts; + private List outputPorts; + private List connections; + private List labels; + private List funnels; +} \ No newline at end of file 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 new file mode 100644 index 00000000..b29862ef --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/InputPorts.java @@ -0,0 +1,19 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class InputPorts { + private Revision revision; + private String id; + private String uri; + private Position position; + private Permissions permissions; + private List bulletins; + private Component component; + private Status status; + private String portType; + private OperatePermissions operatePermissions; +} \ No newline at end of file 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 new file mode 100644 index 00000000..0de5546c --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Labels.java @@ -0,0 +1,15 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Labels { + private Revision revision; + private String id; + private String uri; + private Position position; + private Permissions permissions; + private Dimensions dimensions; + private String zIndex; + private Component component; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogFlowFileProperties.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogFlowFileProperties.java new file mode 100644 index 00000000..c846b058 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogFlowFileProperties.java @@ -0,0 +1,20 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class LogFlowFileProperties { + private String name; + private String displayName; + private String description; + private String defaultValue; + private List allowableValues; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogLevel.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogLevel.java new file mode 100644 index 00000000..c06f8db2 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogLevel.java @@ -0,0 +1,20 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class LogLevel { + private String name; + private String displayName; + private String description; + private String defaultValue; + private List allowableValues; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogPayload.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogPayload.java new file mode 100644 index 00000000..e9cae44f --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogPayload.java @@ -0,0 +1,20 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class LogPayload { + private String name; + private String displayName; + private String description; + private String defaultValue; + private List allowableValues; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogPrefix.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogPrefix.java new file mode 100644 index 00000000..bcdddf5e --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/LogPrefix.java @@ -0,0 +1,18 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class LogPrefix { + private String name; + private String displayName; + private String description; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OperatePermissions.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OperatePermissions.java new file mode 100644 index 00000000..339abee1 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OperatePermissions.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class OperatePermissions { + 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/processgroupid/OutputFormat.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputFormat.java new file mode 100644 index 00000000..85dd79b7 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputFormat.java @@ -0,0 +1,20 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class OutputFormat { + private String name; + private String displayName; + private String description; + private String defaultValue; + private List allowableValues; + private String required; + private String sensitive; + private String dynamic; + private String supportsEl; + private String expressionLanguageScope; + private List dependencies; +} \ No newline at end of file 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 new file mode 100644 index 00000000..9c8baab4 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/OutputPorts.java @@ -0,0 +1,19 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class OutputPorts { + private Revision revision; + private String id; + private String uri; + private Position position; + private Permissions permissions; + private List bulletins; + private Component component; + private Status status; + private String portType; + private OperatePermissions operatePermissions; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ParameterContext.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ParameterContext.java new file mode 100644 index 00000000..778dcf85 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ParameterContext.java @@ -0,0 +1,10 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class ParameterContext { + private String id; + private Permissions permissions; + private Component component; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ParentBreadcrumb.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ParentBreadcrumb.java new file mode 100644 index 00000000..c95c2596 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ParentBreadcrumb.java @@ -0,0 +1,10 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class ParentBreadcrumb { + private String id; + private Permissions permissions; + private Breadcrumb breadcrumb; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Permissions.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Permissions.java new file mode 100644 index 00000000..bed0e5d3 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Permissions.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Permissions { + 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/processgroupid/Position.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Position.java new file mode 100644 index 00000000..8463180e --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Position.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Position { + 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/processgroupid/ProcessGroupFlow.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ProcessGroupFlow.java new file mode 100644 index 00000000..8eaf9f5e --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ProcessGroupFlow.java @@ -0,0 +1,14 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class ProcessGroupFlow { + private String id; + private String uri; + private String parentGroupId; + private ParameterContext parameterContext; + private Breadcrumb breadcrumb; + private Flow flow; + private String lastRefreshed; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ProcessGroupsId.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ProcessGroupsId.java new file mode 100644 index 00000000..189547a1 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ProcessGroupsId.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class ProcessGroupsId { + private Permissions permissions; + private ProcessGroupFlow processGroupFlow; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ProcessingPerformanceStatus.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ProcessingPerformanceStatus.java new file mode 100644 index 00000000..b0436353 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/ProcessingPerformanceStatus.java @@ -0,0 +1,13 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class ProcessingPerformanceStatus { + 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/processgroupid/Processors.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java new file mode 100644 index 00000000..2a8f9a1c --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Processors.java @@ -0,0 +1,19 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +import java.util.List; + +@Data +public class Processors { + private Revision revision; + private String id; + private String uri; + private Position position; + private Permissions permissions; + private List bulletins; + private Component2 component; + private String inputRequirement; + private Status status; + private OperatePermissions operatePermissions; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Properties.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Properties.java new file mode 100644 index 00000000..6ebbc446 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Properties.java @@ -0,0 +1,44 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import com.fasterxml.jackson.annotation.JsonProperty; +import lombok.Data; + +/** + * Auto-generated: 2025-05-14 16:51:34 + * + * @author lzltool.com + * @website https://www.lzltool.com/JsonToJava + */ +@Data +public class Properties { + + @JsonProperty("Log Level") + private String logLevel; + + @JsonProperty("Log Payload") + private String logPayload; + + @JsonProperty("Attributes to Log") + private String attributesToLog; + + @JsonProperty("attributes-to-log-regex") + private String attributesToLogRegex; + + @JsonProperty("Attributes to Ignore") + private String attributesToIgnore; + + @JsonProperty("attributes-to-ignore-regex") + private String attributesToIgnoreRegex; + + @JsonProperty("Log FlowFile Properties") + private String logFlowFileProperties; + + @JsonProperty("Output Format") + private String outputFormat; + + @JsonProperty("Log prefix") + private String logPrefix; + + @JsonProperty("character-set") + private String characterSet; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Relationships.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Relationships.java new file mode 100644 index 00000000..9afc6874 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Relationships.java @@ -0,0 +1,11 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Relationships { + private String name; + private String description; + private String autoTerminate; + private String retry; +} \ No newline at end of file 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/Revision.java new file mode 100644 index 00000000..bff55741 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Revision.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Revision { + private int version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Source.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Source.java new file mode 100644 index 00000000..76b9aaab --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Source.java @@ -0,0 +1,14 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Source { + private String id; + private String versionedComponentId; + private String type; + private String groupId; + private String name; + private String running; + private String comments; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Status.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Status.java new file mode 100644 index 00000000..5d8a7de6 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Status.java @@ -0,0 +1,13 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Status { + private String groupId; + private String id; + private String name; + private String runStatus; + private String statsLastRefreshed; + private AggregateSnapshot aggregateSnapshot; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Style.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Style.java new file mode 100644 index 00000000..b8b529df --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgroupid/Style.java @@ -0,0 +1,7 @@ +package com.hzya.frame.nifi.model.processgroupid; + +import lombok.Data; + +@Data +public class Style { +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/AggregateSnapshot.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/AggregateSnapshot.java new file mode 100644 index 00000000..fecf336c --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/AggregateSnapshot.java @@ -0,0 +1,43 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +/** + * Auto-generated: 2025-05-14 15:30:8 + * + * @author bejson.com (i@bejson.com) + * @website http://www.bejson.com/java2pojo/ + */ +@Data +public class AggregateSnapshot { + 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 ProcessingPerformanceStatus processingPerformanceStatus; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb.java new file mode 100644 index 00000000..342dc679 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb.java @@ -0,0 +1,10 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Breadcrumb { + private String id; + private Permissions permissions; + private Breadcrumb2 breadcrumb; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb2.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb2.java new file mode 100644 index 00000000..6e3ef175 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb2.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Breadcrumb2 { + private String id; + private String name; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Bulletin.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Bulletin.java new file mode 100644 index 00000000..4aa55489 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Bulletin.java @@ -0,0 +1,23 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.processgroup + * @Project：fw-nifi + * @name：Bulletin + * @Date：2025/5/14 15:59 + * @Filename：Bulletin + */ +@Data +public class Bulletin { + private String id; + private String category; + private String groupId; + private String sourceId; + private String sourceName; + private String level; + private String message; + private String timestamp; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Bulletins.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Bulletins.java new file mode 100644 index 00000000..985dc833 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Bulletins.java @@ -0,0 +1,21 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.processgroup + * @Project：fw-nifi + * @name：Bulletin + * @Date：2025/5/14 15:57 + * @Filename：Bulletin + */ +@Data +public class Bulletins { + private String id; + private String groupId; + private String sourceId; + private String timestamp; + private String canRead; + private Bulletin bulletin; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component.java new file mode 100644 index 00000000..5e79e2af --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component.java @@ -0,0 +1,37 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Component { + private String id; + private String versionedComponentId; + private String parentGroupId; + private Position position; + private String name; + private String comments; + private Variables variables; + private String flowfileConcurrency; + private String flowfileOutboundPolicy; + private String defaultFlowFileExpiration; + private String defaultBackPressureObjectThreshold; + private String defaultBackPressureDataSizeThreshold; + private String logFileSuffix; + 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/processgrouproot/Component2.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component2.java new file mode 100644 index 00000000..16164c5b --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component2.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Component2 { + private String id; + private String name; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Flow.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Flow.java new file mode 100644 index 00000000..bbcdd6ee --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Flow.java @@ -0,0 +1,17 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +import java.util.List; + +@Data +public class Flow { + private List processGroups; + private List remoteProcessGroups; + private List processors; + private List inputPorts; + private List outputPorts; + private List connections; + private List labels; + private List funnels; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ParameterContext.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ParameterContext.java new file mode 100644 index 00000000..fe77be98 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ParameterContext.java @@ -0,0 +1,18 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.model.processgrouproot + * @Project：fw-nifi + * @name：ParameterContext + * @Date：2025/5/14 16:43 + * @Filename：ParameterContext + */ +@Data +public class ParameterContext { + private String id; + private Permissions permissions; + private Component2 component; +} diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Permissions.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Permissions.java new file mode 100644 index 00000000..7d1a4d49 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Permissions.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Permissions { + 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/processgrouproot/Position.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Position.java new file mode 100644 index 00000000..acc8d66a --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Position.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Position { + 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/processgrouproot/ProcessGroupFlow.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupFlow.java new file mode 100644 index 00000000..61a39682 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupFlow.java @@ -0,0 +1,16 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class ProcessGroupFlow { + private String id; + private String uri; + private Breadcrumb breadcrumb; + private Flow flow; + private String lastRefreshed; + //查询单个流程组 + private String parentGroupId; + //查询单个流程组 + private ParameterContext parameterContext; +} \ 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 new file mode 100644 index 00000000..ac1e25d4 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java @@ -0,0 +1,34 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +import java.util.List; + +@Data +public class ProcessGroups { + private Revision revision; + private String id; + private String uri; + private Position position; + private Permissions permissions; + private List bulletins; + private Component component; + private Status 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/processgrouproot/ProcessGroupsRoot.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupsRoot.java new file mode 100644 index 00000000..9de53dec --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupsRoot.java @@ -0,0 +1,9 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class ProcessGroupsRoot { + private Permissions permissions; + private ProcessGroupFlow processGroupFlow; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessingPerformanceStatus.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessingPerformanceStatus.java new file mode 100644 index 00000000..c3f7e549 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessingPerformanceStatus.java @@ -0,0 +1,13 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class ProcessingPerformanceStatus { + 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/processgrouproot/Revision.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision.java new file mode 100644 index 00000000..b152031a --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Revision.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Revision { + private String version; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Status.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Status.java new file mode 100644 index 00000000..f2d1074a --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Status.java @@ -0,0 +1,11 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Status { + private String id; + private String name; + private String statsLastRefreshed; + private AggregateSnapshot aggregateSnapshot; +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Variables.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Variables.java new file mode 100644 index 00000000..35cd19f8 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Variables.java @@ -0,0 +1,8 @@ +package com.hzya.frame.nifi.model.processgrouproot; + +import lombok.Data; + +@Data +public class Variables { + +} \ 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 new file mode 100644 index 00000000..1a79d26f --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java @@ -0,0 +1,46 @@ +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.processgrouproot.ProcessGroupsRoot; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.service + * @Project：fw-nifi + * @name：NifiService + * @Date：2025/5/14 10:02 + * @Filename：NifiService + */ +@Service +public class NifiApiService { + + private final NifiClient client; + + @Autowired + public NifiApiService(NifiClient client) { + this.client = client; + } + + /** + * 获取token + */ + public String getAccessToken() throws Exception { + return client.getAccessToken(); + } + + /** + * 查询全部流程组或指定流程组 + */ + public ProcessGroupsRoot queryFlowProcessGroupsRoot(String flowGroupId) throws Exception { + ProcessGroupsRoot processGroupsRoot = null; + if (flowGroupId != null) { + processGroupsRoot = client.get(StrUtil.format("/flow/process-groups/{}", flowGroupId), ProcessGroupsRoot.class); + } else { + processGroupsRoot = client.get("/flow/process-groups/root", ProcessGroupsRoot.class); + } + return processGroupsRoot; + } +} \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/util/JsonUtil.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/util/JsonUtil.java new file mode 100644 index 00000000..e21fcfa9 --- /dev/null +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/util/JsonUtil.java @@ -0,0 +1,31 @@ +package com.hzya.frame.nifi.util; + +import com.fasterxml.jackson.databind.ObjectMapper; +import org.springframework.stereotype.Component; + +/** + * @Author：liuyang + * @Package：com.hzya.frame.nifi.util + * @Project：fw-nifi + * @name：JsonUtil + * @Date：2025/5/14 10:03 + * @Filename：JsonUtil + */ +@Component +public class JsonUtil { + + private final ObjectMapper objectMapper; + + public JsonUtil(ObjectMapper objectMapper) { + this.objectMapper = objectMapper; + } + + public String toJson(Object obj) throws Exception { + return objectMapper.writeValueAsString(obj); + } + + public T fromJson(String json, Class clazz) throws Exception { + return objectMapper.readValue(json, clazz); + } + +} diff --git a/fw-nifi/src/test/java/JSONata4Java.java b/fw-nifi/src/test/java/JSONata4Java.java new file mode 100644 index 00000000..47a3f375 --- /dev/null +++ b/fw-nifi/src/test/java/JSONata4Java.java @@ -0,0 +1,43 @@ +//import com.bazaarvoice.jolt.Chainr; +//import com.bazaarvoice.jolt.JsonUtils; +//import com.fasterxml.jackson.databind.JsonNode; +//import com.fasterxml.jackson.databind.ObjectMapper; +// +//import java.io.File; +//import java.io.FileInputStream; +//import java.io.InputStream; +//import java.util.List; +//import java.util.Map; +// +///** +// * @Author：liuyang +// * @Package：PACKAGE_NAME +// * @Project：fw-nifi +// * @name：JSONata4Java +// * @Date：2025/5/13 15:42 +// * @Filename：JSONata4Java +// */ +//public class JSONata4Java { +// public static void main(String[] args) throws Exception { +// // 原始 JSON 数据 +// String aJson = "{ \"id\": 1, \"name\": \"ObjectA\" }"; +// String bJson = "[{ \"id\": 1, \"value\": \"DataB1\" }, { \"id\": 2, \"value\": \"DataB2\" }]"; +// String cJson = "[{ \"id\": 1, \"value\": \"DataC1\" }, { \"id\": 3, \"value\": \"DataC3\" }]"; +// +// // 合并为 Jolt 输入格式 +// String inputJson = "{ \"a\": " + aJson + ", \"b\": " + bJson + ", \"c\": " + cJson + " }"; +// +// // 加载 Jolt 转换规则 +// File newFile = new File("/Users/liuyang/workspaces/hzya/fw-nifi/fw-nifi/src/test/java/spec.json"); +// InputStream inputStream = new FileInputStream(newFile); +// List spec = JsonUtils.jsonToList(inputStream); +// Chainr chainr = Chainr.fromSpec(spec); +// +// // 执行转换 +// Map input = JsonUtils.jsonToMap(inputJson); +// Map output = (Map) chainr.transform(input); +// +// // 输出结果 +// System.out.println(JsonUtils.toPrettyJsonString(output)); +// } +//} diff --git a/fw-nifi/src/test/java/TestNifiConfig.java b/fw-nifi/src/test/java/TestNifiConfig.java new file mode 100644 index 00000000..41bb89a4 --- /dev/null +++ b/fw-nifi/src/test/java/TestNifiConfig.java @@ -0,0 +1,28 @@ +import com.hzya.frame.nifi.service.NifiApiService; +import org.junit.Test; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.context.SpringBootTest; + +/** + * @Author：liuyang + * @Package：PACKAGE_NAME + * @Project：fw-nifi + * @name：TestNifiConfig + * @Date：2025/5/14 11:26 + * @Filename：TestNifiConfig + */ +@SpringBootTest +public class TestNifiConfig { + +// @Autowired +// private NifiApiService nifiService; +// +// @Test +// public void testCreateProcessor() { +// try { +// nifiService.getAccessToken(); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } +} diff --git a/fw-nifi/src/test/java/spec.json b/fw-nifi/src/test/java/spec.json new file mode 100644 index 00000000..a7b76001 --- /dev/null +++ b/fw-nifi/src/test/java/spec.json @@ -0,0 +1,35 @@ +[ + { + "operation": "shift", + "spec": { + "a": { + "id": "id", + "name": "name" + }, + "b": { + "*": { + "id": { + "@(2,a.id)": { + "@2": { + "value": "matchedB.value", + "#B": "matchedB.source" + } + } + } + } + }, + "c": { + "*": { + "id": { + "@(2,a.id)": { + "@2": { + "value": "matchedC.value", + "#C": "matchedC.source" + } + } + } + } + } + } + } +] \ No newline at end of file diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient$IOExceptionRunnable.class b/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient$IOExceptionRunnable.class new file mode 100644 index 00000000..e4a95419 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient$IOExceptionRunnable.class differ 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 new file mode 100644 index 00000000..0030e6c2 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/client/NifiClient.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/config/HttpClientConfig$1.class b/fw-nifi/target/classes/com/hzya/frame/nifi/config/HttpClientConfig$1.class new file mode 100644 index 00000000..0aaeacf7 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/config/HttpClientConfig$1.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/config/HttpClientConfig.class b/fw-nifi/target/classes/com/hzya/frame/nifi/config/HttpClientConfig.class new file mode 100644 index 00000000..88cbed1d Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/config/HttpClientConfig.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/config/JacksonConfig.class b/fw-nifi/target/classes/com/hzya/frame/nifi/config/JacksonConfig.class new file mode 100644 index 00000000..c4261817 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/config/JacksonConfig.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/config/NifiServiceConfig.class b/fw-nifi/target/classes/com/hzya/frame/nifi/config/NifiServiceConfig.class new file mode 100644 index 00000000..339ca0c9 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/config/NifiServiceConfig.class differ 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 new file mode 100644 index 00000000..15d66f3c Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/ProcessorConfig.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/AggregateSnapshot.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/AggregateSnapshot.class new file mode 100644 index 00000000..03395662 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/AggregateSnapshot.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb.class new file mode 100644 index 00000000..81ee868d Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb2.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb2.class new file mode 100644 index 00000000..ee633dc1 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Breadcrumb2.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Bulletin.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Bulletin.class new file mode 100644 index 00000000..f5fad748 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Bulletin.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Bulletins.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Bulletins.class new file mode 100644 index 00000000..ff91c519 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Bulletins.class differ 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 new file mode 100644 index 00000000..cf93f7f1 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Component.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Flow.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Flow.class new file mode 100644 index 00000000..d2c561d9 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Flow.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Permissions.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Permissions.class new file mode 100644 index 00000000..2169808e Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Permissions.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Position.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Position.class new file mode 100644 index 00000000..e0977a3b Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Position.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupFlow.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupFlow.class new file mode 100644 index 00000000..dd5de530 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupFlow.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.class new file mode 100644 index 00000000..bcedd4cc Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupsRoot.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupsRoot.class new file mode 100644 index 00000000..d20f5fd2 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessGroupsRoot.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessingPerformanceStatus.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessingPerformanceStatus.class new file mode 100644 index 00000000..8fdc7cb2 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/ProcessingPerformanceStatus.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Revision.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Revision.class new file mode 100644 index 00000000..4db82529 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Revision.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Status.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Status.class new file mode 100644 index 00000000..fc3e32fd Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Status.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Variables.class b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Variables.class new file mode 100644 index 00000000..b46d00d3 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/model/processgrouproot/Variables.class differ 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 new file mode 100644 index 00000000..165d72db Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/service/NifiApiService.class differ diff --git a/fw-nifi/target/classes/com/hzya/frame/nifi/util/JsonUtil.class b/fw-nifi/target/classes/com/hzya/frame/nifi/util/JsonUtil.class new file mode 100644 index 00000000..db918214 Binary files /dev/null and b/fw-nifi/target/classes/com/hzya/frame/nifi/util/JsonUtil.class differ diff --git a/fw-nifi/target/classes/main/webapp/WEB-INF/web.xml b/fw-nifi/target/classes/main/webapp/WEB-INF/web.xml new file mode 100644 index 00000000..d80081d1 --- /dev/null +++ b/fw-nifi/target/classes/main/webapp/WEB-INF/web.xml @@ -0,0 +1,6 @@ + + + \ No newline at end of file diff --git a/fw-nifi/target/classes/test/java/spec.json b/fw-nifi/target/classes/test/java/spec.json new file mode 100644 index 00000000..a7b76001 --- /dev/null +++ b/fw-nifi/target/classes/test/java/spec.json @@ -0,0 +1,35 @@ +[ + { + "operation": "shift", + "spec": { + "a": { + "id": "id", + "name": "name" + }, + "b": { + "*": { + "id": { + "@(2,a.id)": { + "@2": { + "value": "matchedB.value", + "#B": "matchedB.source" + } + } + } + } + }, + "c": { + "*": { + "id": { + "@(2,a.id)": { + "@2": { + "value": "matchedC.value", + "#C": "matchedC.source" + } + } + } + } + } + } + } +] \ No newline at end of file diff --git a/fw-nifi/target/test-classes/TestNifiConfig.class b/fw-nifi/target/test-classes/TestNifiConfig.class new file mode 100644 index 00000000..2ea8f3ec Binary files /dev/null and b/fw-nifi/target/test-classes/TestNifiConfig.class differ