Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Public Member Functions | Private Member Functions | Private Attributes | List of all members
com.cloudera.impala.analysis.DescriptorTable Class Reference
Collaboration diagram for com.cloudera.impala.analysis.DescriptorTable:

Public Member Functions

TupleDescriptor createTupleDescriptor (String debugName)
 
TupleDescriptor copyTupleDescriptor (TupleId srcId, String debugName)
 
SlotDescriptor addSlotDescriptor (TupleDescriptor d)
 
SlotDescriptor copySlotDescriptor (TupleDescriptor dest, SlotDescriptor src)
 
TupleDescriptor getTupleDesc (TupleId id)
 
SlotDescriptor getSlotDesc (SlotId id)
 
Collection< TupleDescriptor > getTupleDescs ()
 
Collection< SlotDescriptor > getSlotDescs ()
 
TupleId getMaxTupleId ()
 
SlotId getMaxSlotId ()
 
void addReferencedTable (Table table)
 
void addReferencedPartition (Table table, long partitionId)
 
void markSlotsMaterialized (List< SlotId > ids)
 
List< SlotId > getTupleSlotIds (List< SlotId > slotIds, TupleId tupleId)
 
void computeMemLayout ()
 
TDescriptorTable toThrift ()
 
String debugString ()
 

Private Member Functions

HashSet< Long > getReferencedPartitions (Table table)
 

Private Attributes

final HashMap< TupleId,
TupleDescriptor > 		tupleDescs_ = Maps.newHashMap()
 
final HashMap< SlotId,
SlotDescriptor > 		slotDescs_ = Maps.newHashMap()
 
final IdGenerator< TupleId > tupleIdGenerator_ = TupleId.createGenerator()
 
final IdGenerator< SlotId > slotIdGenerator_ = SlotId.createGenerator()
 
final List< Table > referencedTables_ = Lists.newArrayList()
 
final HashMap< Table, HashSet
< Long > > 		referencedPartitionsPerTable_
 

Detailed Description

Repository for tuple (and slot) descriptors. Descriptors should only be created through this class, which assigns them unique ids.

Definition at line 36 of file DescriptorTable.java.

Member Function Documentation

void com.cloudera.impala.analysis.DescriptorTable.addReferencedPartition ( Table  table,
long  partitionId 
)
inline

Add the partition with ID partitionId to the set of referenced partitions for the given table.

Definition at line 116 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.getReferencedPartitions().

void com.cloudera.impala.analysis.DescriptorTable.addReferencedTable ( Table  table)
inline

Definition at line 95 of file DescriptorTable.java.

SlotDescriptor com.cloudera.impala.analysis.DescriptorTable.addSlotDescriptor ( TupleDescriptor  d)
inline

Definition at line 71 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.slotIdGenerator_.

void com.cloudera.impala.analysis.DescriptorTable.computeMemLayout ( )
inline

Definition at line 143 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.tupleDescs_.

SlotDescriptor com.cloudera.impala.analysis.DescriptorTable.copySlotDescriptor ( TupleDescriptor  dest,
SlotDescriptor  src 
)
inline

Append copy of src to dest.

Definition at line 81 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.slotIdGenerator_.

Referenced by com.cloudera.impala.analysis.DescriptorTable.copyTupleDescriptor().

TupleDescriptor com.cloudera.impala.analysis.DescriptorTable.copyTupleDescriptor ( TupleId  srcId,
String  debugName 
)
inline

Create copy of src with new id. The returned descriptor has its mem layout computed.

Definition at line 58 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.copySlotDescriptor(), com.cloudera.impala.analysis.TupleDescriptor.getByteSize(), com.cloudera.impala.analysis.TupleDescriptor.getSlots(), and com.cloudera.impala.analysis.DescriptorTable.tupleIdGenerator_.

TupleDescriptor com.cloudera.impala.analysis.DescriptorTable.createTupleDescriptor ( String  debugName)
inline

Definition at line 48 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.tupleIdGenerator_.

String com.cloudera.impala.analysis.DescriptorTable.debugString ( )
inline

Definition at line 180 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.tupleDescs_.

SlotId com.cloudera.impala.analysis.DescriptorTable.getMaxSlotId ( )
inline

Definition at line 93 of file DescriptorTable.java.

TupleId com.cloudera.impala.analysis.DescriptorTable.getMaxTupleId ( )
inline

Definition at line 92 of file DescriptorTable.java.

