Interface Prophet<K,​V>

  • Type Parameters:
    K - key type of the optimized value
    V - type of optimized value
    All Known Implementing Classes:
    ParallelismProphet, SkewProphet

    public interface Prophet<K,​V>
    A prophet class for dynamic optimization. It calculates the statistics the runtime pass needs by (including, but not limited to) parsing the messages accumulated by the RuntimeMessageOutputCollector, and feeds the information to the runtime pass in NemoPlanRewriter.
    • Method Detail

      • calculate

        java.util.Map<K,​V> calculate()
        Calculate the optimized values based on runtime messages.
        Returns:
        A map containing the optimized values.