org.apache.drill.exec.store.mongo.plan

Class MongoPluginImplementor

java.lang.Object

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

org.apache.drill.exec.store.mongo.plan.MongoPluginImplementor

All Implemented Interfaces:

PluginImplementor

public class MongoPluginImplementor
extends AbstractPluginImplementor

Implementation of PluginImplementor for Mongo. This class tries to convert operators to use MongoCollection.find() if only simple project and filter expressions are present, otherwise MongoCollection.aggregate(java.util.List<? extends org.bson.conversions.Bson>) is used to obtain data from Mongo.

Constructor Summary

Constructors

Constructor and Description
MongoPluginImplementor()

Method Summary

Modifier and Type	Method and Description
boolean	canImplement(org.apache.calcite.rel.core.Aggregate aggregate)
boolean	canImplement(DrillLimitRelBase limit)
boolean	canImplement(org.apache.calcite.rel.core.Filter filter)
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)
GroupScan	getPhysicalOperator()
protected boolean	hasPluginGroupScan(org.apache.calcite.rel.RelNode node)
void	implement(PluginAggregateRel aggregate)
void	implement(PluginFilterRel filter)
void	implement(PluginLimitRel limit)
void	implement(PluginProjectRel project)
void	implement(PluginSortRel sort)
void	implement(PluginUnionRel union)
void	implement(StoragePluginTableScan scan)
protected Class<? extends StoragePlugin>	supportedPlugin()

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

artificialLimit, canImplement, findGroupScan, implement, splitProject

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

MongoPluginImplementor

public MongoPluginImplementor()

Method Detail

implement

public void implement(PluginAggregateRel aggregate)
               throws IOException

Specified by:

implement in interface PluginImplementor

Overrides:

implement in class AbstractPluginImplementor

Throws:

IOException

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(PluginLimitRel limit)
               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

implement

public void implement(PluginSortRel sort)
               throws IOException

Specified by:

implement in interface PluginImplementor

Overrides:

implement in class AbstractPluginImplementor

Throws:

IOException

implement

public void implement(PluginUnionRel union)
               throws IOException

Specified by:

implement in interface PluginImplementor

Overrides:

implement in class AbstractPluginImplementor

Throws:

IOException

implement

public void implement(StoragePluginTableScan scan)

Specified by:

implement in interface PluginImplementor

Overrides:

implement in class AbstractPluginImplementor

canImplement

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

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement in class AbstractPluginImplementor

canImplement

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

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement in class AbstractPluginImplementor

canImplement

public boolean canImplement(DrillLimitRelBase limit)

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement 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

canImplement

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

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement in class AbstractPluginImplementor

canImplement

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

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement in class AbstractPluginImplementor

canImplement

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

Specified by:

canImplement in interface PluginImplementor

Overrides:

canImplement in class AbstractPluginImplementor

supportedPlugin

protected Class<? extends StoragePlugin> supportedPlugin()

Specified by:

supportedPlugin in class AbstractPluginImplementor

getPhysicalOperator

public GroupScan getPhysicalOperator()

hasPluginGroupScan

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

Specified by:

hasPluginGroupScan in class AbstractPluginImplementor