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

Class AbstractPluginImplementor

java.lang.Object

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

All Implemented Interfaces:

PluginImplementor

Direct Known Subclasses:

DeltaPluginImplementor, DrillPluginImplementor, IcebergPluginImplementor, MongoPluginImplementor

public abstract class AbstractPluginImplementor
extends Object
implements PluginImplementor

Abstract base implementation of PluginImplementor that can be used by plugin implementors which can support only a subset of all provided operations.

Constructor Summary

Constructors

Constructor	Description
AbstractPluginImplementor()

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.Aggregate aggregate)
boolean	canImplement(org.apache.calcite.rel.core.Filter filter)
boolean	canImplement(org.apache.calcite.rel.core.Join scan)
boolean	canImplement(org.apache.calcite.rel.core.Project project)
boolean	canImplement(org.apache.calcite.rel.core.Sort sort)
boolean	canImplement(org.apache.calcite.rel.core.TableScan scan)
boolean	canImplement(org.apache.calcite.rel.core.Union union)
boolean	canImplement(DrillLimitRelBase limit)
protected GroupScan	findGroupScan(org.apache.calcite.rel.RelNode node)
protected abstract boolean	hasPluginGroupScan(org.apache.calcite.rel.RelNode node)
void	implement(PluginAggregateRel aggregate)
void	implement(PluginFilterRel filter)
void	implement(PluginJoinRel join)
void	implement(PluginLimitRel limit)
void	implement(PluginProjectRel project)
void	implement(PluginSortRel sort)
void	implement(PluginUnionRel union)
void	implement(StoragePluginTableScan scan)
boolean	splitProject(org.apache.calcite.rel.core.Project project)
protected abstract Class<? extends StoragePlugin>	supportedPlugin()

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

getPhysicalOperator, visitChild

Constructor Details

AbstractPluginImplementor

public AbstractPluginImplementor()

Method Details

implement

public void implement(PluginAggregateRel aggregate)
               throws IOException

Specified by:

implement in interface PluginImplementor

Throws:

IOException

implement

public void implement(PluginFilterRel filter)
               throws IOException

Specified by:

implement in interface PluginImplementor

Throws:

IOException

implement

public void implement(PluginLimitRel limit)
               throws IOException

Specified by:

implement in interface PluginImplementor

Throws:

IOException

implement

public void implement(PluginProjectRel project)
               throws IOException

Specified by:

implement in interface PluginImplementor

Throws:

IOException

implement

public void implement(PluginSortRel sort)
               throws IOException

Specified by:

implement in interface PluginImplementor

Throws:

IOException

implement

public void implement(PluginUnionRel union)
               throws IOException

Specified by:

implement in interface PluginImplementor

Throws:

IOException

implement

public void implement(PluginJoinRel join)
               throws IOException

Specified by:

implement in interface PluginImplementor

Throws:

IOException

implement

public void implement(StoragePluginTableScan scan)
               throws IOException

Specified by:

implement in interface PluginImplementor

Throws:

IOException

canImplement

public boolean canImplement(org.apache.calcite.rel.core.Aggregate aggregate)

Specified by:

canImplement in interface PluginImplementor

canImplement

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

Specified by:

canImplement in interface PluginImplementor

canImplement

public boolean canImplement(DrillLimitRelBase limit)

Specified by:

canImplement in interface PluginImplementor

canImplement

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

Specified by:

canImplement in interface PluginImplementor

canImplement

public boolean canImplement(org.apache.calcite.rel.core.Sort sort)

Specified by:

canImplement in interface PluginImplementor

canImplement

public boolean canImplement(org.apache.calcite.rel.core.Union union)

Specified by:

canImplement in interface PluginImplementor

canImplement

public boolean canImplement(org.apache.calcite.rel.core.TableScan scan)

Specified by:

canImplement in interface PluginImplementor

canImplement

public boolean canImplement(org.apache.calcite.rel.core.Join scan)

Specified by:

canImplement in interface PluginImplementor

splitProject

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

Specified by:

splitProject in interface PluginImplementor

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

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

findGroupScan

protected GroupScan findGroupScan(org.apache.calcite.rel.RelNode node)

supportedPlugin

protected abstract Class<? extends StoragePlugin> supportedPlugin()

hasPluginGroupScan

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