class FlinkPipeline extends AbstractPipeline implements Compilable {

    @Override
    public PipelineResult asJsonFile(String clusterPath) {
        return null;
    }

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

}