org.apache.drill.test

Class PrintingResultsListener

java.lang.Object

org.apache.drill.exec.client.LoggingResultsListener

org.apache.drill.test.PrintingResultsListener

All Implemented Interfaces:

UserResultsListener

public class PrintingResultsListener
extends LoggingResultsListener

Constructor Summary

Constructors

Constructor and Description
PrintingResultsListener(DrillConfig config, QuerySubmitter.Format format, int columnWidth)

Method Summary

Modifier and Type	Method and Description
void	dataArrived(QueryDataBatch result, ConnectionThrottle throttle) A QueryData message was received
void	queryCompleted(UserBitShared.QueryResult.QueryState state) The query has completed (successful completion or cancellation).
void	submissionFailed(UserException ex) The query has failed.

Methods inherited from class org.apache.drill.exec.client.LoggingResultsListener

queryIdArrived

Methods inherited from class java.lang.Object

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

Constructor Detail

PrintingResultsListener

public PrintingResultsListener(DrillConfig config,
                               QuerySubmitter.Format format,
                               int columnWidth)

Method Detail

submissionFailed

public void submissionFailed(UserException ex)

Description copied from interface: UserResultsListener

The query has failed. Most likely called when the server returns a FAILED query state. Can also be called if dataArrived() throws an exception

Specified by:

submissionFailed in interface UserResultsListener

Overrides:

submissionFailed in class LoggingResultsListener

Parameters:

ex - exception describing the cause of the failure

queryCompleted

public void queryCompleted(UserBitShared.QueryResult.QueryState state)

Description copied from interface: UserResultsListener

The query has completed (successful completion or cancellation). The listener will not receive any other data or result message. Called when the server returns a terminal-non failing- state (COMPLETED or CANCELLED)

Specified by:

queryCompleted in interface UserResultsListener

Overrides:

queryCompleted in class LoggingResultsListener

dataArrived

public void dataArrived(QueryDataBatch result,
                        ConnectionThrottle throttle)

Description copied from interface: UserResultsListener

A QueryData message was received

Specified by:

dataArrived in interface UserResultsListener

Overrides:

dataArrived in class LoggingResultsListener

Parameters:

result - data batch received

throttle - connection throttle