Examples of compile()

Examples of org.apache.phoenix.compile.QueryCompiler.compile()

70
71
72
73
74
75
76
77
78
79
80
        return optimize(statement, select, FromCompiler.getResolverForQuery(select, statement.getConnection()), Collections.<PColumn>emptyList(), null);
    }

    public QueryPlan optimize(PhoenixStatement statement, SelectStatement select, ColumnResolver resolver, List<? extends PDatum> targetColumns, ParallelIteratorFactory parallelIteratorFactory) throws SQLException {
        QueryCompiler compiler = new QueryCompiler(statement, select, resolver, targetColumns, parallelIteratorFactory, new SequenceManager(statement));
        QueryPlan dataPlan = compiler.compile();
        return optimize(dataPlan, statement, targetColumns, parallelIteratorFactory);
    }
   
    public QueryPlan optimize(QueryPlan dataPlan, PhoenixStatement statement, List<? extends PDatum> targetColumns, ParallelIteratorFactory parallelIteratorFactory) throws SQLException {
        SelectStatement select = (SelectStatement)dataPlan.getStatement();
View Full Code Here

Examples of org.apache.phoenix.compile.UpsertCompiler.compile()

437
438
439
440
441
442
443
444
445
446
447
        @SuppressWarnings("unchecked")
        @Override
        public MutationPlan compilePlan(PhoenixStatement stmt, Sequence.ValueOp seqAction) throws SQLException {
            UpsertCompiler compiler = new UpsertCompiler(stmt);
            MutationPlan plan = compiler.compile(this);
            plan.getContext().getSequenceManager().validateSequences(seqAction);
            return plan;
        }
    }
   
View Full Code Here

Examples of org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.compile()

83
84
85
86
87
88
89
90
91
92
93
        return new P2jPlanGenerator(lps.getLP(null));
    }

    private Map<PhysicalOperator, Operator> getP2lMap(LipstickPigServer lps) throws Exception {
        HExecutionEngine he = new HExecutionEngine(lps.getPigContext());
        he.compile(getLogicalPlan(lps), null);

        Map<Operator, PhysicalOperator> l2pMap = he.getLogToPhyMap();
        Map<PhysicalOperator, Operator> p2lMap = Maps.newHashMap();
        for (Entry<Operator, PhysicalOperator> i : l2pMap.entrySet()) {
            p2lMap.put(i.getValue(), i.getKey());
View Full Code Here

Examples of org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler.compile()

446
447
448
449
450
451
452
453
454
455
456
        HExecutionEngine exe = pc.getExecutionEngine();
        ConfigurationValidator.validatePigProperties(exe.getConfiguration());
        Configuration conf = ConfigurationUtil.toConfiguration(exe.getConfiguration());
        JobControlCompiler jcc = new JobControlCompiler(pc, conf);
        try {
          jcc.compile(mrPlan, "Test");
        } catch (JobCreationException jce) {
            assertTrue(jce.getErrorCode() == 1068);
        }
    }
   
View Full Code Here

Examples of org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler.compile()

606
607
608
609
610
611
612
613
614
615
616
        return buildPhysicalPlanFromNewLP(optimizeNewLP(migrateToNewLP(lp)), pc);
    }
   
    public static MROperPlan buildMRPlan(PhysicalPlan pp, PigContext pc) throws Exception{
        MRCompiler comp = new MRCompiler(pp, pc);
        comp.compile();
        return comp.getMRPlan(); 
    }
   
    public static MROperPlan buildMRPlanWithOptimizer(PhysicalPlan pp, PigContext pc) throws Exception {
        MapRedUtil.checkLeafIsStore(pp, pc);
View Full Code Here

Examples of org.apache.pig.backend.hadoop.executionengine.tez.TezLauncher.compile()

33
34
35
36
37
38
39
40
41
42
43
public class TestLoaderStorerShipCacheFilesTez extends TestLoaderStorerShipCacheFiles {

    @Override
    protected void checkPlan(PhysicalPlan pp, String[] expectedFiles, int size, PigContext pigContext) throws Exception {
        TezLauncher launcher = new TezLauncher();
        TezPlanContainer tezPlanContainer = launcher.compile(pp, pigContext);
        assertPlanContains(tezPlanContainer.getRoots().get(0).getTezOperPlan(), expectedFiles, size);
    }

    private void assertPlanContains(TezOperPlan plan, String[] expectedFiles, int size) throws VisitorException {
        TezPOUserFuncVisitor udfVisitor = new TezPOUserFuncVisitor(plan);
View Full Code Here

Examples of org.apache.pig.backend.hadoop.executionengine.tez.plan.TezCompiler.compile()

325
326
327
328
329
330
331
332
333
334
335
    }

    public TezPlanContainer compile(PhysicalPlan php, PigContext pc)
            throws PlanException, IOException, VisitorException {
        TezCompiler comp = new TezCompiler(php, pc);
        comp.compile();
        TezPlanContainer planContainer = comp.getPlanContainer();
        for (Map.Entry<OperatorKey, TezPlanContainerNode> entry : planContainer
                .getKeys().entrySet()) {
            TezOperPlan tezPlan = entry.getValue().getTezOperPlan();
            optimize(tezPlan, pc);
View Full Code Here

Examples of org.apache.pig.impl.util.JavaCompilerHelper.compile()

228
229
230
231
232
233
234
235
236
237
238
    private static void compileCodeString(String className, String generatedCodeString, File codeDir) {
        JavaCompilerHelper compiler = new JavaCompilerHelper();
        String tempDir = codeDir.getAbsolutePath();
        compiler.addToClassPath(tempDir);
        LOG.debug("Compiling SchemaTuple code with classpath: " + compiler.getClassPath());
        compiler.compile(tempDir, new JavaCompilerHelper.JavaSourceFromString(className, generatedCodeString));
        LOG.info("Successfully compiled class: " + className);
    }

    static class CompareToSpecificString extends TypeInFunctionStringOut {
        private int id;
View Full Code Here

Examples of org.apache.regexp.RECompiler.compile()

128
129
130
131
132
133
134
135
136
137
138
                // Output program as a nice, formatted character array
                System.out.print("\n    // Pre-compiled regular expression '" + pattern + "'\n"
                                 + "    private static char[] " + instructions + " = \n    {");

                // Compile program for pattern
                REProgram program = r.compile(pattern);

                // Number of columns in output
                int numColumns = 7;

                // Loop through program
View Full Code Here

Examples of org.apache.shindig.gadgets.rewrite.js.DefaultJsCompiler.compile()

210
211
212
213
214
215
216
217
218
219
220
  @SuppressWarnings("unchecked")
  private DefaultJsCompiler mockDefaultJsCompiler(JsResponse res, Iterable<JsContent> content) {
    DefaultJsCompiler result = createMock(DefaultJsCompiler.class);
    expect(result.getJsContent(isA(JsUri.class), isA(FeatureBundle.class)))
        .andReturn(content).anyTimes();
    expect(result.compile(isA(JsUri.class), isA(Iterable.class), isA(String.class)))
        .andReturn(res).anyTimes();
    replay(result);
    return result;
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.