Examples of org.apache.accumulo.core.client.admin.TableOperations.attachIterator()

Package org.apache.accumulo.core.client.admin

Class org.apache.accumulo.core.client.admin.TableOperations

Examples of org.apache.accumulo.core.client.admin.TableOperations.attachIterator()

org.apache.accumulo.core.client.admin.TableOperations.attachIterator()
Add an iterator to a table on all scopes. @param tableName the name of the table @param setting object specifying the properties of the iterator @throws AccumuloSecurityException thrown if the user does not have the ability to set properties on the table @throws TableNotFoundException throw if the table no longer exists @throws IllegalArgumentException if the setting conflicts with any existing iterators

      if (!tableOps.exists(getTableName())) {
        tableOps.create(getTableName());
        IteratorSetting is = new IteratorSetting(10, org.apache.accumulo.core.iterators.user.SummingCombiner.class);
        SummingCombiner.setEncodingType(is, LongCombiner.Type.STRING);
        SummingCombiner.setCombineAllColumns(is, true);
        tableOps.attachIterator(getTableName(), is);
      }
    } catch (TableExistsException ex) {
      // expected if there are multiple walkers
    }
    state.set("rand", rand);

View Full Code Here

      if (!tableOps.exists(getTableName())) {
        tableOps.create(getTableName());
        IteratorSetting is = new IteratorSetting(10, org.apache.accumulo.core.iterators.user.SummingCombiner.class);
        SummingCombiner.setEncodingType(is, LongCombiner.Type.STRING);
        SummingCombiner.setCombineAllColumns(is, true);
        tableOps.attachIterator(getTableName(), is);
      }
    } catch (TableExistsException ex) {
      // expected if there are multiple walkers
    }
    state.set("rand", rand);

View Full Code Here

      if (!tableOps.exists(getTableName())) {
        tableOps.create(getTableName());
        IteratorSetting is = new IteratorSetting(10, SummingCombiner.class);
        SummingCombiner.setEncodingType(is, LongCombiner.Type.STRING);
        SummingCombiner.setCombineAllColumns(is, true);
        tableOps.attachIterator(getTableName(), is);
      }
    } catch (TableExistsException ex) {
      // expected if there are multiple walkers
    }
    state.set("rand", rand);

View Full Code Here

            fail();
          case 1:
            ops.addSplits(tableName, new TreeSet<Text>());
            fail();
          case 2:
            ops.attachIterator(tableName, setting);
            fail();
          case 3:
            ops.cancelCompaction(tableName);
            fail();
          case 4:

View Full Code Here

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.