本文整理了Java中org.apache.hadoop.hbase.util.Bytes.contains()方法的一些代码示例，展示了Bytes.contains()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Bytes.contains()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.util.Bytes
类名称：Bytes
方法名：contains

Bytes.contains介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

public void testContains() {
 byte[] array = Bytes.toBytes("hello world");
 assertTrue(Bytes.contains(array, (byte) 'e'));
 assertTrue(Bytes.contains(array, (byte) 'd'));
 assertFalse( Bytes.contains(array, (byte) 'a'));
 assertTrue(Bytes.contains(array, Bytes.toBytes("world")));
 assertTrue(Bytes.contains(array, Bytes.toBytes("ello")));
 assertFalse(Bytes.contains(array, Bytes.toBytes("owo")));
}

代码示例来源：origin: apache/hbase

IOUtils.readFully(in, fileData);
in.close();
assertFalse("Cells appear to be plaintext", Bytes.contains(fileData, value));

代码示例来源：origin: apache/hbase

IOUtils.readFully(in, fileData);
in.close();
assertTrue("Cells should be plaintext", Bytes.contains(fileData, value));

代码示例来源：origin: apache/hbase

IOUtils.readFully(in, fileData);
in.close();
assertFalse("Cells appear to be plaintext", Bytes.contains(fileData, value));

代码示例来源：origin: apache/phoenix

private boolean shouldFailUpsert(ObserverContext<RegionCoprocessorEnvironment> c, Put put) {
  return Bytes.contains(put.getRow(), Bytes.toBytes(ROW_TO_FAIL));
}

代码示例来源：origin: apache/phoenix

public static int getBaseColumnCount(List<Mutation> tableMetadata) {
  int result = -1;
  for (Mutation mutation : tableMetadata) {
    for (List<Cell> cells : mutation.getFamilyCellMap().values()) {
      for (Cell cell : cells) {
        // compare using offsets
        if (Bytes.compareTo(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength(), PhoenixDatabaseMetaData.BASE_COLUMN_COUNT_BYTES, 0,
          PhoenixDatabaseMetaData.BASE_COLUMN_COUNT_BYTES.length) == 0)
        if (Bytes.contains(cell.getQualifierArray(), PhoenixDatabaseMetaData.BASE_COLUMN_COUNT_BYTES)) {
          result = PInteger.INSTANCE.getCodec()
            .decodeInt(cell.getValueArray(), cell.getValueOffset(), SortOrder.ASC);
        }
      }
    }
  }
  return result;
}

代码示例来源：origin: apache/phoenix

TagUtil.concatTags(HConstants.EMPTY_BYTE_ARRAY, updateCacheFrequencyKv);
boolean viewModifiedUpdateCacheFrequency = (PTableType.VIEW.equals(tableType)) &&
    Bytes.contains(tagUpdateCacheFreq, VIEW_MODIFIED_PROPERTY_BYTES);
Cell indexDisableTimestampKv = tableKeyValues[INDEX_DISABLE_TIMESTAMP];
long indexDisableTimestamp = indexDisableTimestampKv == null ? 0L : PLong.INSTANCE.getCodec().decodeLong(indexDisableTimestampKv.getValueArray(),
    TagUtil.concatTags(HConstants.EMPTY_BYTE_ARRAY, useStatsForParallelizationKv);
boolean viewModifiedUseStatsForParallelization = (PTableType.VIEW.equals(tableType)) &&
    Bytes.contains(tagUseStatsForParallelization, VIEW_MODIFIED_PROPERTY_BYTES);

代码示例来源：origin: org.apache.hbase/hbase-common

public void testContains() {
 byte[] array = Bytes.toBytes("hello world");
 assertTrue(Bytes.contains(array, (byte) 'e'));
 assertTrue(Bytes.contains(array, (byte) 'd'));
 assertFalse( Bytes.contains(array, (byte) 'a'));
 assertTrue(Bytes.contains(array, Bytes.toBytes("world")));
 assertTrue(Bytes.contains(array, Bytes.toBytes("ello")));
 assertFalse(Bytes.contains(array, Bytes.toBytes("owo")));
}

代码示例来源：origin: com.aliyun.hbase/alihbase-common

public void testContains() {
 byte[] array = Bytes.toBytes("hello world");
 assertTrue(Bytes.contains(array, (byte) 'e'));
 assertTrue(Bytes.contains(array, (byte) 'd'));
 assertFalse( Bytes.contains(array, (byte) 'a'));
 assertTrue(Bytes.contains(array, Bytes.toBytes("world")));
 assertTrue(Bytes.contains(array, Bytes.toBytes("ello")));
 assertFalse(Bytes.contains(array, Bytes.toBytes("owo")));
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

public static int getBaseColumnCount(List<Mutation> tableMetadata) {
  int result = -1;
  for (Mutation mutation : tableMetadata) {
    for (List<Cell> cells : mutation.getFamilyCellMap().values()) {
      for (Cell cell : cells) {
        // compare using offsets
        if (Bytes.compareTo(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength(), PhoenixDatabaseMetaData.BASE_COLUMN_COUNT_BYTES, 0,
          PhoenixDatabaseMetaData.BASE_COLUMN_COUNT_BYTES.length) == 0)
        if (Bytes.contains(cell.getQualifierArray(), PhoenixDatabaseMetaData.BASE_COLUMN_COUNT_BYTES)) {
          result = PInteger.INSTANCE.getCodec()
            .decodeInt(cell.getValueArray(), cell.getValueOffset(), SortOrder.ASC);
        }
      }
    }
  }
  return result;
}

代码示例来源：origin: org.apache.hbase/hbase-server

IOUtils.readFully(in, fileData);
in.close();
assertFalse("Cells appear to be plaintext", Bytes.contains(fileData, value));

代码示例来源：origin: org.apache.hbase/hbase-server

IOUtils.readFully(in, fileData);
in.close();
assertTrue("Cells should be plaintext", Bytes.contains(fileData, value));

代码示例来源：origin: org.apache.hbase/hbase-server

IOUtils.readFully(in, fileData);
in.close();
assertFalse("Cells appear to be plaintext", Bytes.contains(fileData, value));

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

TagUtil.concatTags(HConstants.EMPTY_BYTE_ARRAY, updateCacheFrequencyKv);
boolean viewModifiedUpdateCacheFrequency = (PTableType.VIEW.equals(tableType)) &&
    Bytes.contains(tagUpdateCacheFreq, VIEW_MODIFIED_PROPERTY_BYTES);
Cell indexDisableTimestampKv = tableKeyValues[INDEX_DISABLE_TIMESTAMP];
long indexDisableTimestamp = indexDisableTimestampKv == null ? 0L : PLong.INSTANCE.getCodec().decodeLong(indexDisableTimestampKv.getValueArray(),
    TagUtil.concatTags(HConstants.EMPTY_BYTE_ARRAY, useStatsForParallelizationKv);
boolean viewModifiedUseStatsForParallelization = (PTableType.VIEW.equals(tableType)) &&
    Bytes.contains(tagUseStatsForParallelization, VIEW_MODIFIED_PROPERTY_BYTES);