com.datastax.oss.dsbulk.workflow.commons.settings

Class ExecutorSettings

java.lang.Object

com.datastax.oss.dsbulk.workflow.commons.settings.ExecutorSettings

public class ExecutorSettings
extends Object

Method Summary

Modifier and Type	Method and Description
protected boolean	checkContinuousPaging(CqlSession session, boolean searchQuery)
protected boolean	continuousPagingAvailable(CqlSession session)
void	init()
protected boolean	isOssCassandra(CqlSession session)
protected BulkExecutor	newBulkExecutor(CqlSession session, ExecutionListener executionListener, boolean read, boolean searchQuery)
BulkReader	newReadExecutor(CqlSession session, MetricsCollectingExecutionListener executionListener, boolean searchQuery)
BulkWriter	newWriteExecutor(CqlSession session, ExecutionListener executionListener)

Methods inherited from class java.lang.Object

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

Method Detail

init

public void init()

newWriteExecutor

@NonNull
public BulkWriter newWriteExecutor(@NonNull
                                            CqlSession session,
                                            @NonNull
                                            ExecutionListener executionListener)

newReadExecutor

@NonNull
public BulkReader newReadExecutor(@NonNull
                                           CqlSession session,
                                           @NonNull
                                           MetricsCollectingExecutionListener executionListener,
                                           boolean searchQuery)

newBulkExecutor

@NonNull
protected BulkExecutor newBulkExecutor(@NonNull
                                                CqlSession session,
                                                @NonNull
                                                ExecutionListener executionListener,
                                                boolean read,
                                                boolean searchQuery)

checkContinuousPaging

protected boolean checkContinuousPaging(@NonNull
                                        CqlSession session,
                                        boolean searchQuery)

isOssCassandra

protected boolean isOssCassandra(CqlSession session)

continuousPagingAvailable

protected boolean continuousPagingAvailable(@NonNull
                                            CqlSession session)