Keyword(s) for which to search:
Sort results by title
Keyword Index
Direct Link
Welcome to the DryadLINQ help page
Getting Started
Quick Start
Setting up an HDInsight 3.0 cluster
Building the Job Browser
Resources
Running a DryadLINQ job on HDInsight
Version History
Version 0.2.1
Version 0.2.0
Version 0.1.2
Microsoft.Research.DryadLinq
AssociativeAttribute Class
AssociativeAttribute Constructor
AssociativeAttribute Methods
AssociativeAttribute Properties
AssociativeType Property
CompressionScheme Enumeration
CustomDryadLinqSerializerAttribute Class
CustomDryadLinqSerializerAttribute Constructor
CustomDryadLinqSerializerAttribute Methods
CustomDryadLinqSerializerAttribute Properties
SerializerType Property
DataProvider Class
DataProvider Constructor
DataProvider Methods
CheckExistence Method
Egress Method
GetMetaData Method
GetStreamInfo Method
GetTemporaryStreamUri Method
Ingress(T) Method
Register Method
RewriteUri(T) Method
DataProvider Properties
PathSeparator Property
Scheme Property
DecomposableAttribute Class
DecomposableAttribute Constructor
DecomposableAttribute Methods
DecomposableAttribute Properties
DecompositionType Property
DryadLinqBinaryReader Class
DryadLinqBinaryReader Methods
ReadBool Method
ReadBytes Method
ReadChar Method
ReadChars Method
ReadCompactInt32 Method
ReadDateTime Method
ReadDecimal Method
ReadDouble Method
ReadGuid Method
ReadInt16 Method
ReadInt32 Method
ReadInt64 Method
ReadRawBytes Method
ReadSByte Method
ReadSingle Method
ReadSqlDateTime Method
ReadString Method
ReadUByte Method
ReadUInt16 Method
ReadUInt32 Method
ReadUInt64 Method
ToString Method
DryadLinqBinaryWriter Class
DryadLinqBinaryWriter Methods
ToString Method
Write Method
Write Method (Boolean)
Write Method (Byte)
Write Method (Char)
Write Method (SqlDateTime)
Write Method (DateTime)
Write Method (Decimal)
Write Method (Double)
Write Method (Guid)
Write Method (Int16)
Write Method (Int32)
Write Method (Int64)
Write Method (SByte)
Write Method (Single)
Write Method (String)
Write Method (UInt16)
Write Method (UInt32)
Write Method (UInt64)
WriteBytes Method
WriteChars Method
WriteCompact Method
WriteRawBytes Method
DryadLinqCluster Interface
DryadLinqCluster Methods
Client Method
MakeInternalClusterUri Method
DryadLinqCluster Properties
DefaultMaxNodes Property
DfsClient Property
HeadNode Property
Kind Property
DryadLinqContext Class
DryadLinqContext Constructor
DryadLinqContext Constructor (DryadLinqCluster)
DryadLinqContext Constructor (Int32, String)
DryadLinqContext Constructor (String, PlatformKind)
DryadLinqContext Methods
AzureAccountKey Method
ClientVersion Method
Dispose Method
Equals Method
Equals Method (DryadLinqContext)
FromEnumerable(T) Method
FromStore Method
FromStore(T) Method (String, Expression(Func(Stream, IEnumerable(T))))
FromStore(T) Method (Uri, Expression(Func(Stream, IEnumerable(T))))
RegisterAzureAccount Method
DryadLinqContext Properties
ApplicationMasterMbMemory Property
CompileForVertexDebugging Property
ContainerMbMemory Property
DebugBreak Property
DryadHomeDirectory Property
EnableSpeculativeDuplication Property
ExecutorKind Property
ForceGC Property
GraphManagerNode Property
HeadNode Property
IntermediateDataCompressionScheme Property
JobEnvironmentVariables Property
JobFriendlyName Property
JobMaxNodes Property
JobMinNodes Property
JobPassword Property
JobRuntimeLimit Property
JobUsername Property
LocalDebug Property
MatchClientNetFrameworkVersion Property
NodeGroup Property
OutputDataCompressionScheme Property
PartitionUncPath Property
PeloponneseHomeDirectory Property
PlatformKind Property
Queue Property
ResourcesToAdd Property
ResourcesToRemove Property
RuntimeLoggingLevel Property
SelectOrderPreserving Property
ThreadsPerWorker Property
DryadLinqException Class
DryadLinqException Constructor
DryadLinqException Constructor (String)
DryadLinqException Constructor (SerializationInfo, StreamingContext)
DryadLinqException Constructor (String, Exception)
DryadLinqException Methods
GetObjectData Method
DryadLinqException Properties
ErrorCode Property
DryadLinqException Events
DryadLinqExtension Class
DryadLinqExtension Methods
BroadCast Method
BroadCast(T) Method (IQueryable(T), Int32)
BroadCast(T, T1) Method (IQueryable(T), IQueryable(T1))
CheckOrderBy(TSource, TKey) Method
CrossProduct(T1, T2, T3) Method
DoWhile Method
DoWhile(T) Method (IQueryable(T), Func(IQueryable(T), IQueryable(T)), Func(IQueryable(T), IQueryable(T), IQueryable(Boolean)))
DoWhile(T) Method (IQueryable(T), Func(IQueryable(T), IQueryable(T)), Func(IQueryable(T), IQueryable(T), IQueryable(Boolean)), Int32)
MapReduce(TSource, TMap, TKey, TResult) Method
DryadLinqJobInfo Class
DryadLinqJobInfo Methods
CancelJob Method
Wait Method
DryadLinqJobInfo Properties
JobIds Property
DryadLinqLog Class
DryadLinqLog Fields
Level Field
DryadLinqLog Methods
AddCritical Method
AddError Method
AddInfo Method
AddVerbose Method
AddWarning Method
DryadLinqMetaData Class
DryadLinqMetaData Methods
DryadLinqQueryable Class
DryadLinqQueryable Methods
Aggregate Method
Aggregate(TSource, TAccumulate) Method (IQueryable(TSource), Expression(Func(TAccumulate)), Expression(Func(TAccumulate, TSource, TAccumulate)))
Aggregate(TSource, TAccumulate, TResult) Method (IQueryable(TSource), Expression(Func(TAccumulate)), Expression(Func(TAccumulate, TSource, TAccumulate)), Expression(Func(TAccumulate, TResult)))
AggregateAsQuery Method
AggregateAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, TSource, TSource)))
AggregateAsQuery(TSource, TAccumulate) Method (IQueryable(TSource), TAccumulate, Expression(Func(TAccumulate, TSource, TAccumulate)))
AggregateAsQuery(TSource, TAccumulate, TResult) Method (IQueryable(TSource), TAccumulate, Expression(Func(TAccumulate, TSource, TAccumulate)), Expression(Func(TAccumulate, TResult)))
AllAsQuery(TSource) Method
AnyAsQuery Method
AnyAsQuery(TSource) Method (IQueryable(TSource))
AnyAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Boolean)))
Apply Method
Apply(T1, T2) Method (IQueryable(T1), Expression(Func(IEnumerable(T1), IEnumerable(T2))))
Apply(T1, T2) Method (IQueryable(T1), IQueryable[], Expression(Func(IEnumerable(T1), IEnumerable[], IEnumerable(T2))))
Apply(T1, T2) Method (IQueryable(T1), IQueryable(T1)[], Expression(Func(IEnumerable(T1)[], IEnumerable(T2))))
Apply(T1, T2, T3) Method (IQueryable(T1), IQueryable(T2), Expression(Func(IEnumerable(T1), IEnumerable(T2), IEnumerable(T3))))
ApplyPerPartition Method
ApplyPerPartition(T1, T2) Method (IQueryable(T1), Expression(Func(IEnumerable(T1), IEnumerable(T2))))
ApplyPerPartition(T1, T2) Method (IQueryable(T1), IQueryable[], Expression(Func(IEnumerable(T1), IEnumerable[], IEnumerable(T2))), Boolean)
ApplyPerPartition(T1, T2) Method (IQueryable(T1), IQueryable(T1)[], Expression(Func(IEnumerable(T1)[], IEnumerable(T2))), Boolean)
ApplyPerPartition(T1, T2, T3) Method (IQueryable(T1), IQueryable(T2), Expression(Func(IEnumerable(T1), IEnumerable(T2), IEnumerable(T3))), Boolean)
ApplyWithPartitionIndex(T1, T2) Method
AssumeHashPartition Method
AssumeHashPartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)))
AssumeHashPartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), IEqualityComparer(TKey))
AssumeOrderBy Method
AssumeOrderBy(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), Boolean)
AssumeOrderBy(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), IComparer(TKey), Boolean)
AssumeRangePartition Method
AssumeRangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), Boolean)
AssumeRangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), TKey[])
AssumeRangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), IComparer(TKey), Boolean)
AssumeRangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), TKey[], IComparer(TKey))
AverageAsQuery Method
AverageAsQuery Method (IQueryable(Decimal))
AverageAsQuery Method (IQueryable(Double))
AverageAsQuery Method (IQueryable(Int32))
AverageAsQuery Method (IQueryable(Int64))
AverageAsQuery Method (IQueryable(Nullable(Decimal)))
AverageAsQuery Method (IQueryable(Nullable(Double)))
AverageAsQuery Method (IQueryable(Nullable(Int32)))
AverageAsQuery Method (IQueryable(Nullable(Int64)))
AverageAsQuery Method (IQueryable(Nullable(Single)))
AverageAsQuery Method (IQueryable(Single))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Decimal)))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Double)))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Int32)))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Int64)))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Decimal))))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Double))))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Int32))))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Int64))))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Single))))
AverageAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Single)))
ContainsAsQuery Method
ContainsAsQuery(TSource) Method (IQueryable(TSource), TSource)
ContainsAsQuery(TSource) Method (IQueryable(TSource), TSource, IEqualityComparer(TSource))
CountAsQuery Method
CountAsQuery(TSource) Method (IQueryable(TSource))
CountAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Boolean)))
DoWhile(T) Method
FirstAsQuery Method
FirstAsQuery(TSource) Method (IQueryable(TSource))
FirstAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Boolean)))
Fork Method
Fork(T, R1, R2) Method (IQueryable(T), Expression(Func(IEnumerable(T), IEnumerable(ForkTuple(R1, R2)))))
Fork(T, R1, R2, R3) Method (IQueryable(T), Expression(Func(IEnumerable(T), IEnumerable(ForkTuple(R1, R2, R3)))))
Fork(T, R1, R2) Method (IQueryable(T), Expression(Func(T, ForkTuple(R1, R2))))
Fork(T, R1, R2, R3) Method (IQueryable(T), Expression(Func(T, ForkTuple(R1, R2, R3))))
Fork(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), TKey[])
HashPartition Method
HashPartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)))
HashPartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), IEqualityComparer(TKey))
HashPartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), Int32)
HashPartition(TSource, TKey, TResult) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), Expression(Func(TSource, TResult)))
HashPartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), IEqualityComparer(TKey), Int32)
HashPartition(TSource, TKey, TResult) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), IEqualityComparer(TKey), Expression(Func(TSource, TResult)))
LastAsQuery Method
LastAsQuery(TSource) Method (IQueryable(TSource))
LastAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Boolean)))
LongCountAsQuery Method
LongCountAsQuery(TSource) Method (IQueryable(TSource))
LongCountAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Boolean)))
LongSelect(TSource, TResult) Method
LongSelectMany Method
LongSelectMany(TSource, TResult) Method (IQueryable(TSource), Expression(Func(TSource, Int64, IEnumerable(TResult))))
LongSelectMany(TSource, TCollection, TResult) Method (IQueryable(TSource), Expression(Func(TSource, Int64, IEnumerable(TCollection))), Expression(Func(TSource, TCollection, TResult)))
LongSkipWhile(TSource) Method
LongTakeWhile(TSource) Method
LongWhere(TSource) Method
MaxAsQuery Method
MaxAsQuery(TSource) Method (IQueryable(TSource))
MaxAsQuery(TSource, TResult) Method (IQueryable(TSource), Expression(Func(TSource, TResult)))
MinAsQuery Method
MinAsQuery(TSource) Method (IQueryable(TSource))
MinAsQuery(TSource, TResult) Method (IQueryable(TSource), Expression(Func(TSource, TResult)))
RangePartition Method
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)))
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), Boolean)
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), Int32)
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), TKey[])
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), Boolean, Int32)
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), IComparer(TKey), Boolean)
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), TKey[], IComparer(TKey))
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), IComparer(TKey), Boolean, Int32)
RangePartition(TSource, TKey) Method (IQueryable(TSource), Expression(Func(TSource, TKey)), TKey[], IComparer(TKey), Boolean)
SequenceEqualAsQuery Method
SequenceEqualAsQuery(TSource) Method (IQueryable(TSource), IEnumerable(TSource))
SequenceEqualAsQuery(TSource) Method (IQueryable(TSource), IEnumerable(TSource), IEqualityComparer(TSource))
SingleAsQuery Method
SingleAsQuery(TSource) Method (IQueryable(TSource))
SingleAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Boolean)))
SlidingWindow(T1, T2) Method
Submit Method
Submit Method (IQueryable[])
Submit(TSource) Method (IQueryable(TSource))
SubmitAndWait Method
SubmitAndWait Method (IQueryable[])
SubmitAndWait(TSource) Method (IQueryable(TSource))
SumAsQuery Method
SumAsQuery Method (IQueryable(Decimal))
SumAsQuery Method (IQueryable(Double))
SumAsQuery Method (IQueryable(Int32))
SumAsQuery Method (IQueryable(Int64))
SumAsQuery Method (IQueryable(Nullable(Decimal)))
SumAsQuery Method (IQueryable(Nullable(Double)))
SumAsQuery Method (IQueryable(Nullable(Int32)))
SumAsQuery Method (IQueryable(Nullable(Int64)))
SumAsQuery Method (IQueryable(Nullable(Single)))
SumAsQuery Method (IQueryable(Single))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Decimal)))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Double)))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Int32)))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Int64)))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Decimal))))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Double))))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Int32))))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Int64))))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Nullable(Single))))
SumAsQuery(TSource) Method (IQueryable(TSource), Expression(Func(TSource, Single)))
ToStore Method
ToStore(TSource) Method (IQueryable(TSource), String, Boolean, Expression(Action(IEnumerable(TSource), Stream)), Expression(Func(Stream, IEnumerable(TSource))))
ToStore(TSource) Method (IQueryable(TSource), Uri, Boolean, Expression(Action(IEnumerable(TSource), Stream)), Expression(Func(Stream, IEnumerable(TSource))))
DryadLinqStreamInfo Class
DryadLinqStreamInfo Constructor
DryadLinqStreamInfo Methods
DryadLinqStreamInfo Properties
DataSize Property
PartitionCount Property
DryadLinqYarnCluster Class
DryadLinqYarnCluster Constructor
DryadLinqYarnCluster Constructor (String, Int32, Int32, Int32, String, String, Int32, String, Int32)
DryadLinqYarnCluster Constructor (String, Int32, Int32, Int32, String, String, Int32, String, Int32, Int32, String, Int32)
DryadLinqYarnCluster Fields
ApplicationMasterMbMemory Field
ContainerMbMemory Field
DefaultNumberOfContainers Field
HdfsPort Field
LauncherNode Field
LauncherPort Field
NameNode Field
User Field
WebHdfsPort Field
YarnPort Field
DryadLinqYarnCluster Methods
Client Method
MakeInternalClusterUri Method
DryadLinqYarnCluster Properties
DefaultMaxNodes Property
DfsClient Property
HeadNode Property
Kind Property
Queue Property
ExecutorKind Enumeration
ForkTuple(T1, T2) Structure
ForkTuple(T1, T2) Constructor
ForkTuple(T1, T2) Methods
Equals Method
Equals Method (ForkTuple(T1, T2))
GetHashCode Method
ForkTuple(T1, T2) Properties
First Property
HasFirst Property
HasSecond Property
Second Property
ForkTuple(T1, T2, T3) Structure
ForkTuple(T1, T2, T3) Constructor
ForkTuple(T1, T2, T3) Methods
Equals Method
Equals Method (ForkTuple(T1, T2, T3))
GetHashCode Method
ForkTuple(T1, T2, T3) Properties
First Property
HasFirst Property
HasSecond Property
HasThird Property
Second Property
Third Property
ForkValue(T) Structure
ForkValue(T) Constructor
ForkValue(T) Methods
Equals Method
Equals Method (ForkValue(T))
GetHashCode Method
ForkValue(T) Properties
HasValue Property
Value Property
GenericAssociative(TAssoc, TAccumulate) Class
GenericAssociative(TAssoc, TAccumulate) Methods
RecursiveAccumulate Method
Seed Method
GenericDecomposable(TDecomposable, TSource, TAccumulate, TResult) Class
GenericDecomposable(TDecomposable, TSource, TAccumulate, TResult) Methods
Accumulate Method
FinalReduce Method
Initialize Method
RecursiveAccumulate Method
Seed Method
IAssociative(TAccumulate) Interface
IAssociative(TAccumulate) Methods
RecursiveAccumulate Method
Seed Method
IDecomposable(TSource, TAccumulate, TResult) Interface
IDecomposable(TSource, TAccumulate, TResult) Methods
Accumulate Method
FinalReduce Method
Initialize Method
RecursiveAccumulate Method
Seed Method
IDryadLinqSerializer(T) Interface
IDryadLinqSerializer(T) Methods
Read Method
Write Method
IKeyedMultiQueryable(T, K) Interface
IKeyedMultiQueryable(T, K) Methods
IKeyedMultiQueryable(T, K) Properties
Item Property
Keys Property
IMultiQueryable Interface
IMultiQueryable Methods
ElementType Method
IMultiQueryable Properties
Expression Property
NumberOfInputs Property
Provider Property
IMultiQueryable(T1, T2) Interface
IMultiQueryable(T1, T2) Methods
IMultiQueryable(T1, T2) Properties
First Property
Second Property
IMultiQueryable(T1, T2, T3) Interface
IMultiQueryable(T1, T2, T3) Methods
IMultiQueryable(T1, T2, T3) Properties
First Property
Second Property
Third Property
LineRecord Structure
LineRecord Constructor
LineRecord Methods
CompareTo Method
CompareTo Method (Object)
CompareTo Method (LineRecord)
Equals Method
Equals Method (Object)
Equals Method (LineRecord)
GetHashCode Method
ToString Method
LineRecord Operators
Equality Operator
GreaterThan Operator
Inequality Operator
LessThan Operator
LineRecord Properties
Line Property
NullableAttribute Class
NullableAttribute Constructor
NullableAttribute Methods
NullableAttribute Properties
CanBeNull Property
Pair(T1, T2) Structure
Pair(T1, T2) Constructor
Pair(T1, T2) Methods
Equals Method
Equals Method (Object)
Equals Method (Pair(T1, T2))
Equals Method (Pair(T1, T2), Pair(T1, T2))
GetHashCode Method
ToString Method
Pair(T1, T2) Operators
Equality Operator
Inequality Operator
Pair(T1, T2) Properties
Key Property
Value Property
PlatformKind Enumeration
QueryLoggingLevel Enumeration
ResourceAttribute Class
ResourceAttribute Constructor
ResourceAttribute Methods
ResourceAttribute Properties
IsExpensive Property
IsStateful Property
This page uses an IFRAME but your browser does not support it.