资源简介
这是一个自定义nifiprocessor的实例，里面提供了五个实例，提取url页面中所有的a标签，通过redis过滤，去重，过滤等等。
代码片段和文件信息
package hylanda.processors.getatag;
import java.io.BufferedOutputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import org.apache.commons.io.IOUtils;
import org.apache.nifi.annotation.behavior.ReadsAttribute;
import org.apache.nifi.annotation.behavior.ReadsAttributes;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.behavior.WritesAttributes;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
import org.apache.nifi.annotation.documentation.SeeAlso;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.flowfile.FlowFile;
import org.apache.nifi.logging.ComponentLog;
import org.apache.nifi.processor.AbstractProcessor;
import org.apache.nifi.processor.ProcessContext;
import org.apache.nifi.processor.ProcessSession;
import org.apache.nifi.processor.ProcessorInitializationContext;
import org.apache.nifi.processor.Relationship;
import org.apache.nifi.processor.exception.ProcessException;
import org.apache.nifi.processor.util.StandardValidators;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONobject;
import hylanda.processors.getatag.util.GenUrlCrc64;
import hylanda.processors.getatag.util.IpConfig;
@Tags（{“hylandaxinwenduchaurljson“}）
@CapabilityDescription（“新闻督察用同一个taskid下的多个结果url分解成jsonarray“）
@SeeAlso（{}）
@ReadsAttributes（{@ReadsAttribute（attribute=““ description=““）}）
@WritesAttributes（{@WritesAttribute（attribute=““ description=““）}）
public class XWDCAttributeToJSON extends AbstractProcessor{
public static final PropertyDescriptor LIST = new PropertyDescriptor
.Builder（）.name（“list“）
.displayName（“list“）
.description（“url list!“）
.required（true）
.addValidator（StandardValidators.NON_EMPTY_VALIDATOR）
.build（）;
public static final PropertyDescriptor TASK_ID = new PropertyDescriptor
.Builder（）.name（“task_id“）
.displayName（“task_id“）
.description（“task id!“）
.required（true）
.addValidator（StandardValidators.NON_EMPTY_VALIDATOR）
.build（）;
public static final PropertyDescriptor SOURCE_URL = new PropertyDescriptor
.Builder（）.name（“source_url“）
.displayName（“source_url“）
.description（“source_url!“）
.required（true）
.addValidator（StandardValidators.NON_EMPTY_VALIDATOR）
.build（）;
public static final PropertyDescriptor SITE_ID = new PropertyDescriptor
.Builder（）.name（“site_id“）
.displayName（“site_id“）
.description（“site_id!“）
.required（true）
.addValidator（StandardValidators.NON_EMPTY_VALIDATOR）
.build（）;
public static final Relationship SUCCESS = new Relationship.Builder 属性 大小 日期 时间 名称
----------- --------- ---------- ----- ----
文件 445 2017-12-29 17:03 nifi-get-a-tag-processor\.classpath
文件 30 2018-01-03 17:55 nifi-get-a-tag-processor\.git\COMMIT_EDITMSG
文件 288 2018-01-03 14:44 nifi-get-a-tag-processor\.git\config
文件 23 2018-01-03 14:09 nifi-get-a-tag-processor\.git\HEAD
文件 14296 2018-01-03 17:55 nifi-get-a-tag-processor\.git\index
文件 473 2018-01-03 17:55 nifi-get-a-tag-processor\.git\logs\HEAD
文件 473 2018-01-03 17:55 nifi-get-a-tag-processor\.git\logs\refs\heads\master
文件 280 2018-01-03 17:55 nifi-get-a-tag-processor\.git\logs\refs\remotes\origin\master
文件 193 2018-01-03 17:55 nifi-get-a-tag-processor\.git\ob
文件 37332 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 218 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 50 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 1038 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 3359 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 1238 2017-12-28 16:56 nifi-get-a-tag-processor\.git\ob
文件 91 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 159 2017-12-28 16:56 nifi-get-a-tag-processor\.git\ob
文件 52 2018-01-03 17:55 nifi-get-a-tag-processor\.git\ob
文件 2343 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 159 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 50 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 349 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 776 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 63 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 64 2017-12-28 16:56 nifi-get-a-tag-processor\.git\ob
文件 184 2018-01-03 14:43 nifi-get-a-tag-processor\.git\ob
文件 49 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 211 2018-01-03 14:43 nifi-get-a-tag-processor\.git\ob
文件 189890 2018-01-03 14:13 nifi-get-a-tag-processor\.git\ob
文件 165 2018-01-03 14:43 nifi-get-a-tag-processor\.git\ob
............此处省略596个文件信息
- 上一篇：Visual Basic 6.0
- 下一篇：VC五子棋源代码 想要的速度下哦 多线程
相关资源
- STM32F103RC+ADC+DMA多通道采样LCD显示
- EPSON XP225 xp235 xp245打印机清零软件+教
- I2C读写AT24C02 基于STM32F103 cube116540
- Scratch源码
- 实验三 消息中间件应用开发：Active
- AxureUX电商产品移动端交互原型
- PID_AutoTune_v0.rar
- IAR FOR 430 破解工具
- radmin3.5.2.1完美破解版（支持win10）8
- 中国1:400万基础地理数据
- AsyncTask文件控制暂停和继续，在状态
- Remote Desktop Organizer v1.4.7 支持win10
- 虚拟光驱deamon 适用于64位服务器的
- 西门坡论坛pb框架 普通版 2.0 非常漂
- 基于STM32RCT6的步进电机驱动程序
- pthreads-w32-2-9-1-release.zip
- AXURE移动端素材元件库68580
- 酒店管理系统基于Qt Creator5）
- E4A无障碍跨程序操作类库（带源码、
- 用友NC开发API字典
- labview魔方程序
- SpringBoot+H2+mybatis-plus59130
- 安卓wifi直连app源码
- flash3.0小游戏
- AE开发Windows最短路径分析
- Navicat Premium 15汉化包.zip55438
- 登录注册界面.zip48872
- 电信中兴光猫超密获取工具使用方法
- 条码字体barcode128
- Rational Rose Common破解文件
川公网安备 51152502000135号
评论
共有 条评论