class FlinkPipeline extends AbstractPipeline implements Compilable {

    public FlinkPipeline(QueryProcedure plan, SqlRunner.Builder builder) {
        super(plan, builder);
        wrapper = new FlinkBodyWrapper();
        wrapper.interpretProcedure(procedure);
        wrapper.importSpecificDependency();
    }

    public  FlinkPipeline(QueryProcedure plan, SqlRunner.Builder builder);

}