Register
注册管道函数,以便在某些事件发生时运行。
public java.lang.String register()
public java.lang.String register(ExecutionMode mode)
public java.lang.String register(
ExecutionMode mode,
gears.operations.OnRegisteredOperation onRegister,
gears.operations.OnUnregisteredOperation onUnregistered)
注册管道函数,以便在某些事件发生时运行。 注册的函数将在每次事件发生时运行。
执行模式
名称 | 描述 |
---|---|
ASYNC | 在所有分片上异步运行。 |
ASYNC_LOCAL | 异步运行,但仅在生成事件的当前分片上运行。 |
SYNC | 仅在生成事件的同一分片上同步运行。 |
注意
如果您调用 register()
但未指定执行模式,则默认设置为 ASYNC
。参数
名称 | 类型 | 描述 |
---|---|---|
mode | ExecutionMode | 要使用的执行模式 (ASYNC/ASYNC_LOCAL/SYNC) |
onRegister | OnRegisteredOperation | 注册回调,将在每个分片注册时调用 |
onUnregistered | OnUnregisteredOperation | 取消注册回调,将在每个分片取消注册时调用 |
返回值
返回注册 ID。
示例
GearsBuilder.CreateGearsBuilder(reader).register();