Class ChunkedPrecessingExtension

Namespace

Tlabs.Data.Processing

Assembly

Tlabs.Data.dll

IQueryable<T> extension for chunked processing>.

public static class ChunkedPrecessingExtension

Inheritance

object

ChunkedPrecessingExtension

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

ChunkedProcessing<TProc, TEnt>(IQueryable<TEnt>, int, int)

Chunked processing of query result with a processor of TProc>.

public static void ChunkedProcessing<TProc, TEnt>(this IQueryable<TEnt> query, int chunkSz, int parallelCnt = 2) where TProc : IChunkProcessor<TEnt>

Parameters

query IQueryable<TEnt>

chunkSz int

parallelCnt int

Type Parameters

TProc

TEnt

Remarks

The processor receives a chunk of TEnt with chunkSz where up to parallelCnt processor being executed in parallel.