• 大小: 43.96MB
    文件类型: .zip
    金币: 1
    下载: 0 次
    发布日期: 2023-11-24
  • 语言: 其他
  • 标签: hive  

资源简介

hive源码,可以学习hive源码,对于源码有兴趣同学可以下载

资源截图

代码片段和文件信息

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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.
 */
package org.apache.hadoop.hive.accumulo;

import java.io.File;
import java.io.IOException;

import org.apache.accumulo.core.client.AccumuloException;
import org.apache.accumulo.core.client.AccumuloSecurityException;
import org.apache.accumulo.core.client.ClientConfiguration;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.Instance;
import org.apache.accumulo.core.client.ZooKeeperInstance;
import org.apache.accumulo.core.client.mock.MockInstance;
import org.apache.accumulo.core.client.security.tokens.AuthenticationToken;
import org.apache.accumulo.core.client.security.tokens.KerberosToken;
import org.apache.accumulo.core.client.security.tokens.PasswordToken;
import org.apache.hadoop.conf.Configuration;

import com.google.common.base.Preconditions;

/**
 *
 */
public class AccumuloConnectionParameters {
  public static final String USER_NAME = “accumulo.user.name“;
  public static final String USER_PASS = “accumulo.user.pass“;
  public static final String ZOOKEEPERS = “accumulo.zookeepers“;
  public static final String INSTANCE_NAME = “accumulo.instance.name“;
  public static final String TABLE_NAME = “accumulo.table.name“;

  // SASL/Kerberos properties
  public static final String SASL_ENABLED = “accumulo.sasl.enabled“;
  public static final String USER_KEYTAB = “accumulo.user.keytab“;

  public static final String USE_MOCK_INSTANCE = “accumulo.mock.instance“;

  protected Configuration conf;
  protected boolean useMockInstance = false;

  public AccumuloConnectionParameters(Configuration conf) {
    // TableDesc#getDeserializer will ultimately instantiate the AccumuloSerDe with a null
    // Configuration
    // We have to accept this and just fail late if data is attempted to be pulled from the
    // Configuration
    this.conf = conf;
  }

  public Configuration getConf() {
    return conf;
  }

  public String getAccumuloUserName() {
    Preconditions.checkNotNull(conf);
    return conf.get(USER_NAME);
  }

  public String getAccumuloPassword() {
    Preconditions.checkNotNull(conf);
    return conf.get(USER_PASS);
  }

  public String getAccumuloInstanceName() {
    Preconditions.checkNotNull(conf);
    return con

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2019-02-08 20:28  hive-master\
     文件         506  2019-02-08 20:28  hive-master\.arcconfig
     文件        1327  2019-02-08 20:28  hive-master\.checkstyle
     文件         529  2019-02-08 20:28  hive-master\.gitattributes
     文件         684  2019-02-08 20:28  hive-master\.gitignore
     文件        1304  2019-02-08 20:28  hive-master\.reviewboardrc
     文件        1628  2019-02-08 20:28  hive-master\.travis.yml
     文件       20798  2019-02-08 20:28  hive-master\LICENSE
     文件         230  2019-02-08 20:28  hive-master\NOTICE
     文件        4389  2019-02-08 20:28  hive-master\README.md
     文件      167884  2019-02-08 20:28  hive-master\RELEASE_NOTES.txt
     目录           0  2019-02-08 20:28  hive-master\accumulo-handler\
     文件        5600  2019-02-08 20:28  hive-master\accumulo-handler\pom.xml
     目录           0  2019-02-08 20:28  hive-master\accumulo-handler\src\
     目录           0  2019-02-08 20:28  hive-master\accumulo-handler\src\java\
     目录           0  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\
     目录           0  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\
     目录           0  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\
     目录           0  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\
     目录           0  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\
     文件        6615  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\AccumuloConnectionParameters.java
     文件        7914  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\AccumuloDefaultIndexScanner.java
     文件        1745  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\AccumuloHiveConstants.java
     文件        6561  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\AccumuloHiveRow.java
     文件        4362  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\AccumuloIndexLexicoder.java
     文件        1780  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\AccumuloIndexScanner.java
     文件        1263  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\AccumuloIndexScannerException.java
     文件       17771  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\AccumuloStorageHandler.java
     文件       15645  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\HiveAccumuloHelper.java
     文件        5243  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\LazyAccumuloMap.java
     文件        5832  2019-02-08 20:28  hive-master\accumulo-handler\src\java\org\apache\hadoop\hive\accumulo\LazyAccumuloRow.java
............此处省略20043个文件信息

评论

共有 条评论