Package org.apache.calcite.test.concurrent

Class ConcurrentTestCommandScript.CommandWithTimeoutAndRowLimit

java.lang.Object

org.apache.calcite.test.concurrent.ConcurrentTestCommandGenerator.AbstractCommand

org.apache.calcite.test.concurrent.ConcurrentTestCommandScript.CommandWithTimeout

org.apache.calcite.test.concurrent.ConcurrentTestCommandScript.CommandWithTimeoutAndRowLimit

All Implemented Interfaces:

ConcurrentTestCommand

Direct Known Subclasses:

ConcurrentTestCommandScript.SelectCommand

Enclosing class:

ConcurrentTestCommandScript

private abstract static class ConcurrentTestCommandScript.CommandWithTimeoutAndRowLimit
extends ConcurrentTestCommandScript.CommandWithTimeout

Command with timeout and row limit.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.test.concurrent.ConcurrentTestCommand

ConcurrentTestCommand.ShouldHaveFailedException

Field Summary

Fields

Modifier and Type	Field	Description
private int	rowLimit

Constructor Summary

Constructors

Modifier	Constructor	Description
private	CommandWithTimeoutAndRowLimit(long timeout)
private	CommandWithTimeoutAndRowLimit(long timeout, int rowLimit)

Method Summary

Modifier and Type	Method	Description
protected void	setRowLimit(java.sql.Statement stmt)

Methods inherited from class org.apache.calcite.test.concurrent.ConcurrentTestCommandScript.CommandWithTimeout

setTimeout

Methods inherited from class org.apache.calcite.test.concurrent.ConcurrentTestCommandGenerator.AbstractCommand

doExecute, execute, isFailureExpected, markToFail, markToFail

Methods inherited from class java.lang.Object

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

Field Detail

rowLimit

private int rowLimit

Constructor Detail

CommandWithTimeoutAndRowLimit

private CommandWithTimeoutAndRowLimit(long timeout)

CommandWithTimeoutAndRowLimit

private CommandWithTimeoutAndRowLimit(long timeout,
                                      int rowLimit)

Method Detail

setRowLimit

protected void setRowLimit(java.sql.Statement stmt)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException