Safe Haskell	None
Language	Haskell2010

Spark.Core.Internal.Client

Contents

AESON INSTANCES ***

Synopsis

Documentation

data RDDId Source #

The ID of an RDD in Spark.

Constructors

RDDId
Fields unRDDId :: !Int

Instances

Eq RDDId Source #
Methods (==) :: RDDId -> RDDId -> Bool # (/=) :: RDDId -> RDDId -> Bool #
Ord RDDId Source #
Methods compare :: RDDId -> RDDId -> Ordering # (<) :: RDDId -> RDDId -> Bool # (<=) :: RDDId -> RDDId -> Bool # (>) :: RDDId -> RDDId -> Bool # (>=) :: RDDId -> RDDId -> Bool # max :: RDDId -> RDDId -> RDDId # min :: RDDId -> RDDId -> RDDId #
Show RDDId Source #
Methods showsPrec :: Int -> RDDId -> ShowS # show :: RDDId -> String # showList :: [RDDId] -> ShowS #
FromJSON RDDId Source #
Methods parseJSON :: Value -> Parser RDDId #

data LocalSessionId Source #

Constructors

LocalSessionId
Fields unLocalSession :: !Text

Instances

Eq LocalSessionId Source #
Methods (==) :: LocalSessionId -> LocalSessionId -> Bool # (/=) :: LocalSessionId -> LocalSessionId -> Bool #
Show LocalSessionId Source #
Methods showsPrec :: Int -> LocalSessionId -> ShowS # show :: LocalSessionId -> String # showList :: [LocalSessionId] -> ShowS #
ToJSON LocalSessionId Source #
Methods toJSON :: LocalSessionId -> Value # toEncoding :: LocalSessionId -> Encoding #

data Computation Source #

Constructors

Computation
Fields cSessionId :: !LocalSessionId cId :: !ComputationID cNodes :: ![UntypedNode] cTerminalNodes :: ![NodePath] cCollectingNode :: !NodePath cTerminalNodeIds :: ![NodeId]

Instances

