spark技术分享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.
|
1 2 3 4 5 |
Projection: InternalRow => InternalRow |
Projection can optionally be initialized with the current partition index (which by default does nothing).
|
1 2 3 4 5 |
initialize(partitionIndex: Int): Unit = {} |
|
Note
|
initialize is overriden by InterpretedProjection and InterpretedMutableProjection projections that are used in interpreted expression evaluation.
|
| Projection | Description |
|---|---|
|
Appears not to be used anymore |
