Safe Haskell | Safe-Inferred |
---|---|
Language | GHC2021 |
Synopsis
- data IntrmTblUpdSt
- type IntrmTblsUpdSt = Map SpecTableName IntrmTblUpdSt
- data ForceTable
- type ForcedTablesMap = Map SpecTableName ForceTable
- data ExecutionReason
- type TableExecutionReasonMap = Map SpecTableName (Bool, ExecutionReason)
- onlyResolved :: IntrmTblUpdSt -> Maybe (Bool, ExecutionReason)
- tablesForUpdate :: forall m b. MonadIO m => UTCTime -> (SpecTableName -> m Bool) -> History -> ForcedTablesMap -> ValidatedInterpretedSpec b -> m (Set SpecTableName, TableExecutionReasonMap)
Documentation
data IntrmTblUpdSt #
Instances
Show IntrmTblUpdSt # | |
Defined in Napkin.Spec.ExecutionPlan showsPrec :: Int -> IntrmTblUpdSt -> ShowS # show :: IntrmTblUpdSt -> String # showList :: [IntrmTblUpdSt] -> ShowS # | |
Eq IntrmTblUpdSt # | |
Defined in Napkin.Spec.ExecutionPlan (==) :: IntrmTblUpdSt -> IntrmTblUpdSt -> Bool # (/=) :: IntrmTblUpdSt -> IntrmTblUpdSt -> Bool # |
type IntrmTblsUpdSt = Map SpecTableName IntrmTblUpdSt #
data ForceTable #
Instances
Show ForceTable # | |
Defined in Napkin.Spec.ExecutionPlan showsPrec :: Int -> ForceTable -> ShowS # show :: ForceTable -> String # showList :: [ForceTable] -> ShowS # | |
Eq ForceTable # | |
Defined in Napkin.Spec.ExecutionPlan (==) :: ForceTable -> ForceTable -> Bool # (/=) :: ForceTable -> ForceTable -> Bool # |
type ForcedTablesMap = Map SpecTableName ForceTable #
data ExecutionReason #
Instances
Show ExecutionReason # | |
Defined in Napkin.Spec.ExecutionPlan showsPrec :: Int -> ExecutionReason -> ShowS # show :: ExecutionReason -> String # showList :: [ExecutionReason] -> ShowS # | |
Eq ExecutionReason # | |
Defined in Napkin.Spec.ExecutionPlan (==) :: ExecutionReason -> ExecutionReason -> Bool # (/=) :: ExecutionReason -> ExecutionReason -> Bool # |
type TableExecutionReasonMap = Map SpecTableName (Bool, ExecutionReason) #
onlyResolved :: IntrmTblUpdSt -> Maybe (Bool, ExecutionReason) #
tablesForUpdate :: forall m b. MonadIO m => UTCTime -> (SpecTableName -> m Bool) -> History -> ForcedTablesMap -> ValidatedInterpretedSpec b -> m (Set SpecTableName, TableExecutionReasonMap) #
tablesForUpdate
discovers missing spec tables or containing old data, or those who's dependencies have changed,
if the table has the appropriate update strategy.
TODO: parallelize