Show Computation Source #
Methods showsPrec :: Int -> Computation -> ShowS # show :: Computation -> String # showList :: [Computation] -> ShowS #
Generic Computation Source #
Associated Types type Rep Computation :: * -> * # Methods from :: Computation -> Rep Computation x # to :: Rep Computation x -> Computation #
type Rep Computation Source #
type Rep Computation = D1 (MetaData "Computation" "Spark.Core.Internal.Client" "karps-0.2.0.0-Ergj4tYxtT33lacYzPfeHg" False) (C1 (MetaCons "Computation" PrefixI True) ((::) ((::) (S1 (MetaSel (Just Symbol "cSessionId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 LocalSessionId)) ((::) (S1 (MetaSel (Just Symbol "cId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 ComputationID)) (S1 (MetaSel (Just Symbol "cNodes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 [UntypedNode])))) ((::) (S1 (MetaSel (Just Symbol "cTerminalNodes") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 [NodePath])) ((:*:) (S1 (MetaSel (Just Symbol "cCollectingNode") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 NodePath)) (S1 (MetaSel (Just Symbol "cTerminalNodeIds") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 [NodeId]))))))

data BatchComputationKV Source #

Constructors

BatchComputationKV
Fields bckvLocalPath :: !NodePath bckvDeps :: ![NodePath] bckvResult :: !PossibleNodeStatus

Instances

Show BatchComputationKV Source #
Methods showsPrec :: Int -> BatchComputationKV -> ShowS # show :: BatchComputationKV -> String # showList :: [BatchComputationKV] -> ShowS #
Generic BatchComputationKV Source #
Associated Types type Rep BatchComputationKV :: * -> * # Methods from :: BatchComputationKV -> Rep BatchComputationKV x # to :: Rep BatchComputationKV x -> BatchComputationKV #
FromJSON BatchComputationKV Source #
Methods parseJSON :: Value -> Parser BatchComputationKV #
type Rep BatchComputationKV Source #
type Rep BatchComputationKV = D1 (MetaData "BatchComputationKV" "Spark.Core.Internal.Client" "karps-0.2.0.0-Ergj4tYxtT33lacYzPfeHg" False) (C1 (MetaCons "BatchComputationKV" PrefixI True) ((::) (S1 (MetaSel (Just Symbol "bckvLocalPath") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 NodePath)) ((::) (S1 (MetaSel (Just Symbol "bckvDeps") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 [NodePath])) (S1 (MetaSel (Just Symbol "bckvResult") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 PossibleNodeStatus)))))

data BatchComputationResult Source #

Constructors

BatchComputationResult
Fields bcrTargetLocalPath :: !NodePath bcrResults :: ![(NodePath, [NodePath], PossibleNodeStatus)]

Instances

Show BatchComputationResult Source #
Methods showsPrec :: Int -> BatchComputationResult -> ShowS # show :: BatchComputationResult -> String # showList :: [BatchComputationResult] -> ShowS #
Generic BatchComputationResult Source #
Associated Types type Rep BatchComputationResult :: * -> * # Methods from :: BatchComputationResult -> Rep BatchComputationResult x # to :: Rep BatchComputationResult x -> BatchComputationResult #
FromJSON BatchComputationResult Source #
Methods parseJSON :: Value -> Parser BatchComputationResult #
type Rep BatchComputationResult Source #
type Rep BatchComputationResult = D1 (MetaData "BatchComputationResult" "Spark.Core.Internal.Client" "karps-0.2.0.0-Ergj4tYxtT33lacYzPfeHg" False) (C1 (MetaCons "BatchComputationResult" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "bcrTargetLocalPath") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 NodePath)) (S1 (MetaSel (Just Symbol "bcrResults") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 [(NodePath, [NodePath], PossibleNodeStatus)]))))

data RDDInfo Source #

Constructors

RDDInfo
Fields rddiId :: !RDDId rddiClassName :: !Text rddiRepr :: !Text rddiParents :: ![RDDId]

Instances

Show RDDInfo Source #
Methods showsPrec :: Int -> RDDInfo -> ShowS # show :: RDDInfo -> String # showList :: [RDDInfo] -> ShowS #
Generic RDDInfo Source #
Associated Types type Rep RDDInfo :: * -> * # Methods from :: RDDInfo -> Rep RDDInfo x # to :: Rep RDDInfo x -> RDDInfo #
FromJSON RDDInfo Source #
Methods parseJSON :: Value -> Parser RDDInfo #
type Rep RDDInfo Source #
type Rep RDDInfo = D1 (MetaData "RDDInfo" "Spark.Core.Internal.Client" "karps-0.2.0.0-Ergj4tYxtT33lacYzPfeHg" False) (C1 (MetaCons "RDDInfo" PrefixI True) ((::) ((::) (S1 (MetaSel (Just Symbol "rddiId") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 RDDId)) (S1 (MetaSel (Just Symbol "rddiClassName") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text))) ((:*:) (S1 (MetaSel (Just Symbol "rddiRepr") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)) (S1 (MetaSel (Just Symbol "rddiParents") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 [RDDId])))))

data SparkComputationItemStats Source #

Constructors

SparkComputationItemStats
Fields scisRddInfo :: ![RDDInfo]

Instances

Show SparkComputationItemStats Source #
Methods showsPrec :: Int -> SparkComputationItemStats -> ShowS # show :: SparkComputationItemStats -> String # showList :: [SparkComputationItemStats] -> ShowS #
Generic SparkComputationItemStats Source #
Associated Types type Rep SparkComputationItemStats :: * -> * # Methods from :: SparkComputationItemStats -> Rep SparkComputationItemStats x # to :: Rep SparkComputationItemStats x -> SparkComputationItemStats #
FromJSON SparkComputationItemStats Source #
Methods parseJSON :: Value -> Parser SparkComputationItemStats #
type Rep SparkComputationItemStats Source #
type Rep SparkComputationItemStats = D1 (MetaData "SparkComputationItemStats" "Spark.Core.Internal.Client" "karps-0.2.0.0-Ergj4tYxtT33lacYzPfeHg" False) (C1 (MetaCons "SparkComputationItemStats" PrefixI True) (S1 (MetaSel (Just Symbol "scisRddInfo") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 [RDDInfo])))

data PossibleNodeStatus Source #

Constructors

NodeQueued
NodeRunning
NodeFinishedSuccess !(Maybe NodeComputationSuccess) !(Maybe SparkComputationItemStats)
NodeFinishedFailure NodeComputationFailure

Instances

Show PossibleNodeStatus Source #
Methods showsPrec :: Int -> PossibleNodeStatus -> ShowS # show :: PossibleNodeStatus -> String # showList :: [PossibleNodeStatus] -> ShowS #
Generic PossibleNodeStatus Source #
Associated Types type Rep PossibleNodeStatus :: * -> * # Methods from :: PossibleNodeStatus -> Rep PossibleNodeStatus x # to :: Rep PossibleNodeStatus x -> PossibleNodeStatus #
FromJSON PossibleNodeStatus Source #
Methods parseJSON :: Value -> Parser PossibleNodeStatus #
type Rep PossibleNodeStatus Source #
type Rep PossibleNodeStatus = D1 (MetaData "PossibleNodeStatus" "Spark.Core.Internal.Client" "karps-0.2.0.0-Ergj4tYxtT33lacYzPfeHg" False) ((:+:) ((:+:) (C1 (MetaCons "NodeQueued" PrefixI False) U1) (C1 (MetaCons "NodeRunning" PrefixI False) U1)) ((:+:) (C1 (MetaCons "NodeFinishedSuccess" PrefixI False) ((:*:) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe NodeComputationSuccess))) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 (Maybe SparkComputationItemStats))))) (C1 (MetaCons "NodeFinishedFailure" PrefixI False) (S1 (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 NodeComputationFailure)))))

