Package org.apache.flink.compiler.plan

Examples of org.apache.flink.compiler.plan.OptimizedPlan

255
256
257
258
259
260
261
262
263
264
   * @return JSON dump of the optimized plan.
   * @throws Exception
   */
  public String getOptimizerPlanAsJSON(Plan plan) throws Exception {
    PactCompiler pc = new PactCompiler(new DataStatistics());
    OptimizedPlan op = pc.compile(plan);
    PlanJSONDumpGenerator gen = new PlanJSONDumpGenerator();
 
    return gen.getOptimizerPlanAsJSON(op);
  }
View Full Code Here
311
312
313
314
315
316
317
318
319
320
321
  public static String optimizerPlanAsJSON(Plan plan) throws Exception {
    LocalExecutor exec = new LocalExecutor();
    try {
      exec.start();
      PactCompiler pc = new PactCompiler(new DataStatistics());
      OptimizedPlan op = pc.compile(plan);
      PlanJSONDumpGenerator gen = new PlanJSONDumpGenerator();

      return gen.getOptimizerPlanAsJSON(op);
    } finally {
      exec.stop();
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
    if (p == null) {
      Assert.fail("Error: Cannot obtain Pact plan. Did the thest forget to override either 'getPactPlan()' or 'getJobGraph()' ?");
    }
   
    PactCompiler pc = new PactCompiler(new DataStatistics());
    OptimizedPlan op = pc.compile(p);
   
    if (printPlan) {
      System.out.println(new PlanJSONDumpGenerator().getOptimizerPlanAsJSON(op));
    }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
     
      InetAddress mockAddress = InetAddress.getLocalHost();
      InetSocketAddress mockJmAddress = new InetSocketAddress(mockAddress, 12345);
     
      Client client = new Client(mockJmAddress, new Configuration(), getClass().getClassLoader());
      OptimizedPlan op = client.getOptimizedPlan(prg, -1);
      assertNotNull(op);
     
      PlanJSONDumpGenerator dumper = new PlanJSONDumpGenerator();
      assertNotNull(dumper.getOptimizerPlanAsJSON(op));
     
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
      }

      // create the plan
      String[] options = params.isEmpty() ? new String[0] : (String[]) params.toArray(new String[params.size()]);
      PackagedProgram program;
      OptimizedPlan optPlan;
      Client client;
     
      try {
        if (assemblerClass == null) {
          program = new PackagedProgram(jarFile, options);
View Full Code Here
TOP

Related Classes of org.apache.flink.compiler.plan.OptimizedPlan

  • org.apache.flink.client.LocalExecutor
  • org.apache.flink.client.program.ContextEnvironment
  • org.apache.flink.client.program.ExecutionPlanCreationTest
  • org.apache.flink.client.RemoteExecutor
  • org.apache.flink.client.web.JobSubmissionServlet
  • org.apache.flink.compiler.AdditionalOperatorsTest
  • org.apache.flink.compiler.BranchingPlansCompilerTest
  • org.apache.flink.compiler.BroadcastVariablePipelinebreakerTest
  • org.apache.flink.compiler.CachedMatchStrategyCompilerTest
  • org.apache.flink.compiler.CoGroupSolutionSetFirstTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.