fs = FileSystem.get(conf);
DataSchemaLoader.initialize(true, fs);
QuerySchemaLoader.initialize(true, fs);
query = new HadoopFileSystemStore(fs).recall(queryInputDir, Query.class);
queryInfo = query.getQueryInfo();
<BUG>if (SystemConfiguration.getProperty("pir.allowAdHocQuerySchemas", "false").equals("true"))
</BUG>
{
qSchema = queryInfo.getQuerySchema();
}

fs = FileSystem.get(conf);
DataSchemaLoader.initialize(true, fs);
QuerySchemaLoader.initialize(true, fs);
query = new HadoopFileSystemStore(fs).recall(queryInputDir, Query.class);
queryInfo = query.getQueryInfo();
if (SystemConfiguration.getBooleanProperty("pir.allowAdHocQuerySchemas", false))
{
qSchema = queryInfo.getQuerySchema();
}
