Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package org.neolumin.vertexium.accumulo.iterator;
 
 import  org.apache.hadoop.io.Text;
 
public class ElementVisibilityRowFilter extends RowFilter {
    public static final String OPT_FILTER_VERTICES = "vertex.enabled";
    public static final String OPT_FILTER_EDGES = "edge.enabled";
    // must match org.neolumin.vertexium.accumulo.AccumuloVertex.CF_SIGNAL
    private static final Text VERTEX_CF_SIGNAL = new Text("V");
    // must match org.neolumin.vertexium.accumulo.AccumuloEdge.CF_SIGNAL
    private static final Text EDGE_CF_SIGNAL = new Text("E");
    boolean filterVertices;
    boolean filterEdges;
    @Override
    public void init(SortedKeyValueIterator<KeyValuesourceMap<StringStringoptionsIteratorEnvironment envthrows IOException {
        this. = options.get() != null;
        this. = options.get() != null;
        if (!this. && !this.) {
            throw new IllegalArgumentException( + " and/or " +  + " must be set to a non-null value.");
        }
        super.init(sourceoptionsenv);
    }
    @Override
    public boolean acceptRow(SortedKeyValueIterator<KeyValuerowIteratorthrows IOException {
        while (rowIterator.hasTop()) {
            Key key = rowIterator.getTopKey();
            if (isVisible(key)) {
                return true;
            }
            rowIterator.next();
        }
        return false;
    }
    private boolean isVisible(Key key) {
        return (this. && key.compareColumnFamily() == 0) ||
                (this. && key.compareColumnFamily() == 0);
    }
New to GrepCode? Check out our FAQ X