| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
DataFrame.Lazy.Internal.PhysicalPlan
Synopsis
- data ScanConfig = ScanConfig {
- scanBatchSize :: !Int
- scanSeparator :: !Char
- scanSchema :: !Schema
- scanPushdownPredicate :: !(Maybe (Expr Bool))
- data PhysicalPlan
- = PhysicalScan DataSource ScanConfig
- | PhysicalProject [Text] PhysicalPlan
- | PhysicalFilter (Expr Bool) PhysicalPlan
- | PhysicalDerive Text UExpr PhysicalPlan
- | PhysicalHashJoin JoinType Text Text PhysicalPlan PhysicalPlan
- | PhysicalSortMergeJoin JoinType Text Text PhysicalPlan PhysicalPlan
- | PhysicalHashAggregate [Text] [(Text, UExpr)] PhysicalPlan
- | PhysicalSort [(Text, SortOrder)] PhysicalPlan
- | PhysicalLimit Int PhysicalPlan
- | PhysicalSpill PhysicalPlan FilePath
- | PhysicalSourceDF DataFrame
Documentation
data ScanConfig Source #
Scan-level configuration: batch size, separator, optional pushdowns.
Constructors
| ScanConfig | |
Fields
| |
Instances
| Show ScanConfig Source # | |
Defined in DataFrame.Lazy.Internal.PhysicalPlan Methods showsPrec :: Int -> ScanConfig -> ShowS # show :: ScanConfig -> String # showList :: [ScanConfig] -> ShowS # | |
data PhysicalPlan Source #
Physical plan: every node carries enough information for the executor to allocate resources and choose algorithms without further analysis.
Constructors
| PhysicalScan DataSource ScanConfig | |
| PhysicalProject [Text] PhysicalPlan | |
| PhysicalFilter (Expr Bool) PhysicalPlan | |
| PhysicalDerive Text UExpr PhysicalPlan | |
| PhysicalHashJoin JoinType Text Text PhysicalPlan PhysicalPlan | |
| PhysicalSortMergeJoin JoinType Text Text PhysicalPlan PhysicalPlan | |
| PhysicalHashAggregate [Text] [(Text, UExpr)] PhysicalPlan | |
| PhysicalSort [(Text, SortOrder)] PhysicalPlan | |
| PhysicalLimit Int PhysicalPlan | |
| PhysicalSpill PhysicalPlan FilePath | Materialize child to a binary file on disk (used for build sides). |
| PhysicalSourceDF DataFrame | Emit an already-loaded DataFrame as a stream of batches. |
Instances
| Show PhysicalPlan Source # | |
Defined in DataFrame.Lazy.Internal.PhysicalPlan Methods showsPrec :: Int -> PhysicalPlan -> ShowS # show :: PhysicalPlan -> String # showList :: [PhysicalPlan] -> ShowS # | |