org.apache.drill.exec.store.mapr.db

Class MapRDBFormatPlugin

java.lang.Object

org.apache.drill.exec.store.mapr.TableFormatPlugin

org.apache.drill.exec.store.mapr.db.MapRDBFormatPlugin

All Implemented Interfaces:

FormatPlugin

public class MapRDBFormatPlugin
extends TableFormatPlugin

Constructor Summary

Constructors

Constructor and Description
MapRDBFormatPlugin(String name, DrillbitContext context, org.apache.hadoop.conf.Configuration fsConf, StoragePluginConfig storageConfig, MapRDBFormatPluginConfig formatConfig)

Method Summary

Modifier and Type	Method and Description
MapRDBFormatPluginConfig	getConfig()
org.apache.hadoop.hbase.client.Connection	getConnection()
AbstractGroupScan	getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns)
AbstractGroupScan	getGroupScan(String userName, FileSelection selection, List<SchemaPath> columns, com.mapr.db.index.IndexDesc indexDesc, MetadataProviderManager metadataProviderManager)
org.apache.hadoop.conf.Configuration	getHBaseConf()
MapRDBTableCache	getJsonTableCache()
FormatMatcher	getMatcher()
Set<StoragePluginOptimizerRule>	getOptimizerRules()
MapRDBCost	getPluginCostModel()
int	getRestrictedScanRangeSizeMB()
int	getScanRangeSizeMB()
String	getTableName(FileSelection selection) Allows to get a table name from FileSelection object
DrillStatsTable.TableStatistics	readStatistics(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path statsTablePath)
boolean	supportsStatistics()
void	writeStatistics(DrillStatsTable.TableStatistics statistics, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path statsTablePath)

Methods inherited from class org.apache.drill.exec.store.mapr.TableFormatPlugin

getContext, getFsConf, getMaprFS, getName, getStorageConfig, getStoragePlugin, getWriter, supportsAutoPartitioning, supportsRead, supportsWrite

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.dfs.FormatPlugin

getGroupScan, getGroupScan, getGroupScan

Constructor Detail

MapRDBFormatPlugin

public MapRDBFormatPlugin(String name,
                          DrillbitContext context,
                          org.apache.hadoop.conf.Configuration fsConf,
                          StoragePluginConfig storageConfig,
                          MapRDBFormatPluginConfig formatConfig)
                   throws IOException

Throws:

IOException

Method Detail

getMatcher

public FormatMatcher getMatcher()

getConfig

public MapRDBFormatPluginConfig getConfig()

Specified by:

getConfig in interface FormatPlugin

Overrides:

getConfig in class TableFormatPlugin

getJsonTableCache

public MapRDBTableCache getJsonTableCache()

getOptimizerRules

public Set<StoragePluginOptimizerRule> getOptimizerRules()

Specified by:

getOptimizerRules in interface FormatPlugin

Overrides:

getOptimizerRules in class TableFormatPlugin

getGroupScan

public AbstractGroupScan getGroupScan(String userName,
                                      FileSelection selection,
                                      List<SchemaPath> columns,
                                      com.mapr.db.index.IndexDesc indexDesc,
                                      MetadataProviderManager metadataProviderManager)
                               throws IOException

Throws:

IOException

getGroupScan

public AbstractGroupScan getGroupScan(String userName,
                                      FileSelection selection,
                                      List<SchemaPath> columns)
                               throws IOException

Throws:

IOException

supportsStatistics

public boolean supportsStatistics()

readStatistics

public DrillStatsTable.TableStatistics readStatistics(org.apache.hadoop.fs.FileSystem fs,
                                                      org.apache.hadoop.fs.Path statsTablePath)

writeStatistics

public void writeStatistics(DrillStatsTable.TableStatistics statistics,
                            org.apache.hadoop.fs.FileSystem fs,
                            org.apache.hadoop.fs.Path statsTablePath)
                     throws IOException

Throws:

IOException

getHBaseConf

public org.apache.hadoop.conf.Configuration getHBaseConf()

getConnection

public org.apache.hadoop.hbase.client.Connection getConnection()

getScanRangeSizeMB

public int getScanRangeSizeMB()

getRestrictedScanRangeSizeMB

public int getRestrictedScanRangeSizeMB()

getPluginCostModel

public MapRDBCost getPluginCostModel()

getTableName

public String getTableName(FileSelection selection)

Allows to get a table name from FileSelection object

Parameters:

selection - File selection object

Returns:

string table name