Skip to content

Instantly share code, notes, and snippets.

@willb
Created March 6, 2014 15:16
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save willb/9391908 to your computer and use it in GitHub Desktop.
Save willb/9391908 to your computer and use it in GitHub Desktop.
/* stream-lib Bloom filter interface */
public class com.clearspring.analytics.stream.membership.BloomFilter extends com.clearspring.analytics.stream.membership.Filter {
static com.clearspring.analytics.stream.membership.ICompactSerializer<com.clearspring.analytics.stream.membership.BloomFilter> serializer_;
public static com.clearspring.analytics.stream.membership.ICompactSerializer<com.clearspring.analytics.stream.membership.BloomFilter> serializer();
public com.clearspring.analytics.stream.membership.BloomFilter(int, int);
public com.clearspring.analytics.stream.membership.BloomFilter(int, double);
com.clearspring.analytics.stream.membership.BloomFilter(int, java.util.BitSet);
public void clear();
public int buckets();
java.util.BitSet filter();
public boolean isPresent(java.lang.String);
public boolean isPresent(byte[]);
public void add(java.lang.String);
public void add(byte[]);
public java.lang.String toString();
com.clearspring.analytics.stream.membership.ICompactSerializer tserializer();
int emptyBuckets();
public static com.clearspring.analytics.stream.membership.BloomFilter alwaysMatchingBloomFilter();
public static byte[] serialize(com.clearspring.analytics.stream.membership.BloomFilter);
public static com.clearspring.analytics.stream.membership.BloomFilter deserialize(byte[]);
static {};
}
/* Cassandra Bloom filter interface */
public abstract class org.apache.cassandra.utils.BloomFilter implements org.apache.cassandra.utils.IFilter {
public final org.apache.cassandra.utils.obs.IBitSet bitset;
public final int hashCount;
org.apache.cassandra.utils.BloomFilter(int, org.apache.cassandra.utils.obs.IBitSet);
protected abstract long[] hash(java.nio.ByteBuffer, int, int, long);
long[] getHashBuckets(java.nio.ByteBuffer, int, long);
public void add(java.nio.ByteBuffer);
public boolean isPresent(java.nio.ByteBuffer);
public void clear();
public void close() throws java.io.IOException;
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment