@Test public void testWrite() throws IOException { Configuration conf = HadoopUtil.getCurrentConfiguration(); conf.set("fs.defaultFS", "file: conf.set("mapreduce.framework.name", "local"); conf.set("mapreduce.application.framework.path", ""); conf.set("fs.file.impl.disable.cache", "true"); final Path outputPath = new Path(getTmpFolderPath(), segmentId); System.out.println(outputPath); Map<Long, HLLCounter> cuboidHLLMap = Maps.newHashMap(); Set<Long> allCuboids = cube.getDescriptor().getAllCuboids(); for (Long cuboid : allCuboids) { cuboidHLLMap.put(cuboid, createMockHLLCounter()); } CubeStatsWriter.writeCuboidStatistics(conf, outputPath, cuboidHLLMap, 100); assertTrue(new File(outputPath.toString(), BatchConstants.CFG_STATISTICS_CUBOID_ESTIMATION_FILENAME).exists()); }
public static void writeCuboidStatistics(Configuration conf, Path outputPath, Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage) throws IOException { writeCuboidStatistics(conf, outputPath, cuboidHLLMap, samplingPercentage, 0, 0, 0); }
CubeStatsWriter { public static void writeCuboidStatistics(Configuration conf, Path outputPath, Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage) throws IOException { writeCuboidStatistics(conf, outputPath, cuboidHLLMap, samplingPercentage, 0, 0, 0); } }
CubeStatsWriter { public static void writeCuboidStatistics(Configuration conf, Path outputPath, Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage) throws IOException { writeCuboidStatistics(conf, outputPath, cuboidHLLMap, samplingPercentage, 0, 0, 0); }  }
CubeStatsWriter { public static void writeCuboidStatistics(Configuration conf, Path outputPath, Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage) throws IOException { writeCuboidStatistics(conf, outputPath, cuboidHLLMap, samplingPercentage, 0, 0, 0); }  static void writeCuboidStatistics(Configuration conf, Path outputPath, //
            Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage); static void writeCuboidStatistics(Configuration conf, Path outputPath, //
            Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage, long sourceRecordCoun); static void writeCuboidStatistics(Configuration conf, Path outputPath, //
            Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage, int mapperNumber, double mapperOverlapRatio,
            long sourceRecordCoun); static void writePartialCuboidStatistics(Configuration conf, Path outputPath, //
            Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage, int mapperNumber, double mapperOverlapRatio,
            int shard); }
CubeStatsWriter { public static void writeCuboidStatistics(Configuration conf, Path outputPath, Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage) throws IOException { writeCuboidStatistics(conf, outputPath, cuboidHLLMap, samplingPercentage, 0, 0, 0); }  static void writeCuboidStatistics(Configuration conf, Path outputPath, //
            Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage); static void writeCuboidStatistics(Configuration conf, Path outputPath, //
            Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage, long sourceRecordCoun); static void writeCuboidStatistics(Configuration conf, Path outputPath, //
            Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage, int mapperNumber, double mapperOverlapRatio,
            long sourceRecordCoun); static void writePartialCuboidStatistics(Configuration conf, Path outputPath, //
            Map<Long, HLLCounter> cuboidHLLMap, int samplingPercentage, int mapperNumber, double mapperOverlapRatio,
            int shard);  }