pack-priv Class SinkRunner

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

Class Inheritance

extends PipeRunner

Class SinkRunner

Field Summary

Modifier and Type	Field and Description
protected Sink	sink Field sink

Inherited from com.ziclix.python.sql.pipe.PipeRunner:: counter exception queue

Access	Constructor and Description
public	SinkRunner(Queue queue queue, Sink sink sink) Constructor SinkRunner

Modifier and Type	Method and Description
protected void	pipe() Implements abstract com.ziclix.python.sql.pipe.PipeRunner.pipe. Method pipe

Inherited from com.ziclix.python.sql.pipe.PipeRunner:: getCount getException run threwException

sink	back to summary
protected Sink sink Field sink

SinkRunner	back to summary
public SinkRunner(Queue queue, Sink sink) Constructor SinkRunner Parameters queue:Queue queue sink:Sink sink

SinkRunner

public SinkRunner(Queue queue, Sink sink)

Constructor SinkRunner

Parameters

pipe	back to summary
protected void pipe() throws InterruptedException Implements abstract com.ziclix.python.sql.pipe.PipeRunner.pipe. Method pipe Annotations @Override

pipe

protected void pipe() throws InterruptedException

Method pipe

Annotations