Safe Haskell | None |
---|---|
Language | Haskell2010 |
- data RDDId = RDDId {}
- data LocalSessionId = LocalSessionId {
- unLocalSession :: !Text
- data Computation = Computation {
- cSessionId :: !LocalSessionId
- cId :: !ComputationID
- cNodes :: ![UntypedNode]
- cTerminalNodes :: ![NodePath]
- cCollectingNode :: !NodePath
- cTerminalNodeIds :: ![NodeId]
- data BatchComputationKV = BatchComputationKV {
- bckvLocalPath :: !NodePath
- bckvDeps :: ![NodePath]
- bckvResult :: !PossibleNodeStatus
- data BatchComputationResult = BatchComputationResult {
- bcrTargetLocalPath :: !NodePath
- bcrResults :: ![(NodePath, [NodePath], PossibleNodeStatus)]
- data RDDInfo = RDDInfo {
- rddiId :: !RDDId
- rddiClassName :: !Text
- rddiRepr :: !Text
- rddiParents :: ![RDDId]
- data SparkComputationItemStats = SparkComputationItemStats {
- scisRddInfo :: ![RDDInfo]
- data PossibleNodeStatus
- data NodeComputationSuccess = NodeComputationSuccess {
- ncsData :: Value
- ncsDataType :: DataType
- data NodeComputationFailure = NodeComputationFailure {
- ncfMessage :: !Text
Documentation
The ID of an RDD in Spark.
data LocalSessionId Source #
data Computation Source #
Computation | |
|
data BatchComputationKV Source #
RDDInfo | |
|
data PossibleNodeStatus Source #