AsyncMap
Asynchronously maps records one-to-one.
public <I extends java.io.Serializable> GearsBuilder<I> asyncMap(
gears.operations.AsyncMapOperation<T,I> mapper)
The asyncMap function allows you to use a GearsFuture object to asynchronously map each input record in the pipe to an output record, one-to-one.
Parameters
Type parameters:
| Name | Description |
|---|---|
| I | The template type of the returned builder |
Function parameters:
| Name | Type | Description |
|---|---|---|
| mapper | For each input record, returns a new output record |
Returns
Returns a GearsBuilder object with a new template type.
Example
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;
});