Method build_enriched_samples

xtop/sql/fragment_manager.py:91–118

Build enriched_samples CTE Args: use_materialized: Whether to use materialized tables datadir: Data directory path Returns: Enriched samples CTE

(self, 
                              use_materialized: bool = False,
                              datadir: str = "out")

        return "WITH " + ",\n".join(cte_parts)
    
    def build_enriched_samples(self, 
                              use_materialized: bool = False,
                              datadir: str = "out") -> str:
        """Build enriched_samples CTE
        
        Args:
            use_materialized: Whether to use materialized tables
            datadir: Data directory path
            
        Returns:
            Enriched samples CTE
        """
        # Get base samples source
        if use_materialized:
            samples_source = "SELECT * FROM xcapture_samples"
        else:
            samples_source = self.get_fragment("base_samples").replace("{datadir}", datadir)
        
        # Get computed columns
        computed_cols = self.get_fragment("computed_columns")
        
        # Combine
        return f"""enriched_samples AS (
    SELECT
        samples.*,
        {computed_cols}
    FROM ({samples_source}) AS samples
)"""
    
    def build_join_clause(self, required_joins: List[str], base_alias: str = "bs") -> str:
        """Build JOIN clauses for required data sources