data NodeComputationSuccess Source #

Constructors

NodeComputationSuccess
Fields ncsData :: Value ncsDataType :: DataType

Instances

Show NodeComputationSuccess Source #
Methods showsPrec :: Int -> NodeComputationSuccess -> ShowS # show :: NodeComputationSuccess -> String # showList :: [NodeComputationSuccess] -> ShowS #
Generic NodeComputationSuccess Source #
Associated Types type Rep NodeComputationSuccess :: * -> * # Methods from :: NodeComputationSuccess -> Rep NodeComputationSuccess x # to :: Rep NodeComputationSuccess x -> NodeComputationSuccess #
FromJSON NodeComputationSuccess Source #
Methods parseJSON :: Value -> Parser NodeComputationSuccess #
type Rep NodeComputationSuccess Source #
type Rep NodeComputationSuccess = D1 (MetaData "NodeComputationSuccess" "Spark.Core.Internal.Client" "karps-0.2.0.0-Ergj4tYxtT33lacYzPfeHg" False) (C1 (MetaCons "NodeComputationSuccess" PrefixI True) ((:*:) (S1 (MetaSel (Just Symbol "ncsData") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Value)) (S1 (MetaSel (Just Symbol "ncsDataType") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 DataType))))

data NodeComputationFailure Source #

Constructors

NodeComputationFailure
Fields ncfMessage :: !Text

Instances

Show NodeComputationFailure Source #
Methods showsPrec :: Int -> NodeComputationFailure -> ShowS # show :: NodeComputationFailure -> String # showList :: [NodeComputationFailure] -> ShowS #
Generic NodeComputationFailure Source #
Associated Types type Rep NodeComputationFailure :: * -> * # Methods from :: NodeComputationFailure -> Rep NodeComputationFailure x # to :: Rep NodeComputationFailure x -> NodeComputationFailure #
type Rep NodeComputationFailure Source #
type Rep NodeComputationFailure = D1 (MetaData "NodeComputationFailure" "Spark.Core.Internal.Client" "karps-0.2.0.0-Ergj4tYxtT33lacYzPfeHg" False) (C1 (MetaCons "NodeComputationFailure" PrefixI True) (S1 (MetaSel (Just Symbol "ncfMessage") NoSourceUnpackedness SourceStrict DecidedStrict) (Rec0 Text)))

Documentation

AESON INSTANCES ***