Search Java Code Snippets


  Help us in improving the repository. Add new snippets through 'Submit Code Snippet ' link.





Java - Code Samples

 Sample 1. Code Sample / Example / Snippet of org.apache.spark.sql.catalyst.expressions.UnsafeProjection

  public UnsafeFixedWidthAggregationMap(

InternalRow emptyAggregationBuffer,

StructType aggregationBufferSchema,

StructType groupingKeySchema,

TaskMemoryManager taskMemoryManager,

int initialCapacity,

long pageSizeBytes,

boolean enablePerfMetrics) {

this.aggregationBufferSchema = aggregationBufferSchema;

this.groupingKeyProjection = UnsafeProjection.create(groupingKeySchema);

this.groupingKeySchema = groupingKeySchema;

this.map =

new BytesToBytesMap(taskMemoryManager, initialCapacity, pageSizeBytes, enablePerfMetrics);

this.enablePerfMetrics = enablePerfMetrics;



final UnsafeProjection valueProjection = UnsafeProjection.create(aggregationBufferSchema);

this.emptyAggregationBuffer = valueProjection.apply(emptyAggregationBuffer).getBytes();

}


   Like      Feedback      org.apache.spark.sql.catalyst.expressions.UnsafeProjection



Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner