@Test public void testCompressionAndEncoding() throws IOException { Configuration conf = new Configuration(); conf.set(LensConfConstants.QUERY_OUTPUT_CHARSET_ENCODING, "UTF-16LE"); conf.setBoolean(LensConfConstants.QUERY_OUTPUT_ENABLE_COMPRESSION, true); setConf(conf); testFormatter(conf, "UnicodeLittleUnmarked", LensConfConstants.RESULT_SET_PARENT_DIR_DEFAULT, ".csv.gz", getMockedResultSet()); Assert.assertEquals(readCompressedFile(new Path(formatter.getFinalOutputPath()), conf, "UTF-16LE"), getExpectedCSVRows()); }
public String getFinalOutputPath() { return finalPath.toString(); }
AbstractFileFormatter extends AbstractOutputFormatter implements FileFormatter { public String getFinalOutputPath() { return finalPath.toString(); } }
AbstractFileFormatter extends AbstractOutputFormatter implements FileFormatter { public String getFinalOutputPath() { return finalPath.toString(); }  }
AbstractFileFormatter extends AbstractOutputFormatter implements FileFormatter { public String getFinalOutputPath() { return finalPath.toString(); }  @Override void init(QueryContext ctx, LensResultSetMetadata metadata); @Override Integer getNumRows(); @Override Long getFileSize(); @Override void writeHeader(); @Override void writeFooter(); String getFinalOutputPath(); @Override void writeExternal(ObjectOutput out); @Override void readExternal(ObjectInput in); }
AbstractFileFormatter extends AbstractOutputFormatter implements FileFormatter { public String getFinalOutputPath() { return finalPath.toString(); }  @Override void init(QueryContext ctx, LensResultSetMetadata metadata); @Override Integer getNumRows(); @Override Long getFileSize(); @Override void writeHeader(); @Override void writeFooter(); String getFinalOutputPath(); @Override void writeExternal(ObjectOutput out); @Override void readExternal(ObjectInput in);  }