Skip to content

Latest commit

 

History

History
41 lines (30 loc) · 1.22 KB

spark-sql-Projection.adoc

File metadata and controls

41 lines (30 loc) · 1.22 KB

Projection Contract — Functions to Produce InternalRow for InternalRow

Projection is a contract of Scala functions that produce an internal binary row for a given internal row.

Projection: InternalRow => InternalRow

Projection can optionally be initialized with the current partition index (which by default does nothing).

initialize(partitionIndex: Int): Unit = {}
Note
initialize is overriden by InterpretedProjection and InterpretedMutableProjection projections that are used in interpreted expression evaluation.
Table 1. Projections
Projection Description

UnsafeProjection

InterpretedProjection

IdentityProjection

MutableProjection

InterpretedMutableProjection

Appears not to be used anymore