Package org.apache.drill.exec.store.dfs

Class MetadataContext

java.lang.Object

org.apache.drill.exec.store.dfs.MetadataContext

public class MetadataContext
extends Object

A metadata context that holds state across multiple invocations of the Parquet metadata APIs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	MetadataContext.PruneStatus

Constructor Summary

Constructors

Constructor	Description
MetadataContext()

Method Summary

Modifier and Type	Method	Description
void	clear()
void	clearStatus(org.apache.hadoop.fs.Path dir)
List<org.apache.hadoop.fs.Path>	getDirectories()
MetadataContext.PruneStatus	getPruneStatus()
boolean	getStatus(org.apache.hadoop.fs.Path dir)
boolean	isMetadataCacheCorrupted()
void	setDirectories(List<org.apache.hadoop.fs.Path> directories)
void	setMetadataCacheCorrupted(boolean metadataCacheCorrupted)	Setting this as true allows to avoid double reading of corrupted, unsupported or missing metadata files
void	setPruneStatus(MetadataContext.PruneStatus status)
void	setStatus(org.apache.hadoop.fs.Path dir)

Methods inherited from class java.lang.Object

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

Constructor Details

MetadataContext

public MetadataContext()

Method Details

setStatus

public void setStatus(org.apache.hadoop.fs.Path dir)

clearStatus

public void clearStatus(org.apache.hadoop.fs.Path dir)

getStatus

public boolean getStatus(org.apache.hadoop.fs.Path dir)

clear

public void clear()

setPruneStatus

public void setPruneStatus(MetadataContext.PruneStatus status)

getPruneStatus

public MetadataContext.PruneStatus getPruneStatus()

isMetadataCacheCorrupted

public boolean isMetadataCacheCorrupted()

Returns:

true if parquet metadata cache files are missing or corrupted, false otherwise

setMetadataCacheCorrupted

public void setMetadataCacheCorrupted(boolean metadataCacheCorrupted)

Setting this as true allows to avoid double reading of corrupted, unsupported or missing metadata files

Parameters:

metadataCacheCorrupted - metadata corruption status

setDirectories

public void setDirectories(List<org.apache.hadoop.fs.Path> directories)

getDirectories

public List<org.apache.hadoop.fs.Path> getDirectories()