本文整理了Java中org.apache.lens.server.api.query.QueryContext.getHDFSResultDir
方法的一些代码示例,展示了QueryContext.getHDFSResultDir
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryContext.getHDFSResultDir
方法的具体详情如下:
包路径:org.apache.lens.server.api.query.QueryContext
类名称:QueryContext
方法名:getHDFSResultDir
暂无
代码示例来源:origin: org.apache.lens/lens-driver-hive
Path resultSetPath = context.getHDFSResultDir();
代码示例来源:origin: apache/lens
Path resultSetPath = context.getHDFSResultDir();
代码示例来源:origin: apache/lens
context = createContext(select, queryConf);
resultSet = driver.execute(context);
validatePersistentResult(resultSet, TEST_DATA_FILE, context.getHDFSResultDir(), false);
queryConf.set(LensConfConstants.QUERY_OUTPUT_DIRECTORY_FORMAT,
"ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'"
context = createContext(select, queryConf);
resultSet = driver.execute(context);
validatePersistentResult(resultSet, TEST_DATA_FILE, context.getHDFSResultDir(), true);
assertHandleSize(handleSize);
代码示例来源:origin: apache/lens
/**
* Validate execute async.
*
* @param ctx the ctx
* @param finalState the final state
* @param isPersistent the is persistent
* @param formatNulls the format nulls
* @param driver the driver
* @throws Exception the exception
*/
protected void validateExecuteAsync(QueryContext ctx, DriverQueryState finalState, boolean isPersistent,
boolean formatNulls, HiveDriver driver) throws Exception {
waitForAsyncQuery(ctx, driver);
driver.updateStatus(ctx);
assertEquals(ctx.getDriverStatus().getState(), finalState, "Expected query to finish with" + finalState);
assertTrue(ctx.getDriverStatus().getDriverFinishTime() > 0);
if (finalState.equals(DriverQueryState.SUCCESSFUL)) {
System.out.println("Progress:" + ctx.getDriverStatus().getProgressMessage());
assertNotNull(ctx.getDriverStatus().getProgressMessage());
if (!isPersistent) {
validateInMemoryResult(driver.fetchResultSet(ctx));
} else {
validatePersistentResult(driver.fetchResultSet(ctx), TEST_DATA_FILE, ctx.getHDFSResultDir(), formatNulls);
}
} else if (finalState.equals(DriverQueryState.FAILED)) {
System.out.println("Error:" + ctx.getDriverStatus().getErrorMessage());
System.out.println("Status:" + ctx.getDriverStatus().getStatusMessage());
assertNotNull(ctx.getDriverStatus().getErrorMessage());
}
}
代码示例来源:origin: apache/lens
QueryContext ctx = createContext("SELECT ID FROM test_persistent_result_set", queryConf);
LensResultSet resultSet = driver.execute(ctx);
validatePersistentResult(resultSet, TEST_DATA_FILE, ctx.getHDFSResultDir(), false);
assertHandleSize(handleSize);
resultSet = driver.execute(ctx);
assertHandleSize(handleSize);
validatePersistentResult(resultSet, TEST_DATA_FILE, ctx.getHDFSResultDir(), true);
driver.closeQuery(ctx.getQueryHandle());
assertHandleSize(handleSize);
内容来源于网络,如有侵权,请联系作者删除!