Package org.apache.opendal

Class AsyncExecutor

java.lang.Object

org.apache.opendal.NativeObject

org.apache.opendal.AsyncExecutor

All Implemented Interfaces:

AutoCloseable

public class AsyncExecutor
extends NativeObject

AsyncExecutor represents an underneath OpenDAL executor that runs async tasks spawned in the Rust world.

If the executor is passed to construct operators, the executor must outlive the operators.

Field Summary

Fields inherited from class org.apache.opendal.NativeObject

nativeHandle

Method Summary

Modifier and Type	Method	Description
static AsyncExecutor	createTokioExecutor(int cores)
protected void	disposeInternal(long handle)	Deletes underlying native object pointer.

Methods inherited from class org.apache.opendal.NativeObject

close, isDisposed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

createTokioExecutor

public static AsyncExecutor createTokioExecutor(int cores)

disposeInternal

protected void disposeInternal(long handle)

Description copied from class: NativeObject

Deletes underlying native object pointer.

Specified by:

disposeInternal in class NativeObject

Parameters:

handle - to the native object pointer