Top Description Fields Constructors Methods

com.ziclix.python.sql.pipe

pack-priv abstract Class PipeRunner

Located in compilation unit of com.ziclix.python.sql.pipe.Pipe.

Class Inheritance

extends Thread

java.lang.Object
java.lang.Thread
com.ziclix.python.sql.pipe.PipeRunner

Known Direct Subclasses

com.ziclix.python.sql.pipe.SourceRunner, com.ziclix.python.sql.pipe.SinkRunner

Class PipeRunner

Date: 2024-12-07
Copyright: 2001 brian zimmer

Field Summary

Modifier and Type	Field and Description
protected int	counter Field counter
protected Throwable	exception Field exception
protected Queue	queue Field queue

Inherited from java.lang.Thread:: MAX_PRIORITY MIN_PRIORITY NORM_PRIORITY

Constructor Summary

Access	Constructor and Description
public	PipeRunner(Queue queue queue) Constructor PipeRunner

Method Summary

Modifier and Type	Method and Description
public int	getCount() The total number of rows handled.
public Throwable	getException() Return the uncaught exception.
protected abstract void	pipe() Handle the source/destination specific copying.
public void	run() Overrides java.lang.Thread.run. Implements java.lang.Runnable.run. Method run
public boolean	threwException() Return true if the thread terminated because of an uncaught exception.

Field Detail

counter	back to summary
protected int counter Field counter

exception	back to summary
protected Throwable exception Field exception

queue	back to summary
protected Queue queue Field queue

Constructor Detail

PipeRunner

back to summary

public PipeRunner(Queue queue)

Constructor PipeRunner

Parameters

queue:Queue: queue

Method Detail

getCount	back to summary
public int getCount() The total number of rows handled.

getException	back to summary
public Throwable getException() Return the uncaught exception.

pipe	back to summary
protected abstract void pipe() throws InterruptedException Handle the source/destination specific copying.

run

back to summary

public void run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

Method run

Annotations

@Override

threwException	back to summary
public boolean threwException() Return true if the thread terminated because of an uncaught exception.