List of addIndexDescriptor() Examples

Examples of addIndexDescriptor()

org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()
Adds the index descriptor to the column family, replacing the existing index descriptor for the {@link org.apache.hadoop.hbase.client.idx.IdxIndexDescriptor#getQualifierName() qualifier name} if one exists. @param descriptor the descriptor @throws IllegalArgumentException if an index descriptor already exists forthe qualifier @throws NullPointerException if the provided descriptor has a null{@link IdxIndexDescriptor#getQualifierName()} @throws java.io.IOException if an error occurrs while attempting towrite the index descriptors to the values

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()


    HTableDescriptor desc = new HTableDescriptor("testConcurrentReadWrite");
    byte[] family = Bytes.toBytes("concurrentRW");
    byte[] qualifier = Bytes.toBytes("strings");
    IdxColumnDescriptor descriptor = new IdxColumnDescriptor(family);
    descriptor.addIndexDescriptor(new IdxIndexDescriptor(qualifier,
      IdxQualifierType.CHAR_ARRAY));
    desc.addFamily(descriptor);
    HBaseAdmin admin = new HBaseAdmin(conf);
    admin.createTable(desc);
    HTable table = new HTable(conf, desc.getName());

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

   *
   * @throws java.io.IOException in case of an IO error
   */
  public void testIdxRegionPerformance() throws IOException {
    IdxColumnDescriptor family1 = new IdxColumnDescriptor(FAMILY_1_NAME);
    family1.addIndexDescriptor(new IdxIndexDescriptor(INT_QUAL_NAME,
      IdxQualifierType.INT));
    family1.addIndexDescriptor(new IdxIndexDescriptor(BYTES_QUAL_NAME,
      IdxQualifierType.BYTE_ARRAY));


    IdxColumnDescriptor family2 = new IdxColumnDescriptor(FAMILY_2_NAME);

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

   */
  public void testIdxRegionPerformance() throws IOException {
    IdxColumnDescriptor family1 = new IdxColumnDescriptor(FAMILY_1_NAME);
    family1.addIndexDescriptor(new IdxIndexDescriptor(INT_QUAL_NAME,
      IdxQualifierType.INT));
    family1.addIndexDescriptor(new IdxIndexDescriptor(BYTES_QUAL_NAME,
      IdxQualifierType.BYTE_ARRAY));


    IdxColumnDescriptor family2 = new IdxColumnDescriptor(FAMILY_2_NAME);
    family2.addIndexDescriptor(new IdxIndexDescriptor(CHARS_QUAL_NAME,
      IdxQualifierType.CHAR_ARRAY));

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

      IdxQualifierType.INT));
    family1.addIndexDescriptor(new IdxIndexDescriptor(BYTES_QUAL_NAME,
      IdxQualifierType.BYTE_ARRAY));


    IdxColumnDescriptor family2 = new IdxColumnDescriptor(FAMILY_2_NAME);
    family2.addIndexDescriptor(new IdxIndexDescriptor(CHARS_QUAL_NAME,
      IdxQualifierType.CHAR_ARRAY));


    HTableDescriptor htableDescriptor
      = new HTableDescriptor("testIdxRegionPerformance");
    htableDescriptor.addFamily(family1);

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

    for (Pair<byte[], IdxIndexDescriptor[]> familyPair : families) {
      IdxColumnDescriptor idxColumnDescriptor
        = new IdxColumnDescriptor(familyPair.getFirst());
      if (familyPair.getSecond() != null) {
        for (IdxIndexDescriptor descriptor : familyPair.getSecond())
          idxColumnDescriptor.addIndexDescriptor(descriptor);
      }
      htd.addFamily(idxColumnDescriptor);
    }
    HRegionInfo info = new HRegionInfo(htd, null, null, false);
    Path path = new Path(DIR + callingMethod);

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

    byte[]... families) {
    HTableDescriptor htd = new HTableDescriptor(tableName);
    for (byte[] family : families) {
      try {
        IdxColumnDescriptor icd = new IdxColumnDescriptor(family);
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual1,
          IdxQualifierType.BYTE_ARRAY));
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual2,
          IdxQualifierType.BYTE_ARRAY));
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual3,
          IdxQualifierType.BYTE_ARRAY));

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

    for (byte[] family : families) {
      try {
        IdxColumnDescriptor icd = new IdxColumnDescriptor(family);
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual1,
          IdxQualifierType.BYTE_ARRAY));
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual2,
          IdxQualifierType.BYTE_ARRAY));
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual3,
          IdxQualifierType.BYTE_ARRAY));
        htd.addFamily(icd);
      } catch (IOException e) {

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

        IdxColumnDescriptor icd = new IdxColumnDescriptor(family);
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual1,
          IdxQualifierType.BYTE_ARRAY));
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual2,
          IdxQualifierType.BYTE_ARRAY));
        icd.addIndexDescriptor(new IdxIndexDescriptor(qual3,
          IdxQualifierType.BYTE_ARRAY));
        htd.addFamily(icd);
      } catch (IOException e) {
        throw new IllegalStateException(e);
      }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

    HTableDescriptor tableDescr = new HTableDescriptor("testfacttable");
    IdxColumnDescriptor idxColumnDescriptor = new IdxColumnDescriptor(Bytes.toBytes("data"));
    IdxIndexDescriptor indexDescriptor1  = new IdxIndexDescriptor(Bytes.toBytes("d1"), IdxQualifierType.LONG);
    IdxIndexDescriptor indexDescriptor2  = new IdxIndexDescriptor(Bytes.toBytes("d2"), IdxQualifierType.LONG);
    IdxIndexDescriptor indexDescriptor3  = new IdxIndexDescriptor(Bytes.toBytes("d3"), IdxQualifierType.LONG);
    idxColumnDescriptor.addIndexDescriptor(indexDescriptor1);
    idxColumnDescriptor.addIndexDescriptor(indexDescriptor2);
    idxColumnDescriptor.addIndexDescriptor(indexDescriptor3);
    tableDescr.addFamily(idxColumnDescriptor);
    if(admin.tableExists("testfacttable")) {
      admin.disableTable("testfacttable");

View Full Code Here

Examples of org.apache.hadoop.hbase.client.idx.IdxColumnDescriptor.addIndexDescriptor()

    IdxColumnDescriptor idxColumnDescriptor = new IdxColumnDescriptor(Bytes.toBytes("data"));
    IdxIndexDescriptor indexDescriptor1  = new IdxIndexDescriptor(Bytes.toBytes("d1"), IdxQualifierType.LONG);
    IdxIndexDescriptor indexDescriptor2  = new IdxIndexDescriptor(Bytes.toBytes("d2"), IdxQualifierType.LONG);
    IdxIndexDescriptor indexDescriptor3  = new IdxIndexDescriptor(Bytes.toBytes("d3"), IdxQualifierType.LONG);
    idxColumnDescriptor.addIndexDescriptor(indexDescriptor1);
    idxColumnDescriptor.addIndexDescriptor(indexDescriptor2);
    idxColumnDescriptor.addIndexDescriptor(indexDescriptor3);
    tableDescr.addFamily(idxColumnDescriptor);
    if(admin.tableExists("testfacttable")) {
      admin.disableTable("testfacttable");
      admin.deleteTable("testfacttable");

View Full Code Here

0 1

TOP

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.