| Safe Haskell | None |
|---|---|
| Language | GHC2021 |
Napkin.Spec.ExecutionPlan
Synopsis
- data IntrmTblUpdSt
- type IntrmTblsUpdSt = Map SpecTableName IntrmTblUpdSt
- type ForcedTablesMap = Map SpecTableName ForceTable
- type ForcedTaskIdMap = Map TaskId ForceTable
- type TableExecutionReasonMap = Map SpecTableName (Bool, ExecutionReason)
- onlyResolved :: IntrmTblUpdSt -> Maybe (Bool, ExecutionReason)
- applyUpdateStrategies :: MonadIO m => UTCTime -> (SpecTableName -> m Bool) -> History -> RawInterpretedSpec b -> TasksDAG Full b -> m (TasksDAG Table b)
- tablesForUpdate :: 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 Methods showsPrec :: Int -> IntrmTblUpdSt -> ShowS # show :: IntrmTblUpdSt -> String # showList :: [IntrmTblUpdSt] -> ShowS # | |
| Eq IntrmTblUpdSt # | |
Defined in Napkin.Spec.ExecutionPlan Methods (==) :: IntrmTblUpdSt -> IntrmTblUpdSt -> Bool # (/=) :: IntrmTblUpdSt -> IntrmTblUpdSt -> Bool # | |
type IntrmTblsUpdSt = Map SpecTableName IntrmTblUpdSt #
type ForcedTablesMap = Map SpecTableName ForceTable #
type ForcedTaskIdMap = Map TaskId ForceTable #
type TableExecutionReasonMap = Map SpecTableName (Bool, ExecutionReason) #
onlyResolved :: IntrmTblUpdSt -> Maybe (Bool, ExecutionReason) #
applyUpdateStrategies :: MonadIO m => UTCTime -> (SpecTableName -> m Bool) -> History -> RawInterpretedSpec b -> TasksDAG Full b -> m (TasksDAG Table b) #
Evaluates update strategies, TODO: parallelize
tablesForUpdate :: 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