List of addIndexGroup() Examples

Examples of addIndexGroup()

com.salesforce.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()
Add a group of columns to index @param columns Pairs of cf:cq (full specification of a column) to index @return the index of the group. This can be used to remove or modify the group via{@link #remove(int)} or {@link #get(int)}, any time before building
org.apache.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()
Add a group of columns to index @param columns Pairs of cf:cq (full specification of a column) to index @return the index of the group. This can be used to remove or modify the group via{@link #remove(int)} or {@link #get(int)}, any time before building
org.apache.phoenix.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()
Add a group of columns to index @param columns Pairs of cf:cq (full specification of a column) to index @return the index of the group. This can be used to remove or modify the group via{@link #remove(int)} or {@link #get(int)}, any time before building

Examples of com.salesforce.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    // enable indexing to a non-existant index table
    byte[] family = new byte[] { 'a' };
    ColumnGroup fam1 = new ColumnGroup(INDEX_TABLE_NAME);
    fam1.add(new CoveredColumn(family, CoveredColumn.ALL_QUALIFIERS));
    CoveredColumnIndexSpecifierBuilder builder = new CoveredColumnIndexSpecifierBuilder();
    builder.addIndexGroup(fam1);
    builder.build(htd);


    // create the region + its WAL
    HRegion region0 = HRegion.createHRegion(hri, hbaseRootDir, this.conf, htd);
    region0.close();

View Full Code Here

Examples of com.salesforce.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    byte[] nonIndexedFamily = Bytes.toBytes("nonIndexedFamily");
    String indexedTableName = getIndexTableName();
    ColumnGroup columns = new ColumnGroup(indexedTableName);
    columns.add(new CoveredColumn(family, qual));
    CoveredColumnIndexSpecifierBuilder builder = new CoveredColumnIndexSpecifierBuilder();
    builder.addIndexGroup(columns);


    // create the primary table w/ indexing enabled
    HTableDescriptor primaryTable = new HTableDescriptor(testTable.getTableName());
    primaryTable.addFamily(new HColumnDescriptor(family));
    primaryTable.addFamily(new HColumnDescriptor(nonIndexedFamily));

View Full Code Here

Examples of com.salesforce.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    // enable indexing to a non-existant index table
    String indexTableName = "INDEX_TABLE";
    ColumnGroup fam1 = new ColumnGroup(indexTableName);
    fam1.add(new CoveredColumn(family, CoveredColumn.ALL_QUALIFIERS));
    CoveredColumnIndexSpecifierBuilder builder = new CoveredColumnIndexSpecifierBuilder();
    builder.addIndexGroup(fam1);
    builder.build(desc);


    // get a reference to the regionserver, so we can ensure it aborts
    HRegionServer server = util.getMiniHBaseCluster().getRegionServer(0);

View Full Code Here

Examples of org.apache.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    // enable indexing to a non-existant index table
    String indexTableName = "INDEX_TABLE";
    ColumnGroup fam1 = new ColumnGroup(indexTableName);
    fam1.add(new CoveredColumn(family, CoveredColumn.ALL_QUALIFIERS));
    CoveredColumnIndexSpecifierBuilder builder = new CoveredColumnIndexSpecifierBuilder();
    builder.addIndexGroup(fam1);
    builder.build(desc);


    // get a reference to the regionserver, so we can ensure it aborts
    HRegionServer server = util.getMiniHBaseCluster().getRegionServer(0);

View Full Code Here

Examples of org.apache.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    byte[] nonIndexedFamily = Bytes.toBytes("nonIndexedFamily");
    String indexedTableName = getIndexTableName();
    ColumnGroup columns = new ColumnGroup(indexedTableName);
    columns.add(new CoveredColumn(family, qual));
    CoveredColumnIndexSpecifierBuilder builder = new CoveredColumnIndexSpecifierBuilder();
    builder.addIndexGroup(columns);


    // create the primary table w/ indexing enabled
    HTableDescriptor primaryTable = new HTableDescriptor(testTable.getTableName());
    primaryTable.addFamily(new HColumnDescriptor(family));
    primaryTable.addFamily(new HColumnDescriptor(nonIndexedFamily));

View Full Code Here

Examples of org.apache.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    // enable indexing to a non-existant index table
    byte[] family = new byte[] { 'a' };
    ColumnGroup fam1 = new ColumnGroup(INDEX_TABLE_NAME);
    fam1.add(new CoveredColumn(family, CoveredColumn.ALL_QUALIFIERS));
    CoveredColumnIndexSpecifierBuilder builder = new CoveredColumnIndexSpecifierBuilder();
    builder.addIndexGroup(fam1);
    builder.build(htd);


    // create the region + its WAL
    HRegion region0 = HRegion.createHRegion(hri, hbaseRootDir, this.conf, htd);
    region0.close();

View Full Code Here

Examples of org.apache.phoenix.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    CoveredColumn col1 = new CoveredColumn(FAMILY, indexed_qualifer);
    fam1.add(col1);
    // matches the family2:* columns
    CoveredColumn col2 = new CoveredColumn(FAMILY2, null);
    fam1.add(col2);
    builder.addIndexGroup(fam1);
    ColumnGroup fam2 = new ColumnGroup(INDEX_TABLE2);
    // match a single family2:qualifier pair
    CoveredColumn col3 = new CoveredColumn(FAMILY2, indexed_qualifer);
    fam2.add(col3);
    builder.addIndexGroup(fam2);

View Full Code Here

Examples of org.apache.phoenix.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    builder.addIndexGroup(fam1);
    ColumnGroup fam2 = new ColumnGroup(INDEX_TABLE2);
    // match a single family2:qualifier pair
    CoveredColumn col3 = new CoveredColumn(FAMILY2, indexed_qualifer);
    fam2.add(col3);
    builder.addIndexGroup(fam2);
    
    Configuration conf = new Configuration(false);
    //convert the map that HTableDescriptor gets into the conf the coprocessor receives
    Map<String, String> map = builder.convertToMap();
    for(Entry<String, String> entry: map.entrySet()){

View Full Code Here

Examples of org.apache.phoenix.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    byte[] nonIndexedFamily = Bytes.toBytes("nonIndexedFamily");
    String indexedTableName = getIndexTableName();
    ColumnGroup columns = new ColumnGroup(indexedTableName);
    columns.add(new CoveredColumn(family, qual));
    CoveredColumnIndexSpecifierBuilder builder = new CoveredColumnIndexSpecifierBuilder();
    builder.addIndexGroup(columns);


    // create the primary table w/ indexing enabled
    HTableDescriptor primaryTable = new HTableDescriptor(testTable.getTableName());
    primaryTable.addFamily(new HColumnDescriptor(family));
    primaryTable.addFamily(new HColumnDescriptor(nonIndexedFamily));

View Full Code Here

Examples of org.apache.phoenix.hbase.index.covered.example.CoveredColumnIndexSpecifierBuilder.addIndexGroup()

    // enable indexing to a non-existant index table
    byte[] family = new byte[] { 'a' };
    ColumnGroup fam1 = new ColumnGroup(INDEX_TABLE_NAME);
    fam1.add(new CoveredColumn(family, CoveredColumn.ALL_QUALIFIERS));
    CoveredColumnIndexSpecifierBuilder builder = new CoveredColumnIndexSpecifierBuilder();
    builder.addIndexGroup(fam1);
    builder.build(htd);


    // create the region + its WAL
    HRegion region0 = HRegion.createHRegion(hri, hbaseRootDir, this.conf, htd);
    region0.close();

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.