HashSet<Long> com.cloudera.impala.analysis.DescriptorTable.getReferencedPartitions ( Table  table)
inlineprivate

Find the set of referenced partitions for the given table. Allocates a set if none has been allocated for the table yet.

Definition at line 103 of file DescriptorTable.java.

Referenced by com.cloudera.impala.analysis.DescriptorTable.addReferencedPartition(), and com.cloudera.impala.analysis.DescriptorTable.toThrift().

SlotDescriptor com.cloudera.impala.analysis.DescriptorTable.getSlotDesc ( SlotId  id)
inline

Definition at line 89 of file DescriptorTable.java.

Referenced by com.cloudera.impala.analysis.Analyzer.createEqPredicate(), com.cloudera.impala.analysis.Analyzer.getBoundPredicates(), com.cloudera.impala.analysis.Analyzer.getEquivSlots(), com.cloudera.impala.analysis.DescriptorTable.getTupleSlotIds(), and com.cloudera.impala.analysis.DescriptorTable.markSlotsMaterialized().

Collection<SlotDescriptor> com.cloudera.impala.analysis.DescriptorTable.getSlotDescs ( )
inline

Definition at line 91 of file DescriptorTable.java.

TupleDescriptor com.cloudera.impala.analysis.DescriptorTable.getTupleDesc ( TupleId  id)
inline

Definition at line 88 of file DescriptorTable.java.

Referenced by com.cloudera.impala.planner.HdfsScanNode.prunePartitions().

Collection<TupleDescriptor> com.cloudera.impala.analysis.DescriptorTable.getTupleDescs ( )
inline

Definition at line 90 of file DescriptorTable.java.

List<SlotId> com.cloudera.impala.analysis.DescriptorTable.getTupleSlotIds ( List< SlotId >  slotIds,
TupleId  tupleId 
)
inline

Return all ids in slotIds that belong to tupleId.

Definition at line 132 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.getSlotDesc().

void com.cloudera.impala.analysis.DescriptorTable.markSlotsMaterialized ( List< SlotId >  ids)
inline

Marks all slots in list as materialized.

Definition at line 123 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.getSlotDesc().

TDescriptorTable com.cloudera.impala.analysis.DescriptorTable.toThrift ( )
inline

Definition at line 149 of file DescriptorTable.java.

References com.cloudera.impala.analysis.DescriptorTable.getReferencedPartitions(), com.cloudera.impala.analysis.DescriptorTable.referencedTables_, and com.cloudera.impala.analysis.DescriptorTable.tupleDescs_.

Member Data Documentation

final HashMap<Table, HashSet<Long> > com.cloudera.impala.analysis.DescriptorTable.referencedPartitionsPerTable_
private
Initial value:
=
Maps.newHashMap()

Definition at line 45 of file DescriptorTable.java.

final List<Table> com.cloudera.impala.analysis.DescriptorTable.referencedTables_ = Lists.newArrayList()
private

Definition at line 43 of file DescriptorTable.java.

Referenced by com.cloudera.impala.analysis.DescriptorTable.toThrift().

final HashMap<SlotId, SlotDescriptor> com.cloudera.impala.analysis.DescriptorTable.slotDescs_ = Maps.newHashMap()
private

Definition at line 38 of file DescriptorTable.java.

final IdGenerator<SlotId> com.cloudera.impala.analysis.DescriptorTable.slotIdGenerator_ = SlotId.createGenerator()
private

Definition at line 40 of file DescriptorTable.java.

Referenced by com.cloudera.impala.analysis.DescriptorTable.addSlotDescriptor(), and com.cloudera.impala.analysis.DescriptorTable.copySlotDescriptor().

final HashMap<TupleId, TupleDescriptor> com.cloudera.impala.analysis.DescriptorTable.tupleDescs_ = Maps.newHashMap()
private

Definition at line 37 of file DescriptorTable.java.

Referenced by com.cloudera.impala.analysis.DescriptorTable.computeMemLayout(), com.cloudera.impala.analysis.DescriptorTable.debugString(), and com.cloudera.impala.analysis.DescriptorTable.toThrift().

final IdGenerator<TupleId> com.cloudera.impala.analysis.DescriptorTable.tupleIdGenerator_ = TupleId.createGenerator()
private

Definition at line 39 of file DescriptorTable.java.

Referenced by com.cloudera.impala.analysis.DescriptorTable.copyTupleDescriptor(), and com.cloudera.impala.analysis.DescriptorTable.createTupleDescriptor().

The documentation for this class was generated from the following file: