com.datastax.oss.dsbulk.workflow.count

Class CountWorkflow

java.lang.Object

com.datastax.oss.dsbulk.workflow.count.CountWorkflow

All Implemented Interfaces:

Workflow, AutoCloseable

public class CountWorkflow
extends Object
implements Workflow

The main class for count workflows.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the workflow and releases all open resources (file descriptors, socket connections, etc.).
boolean	execute() Executes the workflow.
void	init() Initializes the workflow.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

init

public void init()
          throws Exception

Description copied from interface: Workflow

Initializes the workflow.

This method is guaranteed to be called once and only once by the execution engine.

Specified by:

init in interface Workflow

Throws:

Exception - if the workflow could not be initialized properly.

execute

public boolean execute()

Description copied from interface: Workflow

Executes the workflow.

This method is guaranteed to be called once and only once by the execution engine, and only after the workflow has been properly initialized.

Specified by:

execute in interface Workflow

Returns:

true if the workflow completed without any errors, false if it completed with errors.

close

public void close()
           throws Exception

Description copied from interface: Workflow

Closes the workflow and releases all open resources (file descriptors, socket connections, etc.).

This method is guaranteed to be called once and only once by the execution engine, and only after the workflow has finished its execution, regardless of whether the execution finished normally or exceptionally.

Specified by:

close in interface Workflow

Specified by:

close in interface AutoCloseable

Throws:

Exception - if the workflow encountered an error while closing open resources.

toString

public String toString()

Overrides:

toString in class Object