Prajna


DParam

DParam, setting parameters for DSet mapping Base of PrajnaDistributed Object

Constructors

ConstructorDescription
new(dobj)
Signature: dobj:DParam -> DParam

Construct a DParam object based on a prior template

new()
Signature: unit -> DParam

Construct a empty DParam object

Instance members

Instance memberDescription
Cluster()
Signature: unit -> Cluster

Get and Set Cluster

Cluster()
Signature: unit -> unit

Get and Set Cluster

GetCluster()
Signature: unit -> Cluster

Get Current Cluster associated with the object, if the current cluster is not set, use the default cluster

IsPartitionByKey()
Signature: unit -> bool

Is the partition of DSet formed by a key function that maps a data item to an unique partition

IsPartitionByKey()
Signature: unit -> unit

Is the partition of DSet formed by a key function that maps a data item to an unique partition

Name()
Signature: unit -> string

Get and Set name

Name()
Signature: unit -> unit

Get and Set name

NumPartitions()
Signature: unit -> int
Modifiers: abstract

Number of partitions

NumPartitions()
Signature: unit -> unit
Modifiers: abstract

Number of partitions

NumReplications()
Signature: unit -> int

Required number of replications for durability

NumReplications()
Signature: unit -> unit

Required number of replications for durability

Password()
Signature: unit -> string

Password that will be hashed and used for triple DES encryption and decryption of data.

Password()
Signature: unit -> unit

Password that will be hashed and used for triple DES encryption and decryption of data.

PeerRcvdSpeedLimit()
Signature: unit -> int64

Flow control, limits the total bytes send out to PeerRcvdSpeedLimit If it is communicating with N peer, each peer, the sending queue limit is PeerRcvdSpeedLimit/N

PeerRcvdSpeedLimit()
Signature: unit -> unit

Flow control, limits the total bytes send out to PeerRcvdSpeedLimit If it is communicating with N peer, each peer, the sending queue limit is PeerRcvdSpeedLimit/N

PostGroupByReserialization()
Signature: unit -> int

In BinSort/MapReduce, indicate the collection size after the a collection of data is received from network

PostGroupByReserialization()
Signature: unit -> unit

In BinSort/MapReduce, indicate the collection size after the a collection of data is received from network

PreGroupByReserialization()
Signature: unit -> int

In BinSort/MapReduce, indicate whether need to regroup collection before sending a collection of data across network

PreGroupByReserialization()
Signature: unit -> unit

In BinSort/MapReduce, indicate whether need to regroup collection before sending a collection of data across network

SendingQueueLimit()
Signature: unit -> int

Sender flow control, DSet/DStream limits the total sending queue to SendingQueueLimit If it is communicating with N peer, each peer, the sending queue limit is SendingQueueLimit/N

SendingQueueLimit()
Signature: unit -> unit

Sender flow control, DSet/DStream limits the total sending queue to SendingQueueLimit If it is communicating with N peer, each peer, the sending queue limit is SendingQueueLimit/N

SerializationLimit()
Signature: unit -> int

Number of record in a collection during data analytical jobs. This parameter will not change number of record in an existing collection of a DSet. To change the number of record of an existing collection, please use RowsReorg().

SerializationLimit()
Signature: unit -> unit

Number of record in a collection during data analytical jobs. This parameter will not change number of record in an existing collection of a DSet. To change the number of record of an existing collection, please use RowsReorg().

StorageType()
Signature: unit -> StorageKind

Storage Type, which include StorageMedia and IndexMethod

StorageType()
Signature: unit -> unit

Storage Type, which include StorageMedia and IndexMethod

TypeOfLoadBalancer()
Signature: unit -> LoadBalanceAlgorithm

Get or Set Load Balancer Note that the change will affect Partitioner

TypeOfLoadBalancer()
Signature: unit -> unit

Get or Set Load Balancer Note that the change will affect Partitioner

Version()
Signature: unit -> DateTime

Get and Set version

Version()
Signature: unit -> unit

Get and Set version

VersionString
Signature: string

Represent version in a string for display

Fork me on GitHub