Package org.apache.drill.exec.planner.physical.visitor

Class ProducerConsumerPrelVisitor

java.lang.Object

org.apache.drill.exec.planner.physical.visitor.BasePrelVisitor<Prel,Void,RuntimeException>

org.apache.drill.exec.planner.physical.visitor.ProducerConsumerPrelVisitor

All Implemented Interfaces:

PrelVisitor<Prel,Void,RuntimeException>

public class ProducerConsumerPrelVisitor
extends BasePrelVisitor<Prel,Void,RuntimeException>

Field Summary

Fields inherited from interface org.apache.drill.exec.planner.physical.visitor.PrelVisitor

logger

Constructor Summary

Constructors

Constructor	Description
ProducerConsumerPrelVisitor(int queueSize)

Method Summary

Modifier and Type	Method	Description
static Prel	addProducerConsumerToScans(Prel prel, int queueSize)
Prel	visitPrel(Prel prel, Void value)
Prel	visitScan(ScanPrel scanPrel, Void value)

Methods inherited from class org.apache.drill.exec.planner.physical.visitor.BasePrelVisitor

visitExchange, visitJoin, visitLateral, visitLeaf, visitProject, visitScan, visitScreen, visitTableModify, visitUnnest, visitWriter

Methods inherited from class java.lang.Object

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

Constructor Details

ProducerConsumerPrelVisitor

public ProducerConsumerPrelVisitor(int queueSize)

Method Details

addProducerConsumerToScans

public static Prel addProducerConsumerToScans(Prel prel,
 int queueSize)

visitPrel

public Prel visitPrel(Prel prel,
 Void value)
               throws RuntimeException

Specified by:

visitPrel in interface PrelVisitor<Prel,Void,RuntimeException>

Overrides:

visitPrel in class BasePrelVisitor<Prel,Void,RuntimeException>

Throws:

RuntimeException

visitScan

public Prel visitScan(ScanPrel scanPrel,
 Void value)

Specified by:

visitScan in interface PrelVisitor<Prel,Void,RuntimeException>

Overrides:

visitScan in class BasePrelVisitor<Prel,Void,RuntimeException>