Le paramètre doESP=TRUE (Event Stream Processing) permet à l'action d'optimiser les calculs en utilisant le partitionnement et l'ordonnancement existants de votre table d'entrée. Pour que cela fonctionne efficacement, la variable id doit être spécifiée comme le dernier paramètre groupBy et également dans le paramètre orderBy. Cette optimisation est cruciale pour les grands ensembles de données et les analyses en temps quasi réel.
Comment puis-je optimiser les performances de l'action 'aggregate' en tirant parti du partitionnement et de l'ordonnancement des données?
Cette réponse vous a-t-elle aidé ?
Exemples pour l'action aggregate
Agrégation globale des ventes
Un exemple de base qui calcule la somme totale et la moyenne des ventes sur l'ensemble de la table, en utilisant varSpecs.
Agrégation temporelle par mois
Exploitation avancée : agrégation des ventes par mois à l'aide des paramètres 'id' et 'interval'. Remarquez l'utilisation indispensable de groupBy sur la variable temporelle pour que le découpage mensuel fonctionne !