AsyncMap
异步地将记录一对一映射。
public <I extends java.io.Serializable> GearsBuilder<I> asyncMap(
gears.operations.AsyncMapOperation<T,I> mapper)
asyncMap 函数允许您使用 GearsFuture 对象异步地将管道中的每个输入记录映射到一个输出记录，一对一。
参数
类型参数
| 名称 | 描述 |
|---|---|
| I | 返回的构建器的模板类型 |
函数参数
| 名称 | 类型 | 描述 |
|---|---|---|
| mapper | 对于每个输入记录，返回一个新的输出记录 |
返回值
返回一个具有新模板类型的 GearsBuilder 对象。
示例
GearsBuilder.CreateGearsBuilder(reader).
asyncMap(r->{
GearsFuture<String> f = new GearsFuture<String>();
new Thread(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(1);
f.setResult("done");
} catch (Exception e) {
e.printStackTrace();
}
}
}).start();
return f;
});