org.apache.drill.exec.store.iceberg.plan

Class IcebergPluginImplementor

java.lang.Object

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

org.apache.drill.exec.store.iceberg.plan.IcebergPluginImplementor

All Implemented Interfaces:

PluginImplementor

public class IcebergPluginImplementor
extends AbstractPluginImplementor

Constructor Summary

Constructors

Constructor and Description
IcebergPluginImplementor()

Method Summary

Modifier and Type	Method and Description
boolean	artificialLimit() If the plugin doesn't support native limit pushdown, but the reader can limit the number of rows to read.
boolean	canImplement(DrillLimitRelBase limit)
boolean	canImplement(org.apache.calcite.rel.core.Filter filter)
boolean	canImplement(org.apache.calcite.rel.core.Project project)
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 Detail

IcebergPluginImplementor

public IcebergPluginImplementor()

Method Detail

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

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