DryadLinqQueryable ClassDryadLINQ documentation
This class extends LINQ with a set of new operators that are specific to DryadLINQ. The new operators includes partitioning operators (HashPartition and RangePartition) and the Apply operator that enables stateful transformations on datasets.
Inheritance Hierarchy

SystemObject
  Microsoft.Research.DryadLinqDryadLinqQueryable

Namespace: Microsoft.Research.DryadLinq
Assembly: Microsoft.Research.DryadLinq (in Microsoft.Research.DryadLinq.dll) Version: 0.2.1.0 (0.2.1.0)
Syntax

public static class DryadLinqQueryable

The DryadLinqQueryable type exposes the following members.

Methods

  NameDescription
Public methodStatic memberAggregateTSource, TAccumulate(IQueryableTSource, ExpressionFuncTAccumulate, ExpressionFuncTAccumulate, TSource, TAccumulate)
Applies an aggregator function over a sequence.
Public methodStatic memberAggregateTSource, TAccumulate, TResult(IQueryableTSource, ExpressionFuncTAccumulate, ExpressionFuncTAccumulate, TSource, TAccumulate, ExpressionFuncTAccumulate, TResult)
Applies an aggregator function over a sequence.
Public methodStatic memberAggregateAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, TSource, TSource)
Public methodStatic memberAggregateAsQueryTSource, TAccumulate(IQueryableTSource, TAccumulate, ExpressionFuncTAccumulate, TSource, TAccumulate)
Public methodStatic memberAggregateAsQueryTSource, TAccumulate, TResult(IQueryableTSource, TAccumulate, ExpressionFuncTAccumulate, TSource, TAccumulate, ExpressionFuncTAccumulate, TResult)
Public methodStatic memberAllAsQueryTSource
Public methodStatic memberAnyAsQueryTSource(IQueryableTSource)
Public methodStatic memberAnyAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Boolean)
Public methodStatic memberApplyT1, T2(IQueryableT1, ExpressionFuncIEnumerableT1, IEnumerableT2)
Compute applyFunc (source)
Public methodStatic memberApplyT1, T2(IQueryableT1, IQueryable, ExpressionFuncIEnumerableT1, IEnumerable, IEnumerableT2)
Compute applyFunc on multiple sources
Public methodStatic memberApplyT1, T2(IQueryableT1, IQueryableT1, ExpressionFuncIEnumerableT1, IEnumerableT2)
Compute applyFunc on multiple sources
Public methodStatic memberApplyT1, T2, T3(IQueryableT1, IQueryableT2, ExpressionFuncIEnumerableT1, IEnumerableT2, IEnumerableT3)
Compute applyFunc(source1, source2)
Public methodStatic memberApplyPerPartitionT1, T2(IQueryableT1, ExpressionFuncIEnumerableT1, IEnumerableT2)
Compute applyFunc(source)
Public methodStatic memberApplyPerPartitionT1, T2(IQueryableT1, IQueryable, ExpressionFuncIEnumerableT1, IEnumerable, IEnumerableT2, Boolean)
Compute applyFunc on multiple sources
Public methodStatic memberApplyPerPartitionT1, T2(IQueryableT1, IQueryableT1, ExpressionFuncIEnumerableT1, IEnumerableT2, Boolean)
Compute applyFunc on multiple sources
Public methodStatic memberApplyPerPartitionT1, T2, T3(IQueryableT1, IQueryableT2, ExpressionFuncIEnumerableT1, IEnumerableT2, IEnumerableT3, Boolean)
Compute applyFunc(source1, source2)
Public methodStatic memberApplyWithPartitionIndexT1, T2
Computes a user-defined function on each partition of the input. The function takes a partition and its partition index as arguments.
Public methodStatic memberAssumeHashPartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey)
Instruct DryadLINQ to assume that the dataset is hash partitioned.
Public methodStatic memberAssumeHashPartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, IEqualityComparerTKey)
Instructs DryadLINQ to assume that the dataset is hash partitioned.
Public methodStatic memberAssumeOrderByTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, Boolean)
Instructs DryadLINQ to assume that each partition of the dataset is ordered. A dataset is ordered if it is range partitioned and each partition of it is ordered on the same key.
Public methodStatic memberAssumeOrderByTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, IComparerTKey, Boolean)
Instructs DryadLINQ to assume that each partition of the dataset is ordered. A dataset is ordered if it is range partitioned and each partition of it is ordered on the same key.
Public methodStatic memberAssumeRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, Boolean)
Instructs DryadLINQ to assume that the dataset is range partitioned.
Public methodStatic memberAssumeRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, TKey)
Instructs DryadLINQ to assume that the dataset is range partitioned by a specified list of keys.
Public methodStatic memberAssumeRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, IComparerTKey, Boolean)
Instructs DryadLINQ to assume that the dataset is range partitioned.
Public methodStatic memberAssumeRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, TKey, IComparerTKey)
Instructs DryadLINQ to assume that the dataset is range partitioned by a specified list of keys.
Public methodStatic memberAverageAsQuery(IQueryableDecimal)
Public methodStatic memberAverageAsQuery(IQueryableDouble)
Public methodStatic memberAverageAsQuery(IQueryableInt32)
Public methodStatic memberAverageAsQuery(IQueryableInt64)
Public methodStatic memberAverageAsQuery(IQueryableNullableDecimal)
Public methodStatic memberAverageAsQuery(IQueryableNullableDouble)
Public methodStatic memberAverageAsQuery(IQueryableNullableInt32)
Public methodStatic memberAverageAsQuery(IQueryableNullableInt64)
Public methodStatic memberAverageAsQuery(IQueryableNullableSingle)
Public methodStatic memberAverageAsQuery(IQueryableSingle)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Decimal)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Double)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Int32)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Int64)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableDecimal)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableDouble)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableInt32)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableInt64)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableSingle)
Public methodStatic memberAverageAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Single)
Public methodStatic memberContainsAsQueryTSource(IQueryableTSource, TSource)
Public methodStatic memberContainsAsQueryTSource(IQueryableTSource, TSource, IEqualityComparerTSource)
Public methodStatic memberCountAsQueryTSource(IQueryableTSource)
Public methodStatic memberCountAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Boolean)
Public methodStatic memberDoWhileT
Conditional DoWhile loop.
Public methodStatic memberFirstAsQueryTSource(IQueryableTSource)
Public methodStatic memberFirstAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Boolean)
Public methodStatic memberForkTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, TKey)
Divides the input dataset into a collection of datasets based on the keys of the records. The method produces one output dataset for each key in the specified key array. Input records that don't match any of the keys are dropped.
Public methodStatic memberForkT, R1, R2(IQueryableT, ExpressionFuncIEnumerableT, IEnumerableForkTupleR1, R2)
Forks a specified input dataset into two datasets. A specified user-defined function is applied to each partition of the input dataset to produce a sequence of ForkTuples.
Public methodStatic memberForkT, R1, R2(IQueryableT, ExpressionFuncT, ForkTupleR1, R2)
Compute two output datasets from one input dataset. A specified user-defined function is applied to each input element to produce zero or one element for each output dataset.
Public methodStatic memberForkT, R1, R2, R3(IQueryableT, ExpressionFuncIEnumerableT, IEnumerableForkTupleR1, R2, R3)
Forks a specified input dataset into three datasets. A specified user-defined function is applied to each partition of the input dataset to produce a sequence of ForkTuples.
Public methodStatic memberForkT, R1, R2, R3(IQueryableT, ExpressionFuncT, ForkTupleR1, R2, R3)
Forks one input dataset into three output datasets. A specified user-defined function is applied to each input element to produce zero or one element for each output dataset.
Public methodStatic memberHashPartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey)
Hash partition a dataset. The number of resulting partitions is dynamically determined at the runtime.
Public methodStatic memberHashPartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, IEqualityComparerTKey)
Hash partition a dataset. The number of resulting partitions is dynamically determined at the runtime.
Public methodStatic memberHashPartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, Int32)
Hash partition a dataset.
Public methodStatic memberHashPartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, IEqualityComparerTKey, Int32)
Hash partition a dataset.
Public methodStatic memberHashPartitionTSource, TKey, TResult(IQueryableTSource, ExpressionFuncTSource, TKey, ExpressionFuncTSource, TResult)
Hash partition a dataset. The number of resulting partitions is dynamically determined at the runtime.
Public methodStatic memberHashPartitionTSource, TKey, TResult(IQueryableTSource, ExpressionFuncTSource, TKey, IEqualityComparerTKey, ExpressionFuncTSource, TResult)
Hash partition a dataset. The number of resulting partitions is dynamically determined at the runtime.
Public methodStatic memberLastAsQueryTSource(IQueryableTSource)
Public methodStatic memberLastAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Boolean)
Public methodStatic memberLongCountAsQueryTSource(IQueryableTSource)
Public methodStatic memberLongCountAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Boolean)
Public methodStatic memberLongSelectTSource, TResult
Transforms each element of a sequence into a new form by applying a function of the element and its index.
Public methodStatic memberLongSelectManyTSource, TResult(IQueryableTSource, ExpressionFuncTSource, Int64, IEnumerableTResult)
Transforms each element of a sequence into an IEnumerable{T} by applying a function to the element and its index, and then flattens the resulting sequences into one sequence.
Public methodStatic memberLongSelectManyTSource, TCollection, TResult(IQueryableTSource, ExpressionFuncTSource, Int64, IEnumerableTCollection, ExpressionFuncTSource, TCollection, TResult)
Transforms each element of a sequence into an IEnumerable{T} by applying a function to the element and its index, and then flattens the resulting sequences into one sequence.
Public methodStatic memberLongSkipWhileTSource
Skips elements in a sequence as long as a specified condition is true and then returns the remaining elements. The predicate is a function of an element and its index.
Public methodStatic memberLongTakeWhileTSource
Returns the largest prefix of a sequence such that the elements satisfy a specified predicate.
Public methodStatic memberLongWhereTSource
Filters a sequence of values based on a predicate. Each element's index is used in the logic of the predicate function.
Public methodStatic memberMaxAsQueryTSource(IQueryableTSource)
Public methodStatic memberMaxAsQueryTSource, TResult(IQueryableTSource, ExpressionFuncTSource, TResult)
Public methodStatic memberMinAsQueryTSource(IQueryableTSource)
Public methodStatic memberMinAsQueryTSource, TResult(IQueryableTSource, ExpressionFuncTSource, TResult)
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey)
Range partition a dataset. The list of range keys are determined dynamically at runtime.
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, Boolean)
Range partition a dataset. The list of range keys are determined dynamically at runtime.
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, Int32)
Range partition a dataset. The list of range keys are determined dynamically at runtime.
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, TKey)
Range partition a dataset using an array of partition keys.
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, Boolean, Int32)
Range partition a dataset. The list of range keys are determined dynamically at runtime.
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, IComparerTKey, Boolean)
Range partition a dataset. The list of range keys are determined dynamically at runtime.
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, TKey, IComparerTKey)
Range partition a dataset using a specified list of keys.
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, IComparerTKey, Boolean, Int32)
Range partition a dataset. The list of range keys are determined dynamically at runtime.
Public methodStatic memberRangePartitionTSource, TKey(IQueryableTSource, ExpressionFuncTSource, TKey, TKey, IComparerTKey, Boolean)
Range partition a dataset using a specified list of keys.
Public methodStatic memberSequenceEqualAsQueryTSource(IQueryableTSource, IEnumerableTSource)
Public methodStatic memberSequenceEqualAsQueryTSource(IQueryableTSource, IEnumerableTSource, IEqualityComparerTSource)
Public methodStatic memberSingleAsQueryTSource(IQueryableTSource)
Public methodStatic memberSingleAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Boolean)
Public methodStatic memberSlidingWindowT1, T2
Apply a function on every sliding window on the input sequence of records.
Public methodStatic memberSubmit(IQueryable)
Submits a list of DryadLINQ queries for asynchronous execution.
Public methodStatic memberSubmitTSource(IQueryableTSource)
Submits a specified query for asynchronous execution.
Public methodStatic memberSubmitAndWait(IQueryable)
Submits a list of DryadLinq queries for execution and waits for the job to complete
Public methodStatic memberSubmitAndWaitTSource(IQueryableTSource)
Submits a specified query and then waits for the job to complete
Public methodStatic memberSumAsQuery(IQueryableDecimal)
Public methodStatic memberSumAsQuery(IQueryableDouble)
Public methodStatic memberSumAsQuery(IQueryableInt32)
Public methodStatic memberSumAsQuery(IQueryableInt64)
Public methodStatic memberSumAsQuery(IQueryableNullableDecimal)
Public methodStatic memberSumAsQuery(IQueryableNullableDouble)
Public methodStatic memberSumAsQuery(IQueryableNullableInt32)
Public methodStatic memberSumAsQuery(IQueryableNullableInt64)
Public methodStatic memberSumAsQuery(IQueryableNullableSingle)
Public methodStatic memberSumAsQuery(IQueryableSingle)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Decimal)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Double)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Int32)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Int64)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableDecimal)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableDouble)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableInt32)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableInt64)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, NullableSingle)
Public methodStatic memberSumAsQueryTSource(IQueryableTSource, ExpressionFuncTSource, Single)
Public methodStatic memberToStoreTSource(IQueryableTSource, String, Boolean, ExpressionActionIEnumerableTSource, Stream, ExpressionFuncStream, IEnumerableTSource)
Specifies a stream URI to be populated with the result of a specified DryadLINQ query.
Public methodStatic memberToStoreTSource(IQueryableTSource, Uri, Boolean, ExpressionActionIEnumerableTSource, Stream, ExpressionFuncStream, IEnumerableTSource)
Specifies a stream URI to be populated with the result of a specified DryadLINQ query.
Top
See Also

Reference