@SupportsBatching 是 NiFi 处理器上的一个标记注解，它启用调度界面中的“运行时长（Run Duration）”配置项，使框架可在指定时间窗口内批量提交会话、复用 ProcessSession，从而在延迟与吞吐量之间进行权衡。
nifi 中 `@supportsbatching` 是 nifi 处理器上的一个标记注解，它启用调度界面中的“运行时长（run duration）”配置项，使框架可在指定时间窗口内批量提交会话、复用 processsession，从而在延迟与吞吐量之间进行权衡。
@SupportsBatching 并非功能增强型注解，而是一个调度策略声明——它向 NiFi 框架表明：该处理器支持以时间维度进行批处理调度。一旦处理器类被标注，NiFi UI 的「Scheduling」选项卡中便会显示 Run Duration（运行时长）滑块（默认隐藏），用户可据此设定单次调度周期的最大执行时间（例如 3s、10s 或 0 sec）。
其核心行为体现在两个关键机制上：
✅ Session 复用（Session Reuse）
当启用 @SupportsBatching 后，NiFi 的 ProcessSessionFactory.createSession() 在同一调度周期内可能多次返回同一个 ProcessSession 实例（而非每次新建）。这显著减少对象创建开销，并允许处理器在单个会话中累积多个 FlowFile 操作（如 transfer()、remove()、putAttribute() 等）。
✅ 延迟提交（Deferred Commit）
框架将 session.commit() 调用推迟至当前 Run Duration 周期结束时统一执行（或触发条件满足时），而非每次调用立即落盘。这意味着：
- ✅ 提升吞吐：减少对 FlowFile Repository 和 Content Repository 的 I/O 频次；
- ⚠️ 降低强一致性保障：commit() 不再代表数据已持久化——若节点崩溃，未刷盘的批次操作可能丢失；
- ❌ 禁止用于“先提交后清理”场景：例如从数据库读取后立即 commit() 再删除源记录——此时应避免使用该注解，或改用显式事务控制。
以下是一个典型使用示例（自定义处理器片段）：
@SupportsBatching // ← 关键声明
@Processor(name = "BatchCapableProcessor")
public class BatchCapableProcessor extends AbstractProcessor {
@Override
public void onTrigger(ProcessContext context, ProcessSessionFactory sessionFactory) throws ProcessException {
ProcessSession session = sessionFactory.createSession(); // 可能复用已有 session
try {
// 批量处理：一次拉取多条 FlowFile（取决于 backpressure & availability）
List<FlowFile> flowFiles = session.get(100);
for (FlowFile ff : flowFiles) {
ff = session.putAttribute(ff, "batched", "true");
session.transfer(ff, SUCCESS);
}
// 注意：此处 commit 不立即生效，由框架在周期结束时批量提交
session.commit();
} catch (Exception e) {
session.rollback(true);
throw new ProcessException(e);
}
}
}? 重要注意事项：
- Run Duration = 0 sec 表示禁用批处理，每次 onTrigger 调用均使用独立会话并立即提交，追求最低端到端延迟；
- 非零值（如 5s）意味着框架最多等待 5 秒，聚合尽可能多的 FlowFile 进行集中处理，适合高吞吐、可容忍毫秒级延迟的场景（如日志聚合、批量 API 调用）；
- 该注解不改变处理器逻辑本身，也不自动实现“批量拉取/批量写入”，开发者仍需在 onTrigger 中主动设计批量处理逻辑（如调用 session.get(n) 获取多文件）；
- 若处理器内部依赖 session.commit() 的即时持久化语义（如同步删除外部系统数据），则绝对不可使用 @SupportsBatching，否则将引入数据不一致风险。
简言之：@SupportsBatching 是 NiFi 提供的一把“性能调节杠杆”——它不替你写批量逻辑，但为你开放了按时间窗口聚合执行与提交的能力。是否启用，取决于你的用例对一致性、延迟、吞吐三者的优先级排序。
