Skip to content


Projection is a <> of Scala functions that produce an InternalRow for a given internal row.

[source, scala]

Projection: InternalRow => InternalRow

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

[source, scala]

initialize(partitionIndex: Int): Unit = {}

NOTE: initialize is overriden by InterpretedProjection and InterpretedMutableProjection projections that are used in interpreted expression evaluation.

[[implementations]] .Projections [cols="1,2",options="header",width="100%"] |=== | Projection | Description

[[UnsafeProjection]] UnsafeProjection
[[InterpretedProjection]] InterpretedProjection
[[IdentityProjection]] IdentityProjection
[[MutableProjection]] MutableProjection

| [[InterpretedMutableProjection]] InterpretedMutableProjection | Appears not to be used anymore |===

Last update: 2020-11-15