public class DelegatingAsyncResultFuture extends Object implements java.util.function.BiConsumer<Object,Throwable>
DelegatingResultFuture
for AsyncScalarFunction
.Constructor and Description |
---|
DelegatingAsyncResultFuture(ResultFuture<Object> delegatedResultFuture) |
Modifier and Type | Method and Description |
---|---|
void |
accept(Object o,
Throwable throwable) |
void |
addSynchronousResult(Object object) |
CompletableFuture<?> |
createAsyncFuture(DataStructureConverter<Object,Object> converter) |
Object |
getSynchronousResult(int index) |
void |
setOutputFactory(java.util.function.Function<Object,RowData> outputFactory) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
andThen
public DelegatingAsyncResultFuture(ResultFuture<Object> delegatedResultFuture)
public void addSynchronousResult(Object object)
public Object getSynchronousResult(int index)
public void setOutputFactory(java.util.function.Function<Object,RowData> outputFactory)
public CompletableFuture<?> createAsyncFuture(DataStructureConverter<Object,Object> converter)
public void accept(Object o, Throwable throwable)
accept
in interface java.util.function.BiConsumer<Object,Throwable>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.