Package com.inadco.hbl.compiler

Examples of com.inadco.hbl.compiler.Pig8CubeIncrementalCompilerBean


            Path inputPath = new Path(dfs.getWorkingDirectory(), "sample1-input" + System.currentTimeMillis());

            simulateInput(dfs, inputPath);

            // run compiler for the model
            Pig8CubeIncrementalCompilerBean compiler =
                new Pig8CubeIncrementalCompilerBean(
                    getConf(),
                    cubeName,
                    new ClassPathResource("example1-preambula.pig"),
                    5);
            /*
             * test fact compile time exclusion to allow merging different fact
             * stream sources
             */

            compiler.setMeasureExclude(new HashSet<String>(Arrays.asList("excludedMeasure")));

            // or:
            // compiler.setMeasureInclude(new
            // HashSet<String>(Arrays.asList("impCnt", "click")));

            /*
             * this is the version that uses model from resource instead of hbl
             * system table.
             */
            // new Pig8CubeIncrementalCompilerBean(cubeModelRsrc, new
            // ClassPathResource("example1-preambula.pig"), 5);

            String script = compiler.preparePigSource(workPath.toString());

            // ////////////////////////////////////
            // ------------- debug: dump the script
            Path dumpDir = new Path(inputPath, "__debug");
            dfs.mkdirs(dumpDir);
View Full Code Here

TOP

Related Classes of com.inadco.hbl.compiler.Pig8CubeIncrementalCompilerBean

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.