Package org.apache.drill.exec.store.delta.plan

Class DeltaPluginImplementor

java.lang.Object

org.apache.drill.exec.store.plan.AbstractPluginImplementor

org.apache.drill.exec.store.delta.plan.DeltaPluginImplementor

All Implemented Interfaces:

PluginImplementor

public class DeltaPluginImplementor
extends AbstractPluginImplementor

Constructor Summary

Constructors

Constructor	Description
DeltaPluginImplementor()

Method Summary

Modifier and Type	Method	Description
boolean	artificialFilter()	If the plugin doesn't support native filter pushdown, but the reader can prune the set of rows to read.
boolean	artificialLimit()	If the plugin doesn't support native limit pushdown, but the reader can limit the number of rows to read.
boolean	canImplement(org.apache.calcite.rel.core.Filter filter)
boolean	canImplement(org.apache.calcite.rel.core.Project project)
boolean	canImplement(DrillLimitRelBase limit)
GroupScan	getPhysicalOperator()
protected boolean	hasPluginGroupScan(org.apache.calcite.rel.RelNode node)
void	implement(PluginFilterRel filter)
void	implement(PluginLimitRel limit)
void	implement(PluginProjectRel project)
void	implement(StoragePluginTableScan scan)
boolean	splitProject(org.apache.calcite.rel.core.Project project)
protected Class<? extends StoragePlugin>	supportedPlugin()

Methods inherited from class org.apache.drill.exec.store.plan.AbstractPluginImplementor

canImplement, canImplement, canImplement, canImplement, canImplement, findGroupScan, implement, implement, implement, implement

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.store.plan.PluginImplementor

visitChild

Constructor Details

DeltaPluginImplementor

public DeltaPluginImplementor()

Method Details

implement

public void implement(StoragePluginTableScan scan)

Specified by:

implement in interface PluginImplementor

Overrides:

implement in class AbstractPluginImplementor

implement

public void implement(PluginFilterRel filter)
               throws IOException

Specified by:

implement in interface PluginImplementor

Overrides:

implement in class AbstractPluginImplementor

Throws:

IOException

implement

public void implement(PluginProjectRel project)
               throws IOException

Specified by:

implement in interface PluginImplementor

Overrides:

implement in class AbstractPluginImplementor

Throws:

IOException

canImplement

public boolean canImplement(org.apache.calcite.rel.core.Filter filter)

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement in class AbstractPluginImplementor

implement

public void implement(PluginLimitRel limit)
               throws IOException

Specified by:

implement in interface PluginImplementor

Overrides:

implement in class AbstractPluginImplementor

Throws:

IOException

canImplement

public boolean canImplement(DrillLimitRelBase limit)

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement in class AbstractPluginImplementor

artificialLimit

public boolean artificialLimit()

Description copied from interface: PluginImplementor

If the plugin doesn't support native limit pushdown, but the reader can limit the number of rows to read. In this case limit operator on top of the scan should be preserved to ensure returning the correct rows number.

Specified by:

artificialLimit in interface PluginImplementor

Overrides:

artificialLimit in class AbstractPluginImplementor

artificialFilter

public boolean artificialFilter()

Description copied from interface: PluginImplementor

If the plugin doesn't support native filter pushdown, but the reader can prune the set of rows to read. In this case filter operator on top of the scan should be preserved to ensure returning the correct subset of rows.

Specified by:

artificialFilter in interface PluginImplementor

Overrides:

artificialFilter in class AbstractPluginImplementor

supportedPlugin

protected Class<? extends StoragePlugin> supportedPlugin()

Specified by:

supportedPlugin in class AbstractPluginImplementor

splitProject

public boolean splitProject(org.apache.calcite.rel.core.Project project)

Specified by:

splitProject in interface PluginImplementor

Overrides:

splitProject in class AbstractPluginImplementor

canImplement

public boolean canImplement(org.apache.calcite.rel.core.Project project)

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement in class AbstractPluginImplementor

getPhysicalOperator

public GroupScan getPhysicalOperator()

hasPluginGroupScan

protected boolean hasPluginGroupScan(org.apache.calcite.rel.RelNode node)

Specified by:

hasPluginGroupScan in class AbstractPluginImplementor