Class StreamingPolicy

  • All Implemented Interfaces:
    java.io.Serializable, Policy

    public final class StreamingPolicy
    extends java.lang.Object
    implements Policy
    Streaming policy.
    See Also:
    Serialized Form
    • Constructor Detail

      • StreamingPolicy

        public StreamingPolicy()
        Default constructor.
    • Method Detail

      • runCompileTimeOptimization

        public IRDAG runCompileTimeOptimization​(IRDAG dag,
                                                java.lang.String dagDirectory)
        Description copied from interface: Policy
        Optimize the DAG with the compile-time optimizations.
        Specified by:
        runCompileTimeOptimization in interface Policy
        Parameters:
        dag - input DAG.
        dagDirectory - directory to save the DAG information.
        Returns:
        optimized DAG, reshaped or tagged with execution properties.
      • runRunTimeOptimizations

        public IRDAG runRunTimeOptimizations​(IRDAG dag,
                                             Message<?> message)
        Description copied from interface: Policy
        Optimize the DAG with the run-time optimizations.
        Specified by:
        runRunTimeOptimizations in interface Policy
        Parameters:
        dag - input DAG.
        message - from the DAG execution.
        Returns:
        optimized DAG, reshaped or tagged with execution properties.