Skip to content

UnsafeProjection

UnsafeProjection is an extension of the Projection abstraction for expressions that encode InternalRows to UnsafeRows.

UnsafeProjection: InternalRow =[apply]=> UnsafeRow

Contract

Encoding InternalRow as UnsafeRow

apply(
  row: InternalRow): UnsafeRow

Encodes the given InternalRow to an UnsafeRow

Implementations

  • InterpretedUnsafeProjection

CodeGeneratorWithInterpretedFallback

UnsafeProjection factory object is a CodeGeneratorWithInterpretedFallback of UnsafeProjections (based on Expressions).

CodeGeneratorWithInterpretedFallback[Seq[Expression], UnsafeProjection]

createCodeGeneratedObject

createCodeGeneratedObject(
  in: Seq[Expression]): UnsafeProjection

createCodeGeneratedObject is part of the CodeGeneratorWithInterpretedFallback abstraction.

createCodeGeneratedObject...FIXME

createInterpretedObject

createInterpretedObject(
  in: Seq[Expression]): UnsafeProjection

createInterpretedObject is part of the CodeGeneratorWithInterpretedFallback abstraction.

createInterpretedObject...FIXME

create

create(
  fields: Array[DataType]): UnsafeProjection
create(
  expr: Expression): UnsafeProjection
create(
  exprs: Seq[Expression]): UnsafeProjection
create(
  exprs: Seq[Expression],
  inputSchema: Seq[Attribute]): UnsafeProjection
create(
  schema: StructType): UnsafeProjection

create creates an UnsafeProjection for the given BoundReferences.