org.apache.drill.exec.physical.impl.scan.file

Class ImplicitColumnManager.ImplicitColumnOptions

java.lang.Object

org.apache.drill.exec.physical.impl.scan.file.ImplicitColumnManager.ImplicitColumnOptions

Enclosing class:

ImplicitColumnManager

public static class ImplicitColumnManager.ImplicitColumnOptions
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	useLegacyWildcardExpansion Historically Drill will expand partition columns (dir0, dir1, ...) when the project list includes a wildcard.

Constructor Summary

Constructors

Constructor and Description
ImplicitColumnOptions()

Method Summary

Modifier and Type	Method and Description
void	setFiles(List<org.apache.hadoop.fs.Path> files)
void	setPartitionDepth(int partitionDepth)
void	setSelectionRoot(org.apache.hadoop.fs.Path rootPath) Specify the selection root for a directory scan, if any.
void	useLegacyWildcardExpansion(boolean flag) Indicates whether to expand partition columns when the query contains a wildcard.

Methods inherited from class java.lang.Object

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

Field Detail

useLegacyWildcardExpansion

protected boolean useLegacyWildcardExpansion

Historically Drill will expand partition columns (dir0, dir1, ...) when the project list includes a wildcard.

Constructor Detail

ImplicitColumnOptions

public ImplicitColumnOptions()

Method Detail

setSelectionRoot

public void setSelectionRoot(org.apache.hadoop.fs.Path rootPath)

Specify the selection root for a directory scan, if any. Used to populate partition columns. Also, specify the maximum partition depth.

Parameters:

rootPath - Hadoop file path for the directory

setPartitionDepth

public void setPartitionDepth(int partitionDepth)

setFiles

public void setFiles(List<org.apache.hadoop.fs.Path> files)

useLegacyWildcardExpansion

public void useLegacyWildcardExpansion(boolean flag)

Indicates whether to expand partition columns when the query contains a wildcard. Supports queries such as the following:

 select * from dfs.`partitioned-dir`

In which the output columns will be (columns, dir0) if the partitioned directory has one level of nesting.

See TestImplicitFileColumns#testImplicitColumns