Package org.apache.drill.exec.store.hive
Class HiveSubScan
java.lang.Object
org.apache.drill.exec.physical.base.AbstractBase
org.apache.drill.exec.store.hive.HiveSubScan
- All Implemented Interfaces:
Iterable<PhysicalOperator>
,GraphValue<PhysicalOperator>
,FragmentLeaf
,Leaf
,PhysicalOperator
,Scan
,SubScan
-
Field Summary
Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase
INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName
-
Constructor Summary
ConstructorDescriptionHiveSubScan
(String userName, List<List<String>> splits, HiveReadEntry hiveReadEntry, List<String> splitClasses, List<SchemaPath> columns, HiveStoragePlugin hiveStoragePlugin, Map<String, String> confProperties) HiveSubScan
(StoragePluginRegistry registry, String userName, List<List<String>> splits, HiveReadEntry hiveReadEntry, List<String> splitClasses, List<SchemaPath> columns, HiveStoragePluginConfig hiveStoragePluginConfig, Map<String, String> confProperties) -
Method Summary
Modifier and TypeMethodDescription<T,
X, E extends Throwable>
Taccept
(PhysicalVisitor<T, X, E> physicalVisitor, X value) Provides capability to build a set of output based on traversing a query graph tree.org.apache.hadoop.hive.conf.HiveConf
getNewWithChildren
(List<PhysicalOperator> children) Regenerate with this node with a new set of children.getTable()
iterator()
Methods inherited from class org.apache.drill.exec.physical.base.AbstractBase
accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
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.common.graph.GraphValue
accept
Methods inherited from interface java.lang.Iterable
forEach, spliterator
Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator
getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, setCost, setMaxAllocation, setOperatorId
-
Field Details
-
OPERATOR_TYPE
- See Also:
-
-
Constructor Details
-
HiveSubScan
public HiveSubScan(StoragePluginRegistry registry, String userName, List<List<String>> splits, HiveReadEntry hiveReadEntry, List<String> splitClasses, List<SchemaPath> columns, HiveStoragePluginConfig hiveStoragePluginConfig, Map<String, String> confProperties) throws IOException, ExecutionSetupException, ReflectiveOperationException -
HiveSubScan
public HiveSubScan(String userName, List<List<String>> splits, HiveReadEntry hiveReadEntry, List<String> splitClasses, List<SchemaPath> columns, HiveStoragePlugin hiveStoragePlugin, Map<String, String> confProperties) throws IOException, ReflectiveOperationException
-
-
Method Details
-
getSplits
-
getHiveReadEntry
-
getSplitClasses
-
getColumns
-
getHiveStoragePluginConfig
-
getConfProperties
-
getTable
-
getPartitions
-
getInputSplits
-
getStoragePlugin
-
getHiveConf
public org.apache.hadoop.hive.conf.HiveConf getHiveConf() -
accept
public <T,X, T acceptE extends Throwable> (PhysicalVisitor<T, X, throws EE> physicalVisitor, X value) Description copied from interface:PhysicalOperator
Provides capability to build a set of output based on traversing a query graph tree.- Specified by:
accept
in interfacePhysicalOperator
- Throws:
E extends Throwable
-
getNewWithChildren
public PhysicalOperator getNewWithChildren(List<PhysicalOperator> children) throws ExecutionSetupException Description copied from interface:PhysicalOperator
Regenerate with this node with a new set of children. This is used in the case of materialization or optimization.- Specified by:
getNewWithChildren
in interfacePhysicalOperator
- Throws:
ExecutionSetupException
-
iterator
- Specified by:
iterator
in interfaceIterable<PhysicalOperator>
-
getOperatorType
- Specified by:
getOperatorType
in interfacePhysicalOperator
-