hadoop TimelineHBaseSchemaConstants 源码

2022-10-20
浏览 (216)

haddop TimelineHBaseSchemaConstants 代码

文件路径：/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/common/TimelineHBaseSchemaConstants.java

/**
 * 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.yarn.server.timelineservice.storage.common;

import org.apache.hadoop.classification.InterfaceAudience;
import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.hbase.util.Bytes;

/**
 * contains the constants used in the context of schema accesses for
 * {@link org.apache.hadoop.yarn.api.records.timelineservice.TimelineEntity}
 * information.
 */
@InterfaceAudience.Private
@InterfaceStability.Unstable
public final class TimelineHBaseSchemaConstants {
  private TimelineHBaseSchemaConstants() {
  }

  /**
   * Used to create a pre-split for tables starting with a username in the
   * prefix. TODO: this may have to become a config variable (string with
   * separators) so that different installations can presplit based on their own
   * commonly occurring names.
   */
  private final static byte[][] USERNAME_SPLITS = {
      Bytes.toBytes("a"), Bytes.toBytes("ad"), Bytes.toBytes("an"),
      Bytes.toBytes("b"), Bytes.toBytes("ca"), Bytes.toBytes("cl"),
      Bytes.toBytes("d"), Bytes.toBytes("e"), Bytes.toBytes("f"),
      Bytes.toBytes("g"), Bytes.toBytes("h"), Bytes.toBytes("i"),
      Bytes.toBytes("j"), Bytes.toBytes("k"), Bytes.toBytes("l"),
      Bytes.toBytes("m"), Bytes.toBytes("n"), Bytes.toBytes("o"),
      Bytes.toBytes("q"), Bytes.toBytes("r"), Bytes.toBytes("s"),
      Bytes.toBytes("se"), Bytes.toBytes("t"), Bytes.toBytes("u"),
      Bytes.toBytes("v"), Bytes.toBytes("w"), Bytes.toBytes("x"),
      Bytes.toBytes("y"), Bytes.toBytes("z")
  };

  /**
   * The length at which keys auto-split.
   */
  public static final String USERNAME_SPLIT_KEY_PREFIX_LENGTH = "4";

  /**
   * @return splits for splits where a user is a prefix.
   */
  public static byte[][] getUsernameSplits() {
    byte[][] kloon = USERNAME_SPLITS.clone();
    // Deep copy.
    for (int row = 0; row < USERNAME_SPLITS.length; row++) {
      kloon[row] = Bytes.copy(USERNAME_SPLITS[row]);
    }
    return kloon;
  }

}

相关信息

hadoop 源码目录

相关文章

hadoop BaseTableRW 源码

hadoop ColumnRWHelper 源码

hadoop HBaseTimelineStorageUtils 源码

hadoop TypedBufferedMutator 源码

hadoop package-info 源码

0 赞

所属分类： 大数据
本文标签： 大数据
版权声明： 原创文章如转载，请注明本文链接: https://www.seaxiang.com/blog/7e77d6ebc54642b7b2a06eeb1ef97422

热门推荐

1、直接访问google.com
2、 - 优质文章
3、 gate.io
4、 harmony 鸿蒙hdc使用指导
5、 harmony 鸿蒙ArkUI组件（ArkTS）开发常见问题
6、 harmony 鸿蒙初识ArkTS语言
7、 golang
8、 flink kafka connector scan.startup.mode 的几个选项
9、 openharmony
10、 Vue中input框自动聚焦

Loading...