com.datastax.oss.dsbulk.executor.reactor

Interface ReactorBulkExecutor

All Superinterfaces:

AsyncBulkExecutor, AsyncBulkReader, AsyncBulkWriter, AutoCloseable, BulkExecutor, BulkReader, BulkWriter, ReactiveBulkExecutor, ReactiveBulkReader, ReactiveBulkWriter, ReactorBulkReader, ReactorBulkWriter, SyncBulkExecutor, SyncBulkReader, SyncBulkWriter

All Known Implementing Classes:

ContinuousReactorBulkExecutor, DefaultReactorBulkExecutor

public interface ReactorBulkExecutor
extends ReactorBulkWriter, ReactorBulkReader, BulkExecutor

An execution unit for bulk writes and bulk reads that operates in reactive mode using Reactor.

Method Summary

Methods inherited from interface com.datastax.oss.dsbulk.executor.reactor.writer.ReactorBulkWriter

writeReactive, writeReactive, writeReactive, writeReactive, writeReactive

Methods inherited from interface com.datastax.oss.dsbulk.executor.reactor.reader.ReactorBulkReader

readReactive, readReactive, readReactive, readReactive, readReactive

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.BulkWriter

writeSync, writeSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.BulkReader

readSync, readSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.SyncBulkWriter

writeSync, writeSync, writeSync, writeSync, writeSync, writeSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.SyncBulkReader

readSync, readSync, readSync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.writer.AsyncBulkWriter

writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync

Methods inherited from interface com.datastax.oss.dsbulk.executor.api.reader.AsyncBulkReader

readAsync, readAsync, readAsync, readAsync, readAsync

Methods inherited from interface java.lang.AutoCloseable

close