frontend.h

Go to the documentation of this file.

// Copyright 2012 Cloudera Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

#ifndef IMPALA_SERVICE_FRONTEND_H
#define IMPALA_SERVICE_FRONTEND_H

#include <jni.h>

#include "gen-cpp/ImpalaService.h"
#include "gen-cpp/ImpalaHiveServer2Service.h"
#include "gen-cpp/ImpalaInternalService.h"
#include "gen-cpp/Frontend_types.h"
#include "common/status.h"

namespace impala {

class Frontend {
 public:
  Frontend();

  Status UpdateCatalogCache(const TUpdateCatalogCacheRequest& req,
      TUpdateCatalogCacheResponse *resp);

  Status GetExplainPlan(const TQueryCtx& query_ctx, std::string* explain_string);

  Status GetExecRequest(const TQueryCtx& query_ctx, TExecRequest* result);

  Status GetTableNames(const std::string& db, const std::string* pattern,
      const TSessionState* session, TGetTablesResult* table_names);

  Status GetDbNames(const std::string* pattern, const TSessionState* session,
      TGetDbsResult* table_names);

  Status GetDataSrcMetadata(const std::string* pattern, TGetDataSrcsResult* result);

  Status GetStats(const TShowStatsParams& params, TResultSet* result);

  Status GetRolePrivileges(const TShowGrantRoleParams& params, TResultSet* result);

  Status GetFunctions(TFunctionCategory::type fn_category, const std::string& db,
      const std::string* pattern, const TSessionState* session,
      TGetFunctionsResult* functions);

  Status GetCatalogObject(const TCatalogObject& request, TCatalogObject* response);

  Status ShowRoles(const TShowRolesParams& params, TShowRolesResult* result);

  Status DescribeTable(const TDescribeTableParams& params,
      TDescribeTableResult* response);

  Status ShowCreateTable(const TTableName& table_name, std::string* response);

  Status ValidateSettings();

  Status ExecHiveServer2MetadataOp(const TMetadataOpRequest& request,
      TResultSet* result);

  Status GetAllHadoopConfigs(TGetAllHadoopConfigsResponse* result);

  Status GetHadoopConfig(const TGetHadoopConfigRequest& request,
      TGetHadoopConfigResponse* response);

  Status LoadData(const TLoadDataReq& load_data_request, TLoadDataResp* response);

  static bool IsAuthorizationError(const Status& status);

  Status SetCatalogInitialized();

  Status GetTableFiles(const TShowFilesParams& params, TResultSet* result);

 private:
  jclass fe_class_;

  jobject fe_;  // instance of com.cloudera.impala.service.JniFrontend
  jmethodID create_exec_request_id_;  // JniFrontend.createExecRequest()
  jmethodID get_explain_plan_id_;  // JniFrontend.getExplainPlan()
  jmethodID get_hadoop_config_id_;  // JniFrontend.getHadoopConfig(byte[])
  jmethodID get_hadoop_configs_id_;  // JniFrontend.getAllHadoopConfigs()
  jmethodID check_config_id_; // JniFrontend.checkConfiguration()
  jmethodID update_catalog_cache_id_; // JniFrontend.updateCatalogCache()
  jmethodID get_table_names_id_; // JniFrontend.getTableNames
  jmethodID describe_table_id_; // JniFrontend.describeTable
  jmethodID show_create_table_id_; // JniFrontend.showCreateTable
  jmethodID get_db_names_id_; // JniFrontend.getDbNames
  jmethodID get_data_src_metadata_id_; // JniFrontend.getDataSrcMetadata
  jmethodID get_stats_id_; // JniFrontend.getTableStats
  jmethodID get_functions_id_; // JniFrontend.getFunctions
  jmethodID get_catalog_object_id_; // JniFrontend.getCatalogObject
  jmethodID show_roles_id_; // JniFrontend.getRoles
  jmethodID get_role_privileges_id_; // JniFrontend.getRolePrivileges
  jmethodID exec_hs2_metadata_op_id_; // JniFrontend.execHiveServer2MetadataOp
  jmethodID load_table_data_id_; // JniFrontend.loadTableData
  jmethodID set_catalog_initialized_id_; // JniFrontend.setCatalogInitialized
  jmethodID get_table_files_id_; // JniFrontend.getTableFiles
  jmethodID fe_ctor_;
};

}

#endif