Package org.apache.hive.service.cli

Examples of org.apache.hive.service.cli.HiveSQLException

337
338
339
340
341
342
343
344
345
346
347
348
349
350
      if (driver.getResults(convey)) {
        return decode(convey, rowSet);
      }
      return rowSet;
    } catch (IOException e) {
      throw new HiveSQLException(e);
    } catch (CommandNeedRetryException e) {
      throw new HiveSQLException(e);
    } catch (Exception e) {
      throw new HiveSQLException(e);
    } finally {
      convey.clear();
    }
  }
View Full Code Here
452
453
454
455
456
457
458
459
460
461
462
      // apply overlay query specific settings, if any
      for (Map.Entry<String, String> confEntry : getConfOverlay().entrySet()) {
        try {
          sqlOperationConf.verifyAndSet(confEntry.getKey(), confEntry.getValue());
        } catch (IllegalArgumentException e) {
          throw new HiveSQLException("Error applying statement specific settings", e);
        }
      }
    }
    return sqlOperationConf;
  }
View Full Code Here
168
169
170
171
172
173
174
175
176
        }
      }
      setState(OperationState.FINISHED);
    } catch (Exception e) {
      setState(OperationState.ERROR);
      throw new HiveSQLException(e);
    }

  }
View Full Code Here
107
108
109
110
111
112
113
114
        rowSet.addRow(rowData);
      }
      setState(OperationState.FINISHED);
    } catch (Exception e) {
      setState(OperationState.ERROR);
      throw new HiveSQLException(e);
    }
  }
View Full Code Here
174
175
176
177
178
179
180
181
182
  }

  public Operation getOperation(OperationHandle operationHandle) throws HiveSQLException {
    Operation operation = getOperationInternal(operationHandle);
    if (operation == null) {
      throw new HiveSQLException("Invalid OperationHandle: " + operationHandle);
    }
    return operation;
  }
View Full Code Here
47
48
49
50
51
52
53
54
    this.cliService = cliService;
  }

  public void checkStatus(TStatus status) throws HiveSQLException {
    if (TStatusCode.ERROR_STATUS.equals(status.getStatusCode())) {
      throw new HiveSQLException(status);
    }
  }
View Full Code Here
69
70
71
72
73
74
75
76
      checkStatus(resp.getStatus());
      return new SessionHandle(resp.getSessionHandle(), resp.getServerProtocolVersion());
    } catch (HiveSQLException e) {
      throw e;
    } catch (Exception e) {
      throw new HiveSQLException(e);
    }
  }
View Full Code Here
79
80
81
82
83
84
85
   * @see org.apache.hive.service.cli.ICLIService#closeSession(org.apache.hive.service.cli.SessionHandle)
   */
  @Override
  public SessionHandle openSessionWithImpersonation(String username, String password,
      Map<String, String> configuration, String delegationToken) throws HiveSQLException {
    throw new HiveSQLException("open with impersonation operation is not supported in the client");
  }
View Full Code Here
94
95
96
97
98
99
100
101
      TCloseSessionResp resp = cliService.CloseSession(req);
      checkStatus(resp.getStatus());
    } catch (HiveSQLException e) {
      throw e;
    } catch (Exception e) {
      throw new HiveSQLException(e);
    }
  }
View Full Code Here
113
114
115
116
117
118
119
120
      checkStatus(resp.getStatus());
      return new GetInfoValue(resp.getInfoValue());
    } catch (HiveSQLException e) {
      throw e;
    } catch (Exception e) {
      throw new HiveSQLException(e);
    }
  }
View Full Code Here
TOP

Related Classes of org.apache.hive.service.cli.HiveSQLException

  • org.apache.hive.jdbc.Utils
  • org.apache.hive.service.auth.HiveAuthFactory
  • org.apache.hive.service.cli.operation.ExecuteStatementOperation
  • org.apache.hive.service.cli.operation.GetColumnsOperation
  • org.apache.hive.service.cli.operation.GetFunctionsOperation
  • org.apache.hive.service.cli.operation.GetSchemasOperation
  • org.apache.hive.service.cli.operation.GetTablesOperation
  • org.apache.hive.service.cli.operation.GetTableTypesOperation
  • org.apache.hive.service.cli.operation.GetTypeInfoOperation
  • org.apache.hive.service.cli.operation.HiveCommandOperation
    • 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.