本文整理汇总了Java中it.uniroma3.mat.extendedset.intset.ConciseSet类的典型用法代码示例。如果您正苦于以下问题:Java ConciseSet类的具体用法?Java ConciseSet怎么用?Java ConciseSet使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ConciseSet类属于it.uniroma3.mat.extendedset.intset包,在下文中一共展示了ConciseSet类的35个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getBitMap
点赞 3
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Override
public ConciseSet getBitMap(Integer startId, Integer endId) {
if (startId == null && endId == null) {
return sets[this.nValues];
}
int start = 0;
int end = this.nValues - 1;
if (startId != null) {
start = startId;
}
if (endId != null) {
end = endId;
}
ConciseSet ret = new ConciseSet();
for (int i = start; i <= end; ++i) {
ConciseSet temp = getBitMap(i);
ret.addAll(temp);
}
return ret;
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:23,
代码来源:BitMapContainer.java
示例2: getNonAggregatedResponse
点赞 3
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private IIProtos.IIResponse getNonAggregatedResponse(Iterable<Slice> slices, CoprocessorFilter filter, CoprocessorRowType type) {
IIProtos.IIResponse.Builder responseBuilder = IIProtos.IIResponse.newBuilder();
for (Slice slice : slices) {
ConciseSet result = null;
if (filter != null) {
result = new BitMapFilterEvaluator(new SliceBitMapProvider(slice, type)).evaluate(filter.getFilter());
}
Iterator<RawTableRecord> iterator = slice.iterateWithBitmap(result);
while (iterator.hasNext()) {
byte[] data = iterator.next().getBytes();
IIProtos.IIResponse.IIRow.Builder rowBuilder = IIProtos.IIResponse.IIRow.newBuilder().setColumns(ByteString.copyFrom(data));
responseBuilder.addRows(rowBuilder.build());
}
}
return responseBuilder.build();
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:19,
代码来源:IIEndpoint.java
示例3: evalCompare
点赞 3
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private ConciseSet evalCompare(CompareTupleFilter filter) {
switch (filter.getOperator()) {
case ISNULL:
return evalCompareIsNull(filter);
case ISNOTNULL:
return evalCompareIsNotNull(filter);
case EQ:
return evalCompareEqual(filter);
case NEQ:
return evalCompareNotEqual(filter);
case IN:
return evalCompareIn(filter);
case NOTIN:
return evalCompareNotIn(filter);
case LT:
return evalCompareLT(filter);
case LTE:
return evalCompareLTE(filter);
case GT:
return evalCompareGT(filter);
case GTE:
return evalCompareGTE(filter);
default:
throw new IllegalStateException("Unsupported operator " + filter.getOperator());
}
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:27,
代码来源:BitMapFilterEvaluator.java
示例4: testGetOutOfBounds
点赞 3
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Test
public void testGetOutOfBounds()
{
final ConciseSet conciseSet = new ConciseSet();
final Set<Integer> ints = ImmutableSet.of(0, 4, 9);
for (int i : ints) {
conciseSet.add(i);
}
final ImmutableBitmap immutableBitmap = new WrappedImmutableConciseBitmap(
ImmutableConciseSet.newImmutableFromMutable(conciseSet));
final MutableBitmap mutableBitmap = new WrappedConciseBitmap(conciseSet);
for (int i = 0; i < 10; ++i) {
Assert.assertEquals(Integer.toString(i), ints.contains(i), mutableBitmap.get(i));
Assert.assertEquals(Integer.toString(i), ints.contains(i), immutableBitmap.get(i));
}
}
开发者ID:metamx,
项目名称:bytebuffer-collections,
代码行数:17,
代码来源:ConciseBitmapFactoryTest.java
示例5: checkUpdateMode
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private void checkUpdateMode() {
if (isClosedForChange()) {
throw new IllegalStateException();
}
if (sets == null) {
sets = new ConciseSet[nValues + 1];
for (int i = 0; i <= nValues; i++) {
sets[i] = new ConciseSet();
}
}
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:12,
代码来源:BitMapContainer.java
示例6: setToBytes
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private ImmutableBytesWritable setToBytes(ConciseSet set) {
byte[] array;
if (set.isEmpty()) // ConciseSet.toByteBuffer() throws exception when
// set is empty
array = BytesUtil.EMPTY_BYTE_ARRAY;
else
array = set.toByteBuffer().array();
return new ImmutableBytesWritable(array);
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:10,
代码来源:BitMapContainer.java
示例7: bytesToSet
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private ConciseSet bytesToSet(ImmutableBytesWritable bytes) {
if (bytes.get() == null || bytes.getLength() == 0) {
return new ConciseSet();
} else {
IntBuffer intBuffer = ByteBuffer.wrap(bytes.get(), bytes.getOffset(), bytes.getLength()).asIntBuffer();
int[] words = new int[intBuffer.capacity()];
intBuffer.get(words);
return new ConciseSet(words, false);
}
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:11,
代码来源:BitMapContainer.java
示例8: iterateWithBitmap
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
public Iterator<RawTableRecord> iterateWithBitmap(final ConciseSet resultBitMap) {
if (resultBitMap == null) {
return this.iterator();
} else {
final RawTableRecord rec = info.createTableRecordBytes();
final ImmutableBytesWritable temp = new ImmutableBytesWritable();
return new Iterator<RawTableRecord>() {
int i = 0;
int iteratedCount = 0;
int resultSize = resultBitMap.size();
@Override
public boolean hasNext() {
return iteratedCount < resultSize;
}
@Override
public RawTableRecord next() {
while (!resultBitMap.contains(i)) {
i++;
}
for (int col = 0; col < nColumns; col++) {
containers[col].getValueAt(i, temp);
rec.setValueBytes(col, temp);
}
iteratedCount++;
i++;
return rec;
}
@Override
public void remove() {
throw new UnsupportedOperationException();
}
};
}
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:41,
代码来源:Slice.java
示例9: evaluate
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
/**
* @param filter
* @return a set of records that match the filter; or null if filter is null or unable to evaluate
*/
public ConciseSet evaluate(TupleFilter filter) {
if (filter == null)
return null;
if (filter instanceof LogicalTupleFilter)
return evalLogical((LogicalTupleFilter) filter);
if (filter instanceof CompareTupleFilter)
return evalCompare((CompareTupleFilter) filter);
return null; // unable to evaluate
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:17,
代码来源:BitMapFilterEvaluator.java
示例10: evalCompareEqual
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private ConciseSet evalCompareEqual(CompareTupleFilter filter) {
int id = Dictionary.stringToDictId(filter.getFirstValue());
ConciseSet bitMap = provider.getBitMap(filter.getColumn(), id, id);
if (bitMap == null)
return null;
return bitMap.clone(); // NOTE the clone() to void messing provider's cache
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:8,
代码来源:BitMapFilterEvaluator.java
示例11: evalCompareIn
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private ConciseSet evalCompareIn(CompareTupleFilter filter) {
ConciseSet set = new ConciseSet();
for (String value : filter.getValues()) {
int id = Dictionary.stringToDictId(value);
ConciseSet bitMap = provider.getBitMap(filter.getColumn(), id, id);
if (bitMap == null)
return null;
set.addAll(bitMap);
}
return set;
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:12,
代码来源:BitMapFilterEvaluator.java
示例12: dropNull
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private void dropNull(ConciseSet set, CompareTupleFilter filter) {
if (set == null)
return;
ConciseSet nullSet = evalCompareIsNull(filter);
set.removeAll(nullSet);
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:8,
代码来源:BitMapFilterEvaluator.java
示例13: evalLogical
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private ConciseSet evalLogical(LogicalTupleFilter filter) {
List<? extends TupleFilter> children = filter.getChildren();
switch (filter.getOperator()) {
case AND:
return evalLogicalAnd(children);
case OR:
return evalLogicalOr(children);
case NOT:
return evalLogicalNot(children);
default:
throw new IllegalStateException("Unsupported operator " + filter.getOperator());
}
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:15,
代码来源:BitMapFilterEvaluator.java
示例14: evalLogicalAnd
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private ConciseSet evalLogicalAnd(List<? extends TupleFilter> children) {
ConciseSet set = new ConciseSet();
not(set);
for (TupleFilter c : children) {
ConciseSet t = evaluate(c);
if (t == null)
continue; // because it's AND
set.retainAll(t);
}
return set;
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:14,
代码来源:BitMapFilterEvaluator.java
示例15: evalLogicalOr
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private ConciseSet evalLogicalOr(List<? extends TupleFilter> children) {
ConciseSet set = new ConciseSet();
for (TupleFilter c : children) {
ConciseSet t = evaluate(c);
if (t == null)
return null; // because it's OR
set.addAll(t);
}
return set;
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:13,
代码来源:BitMapFilterEvaluator.java
示例16: not
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private void not(ConciseSet set) {
if (set == null)
return;
set.add(provider.getRecordCount());
set.complement();
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:8,
代码来源:BitMapFilterEvaluator.java
示例17: getBitMap
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Override
public ConciseSet getBitMap(TblColRef col, Integer startId, Integer endId) {
if (!col.equals(colA))
return null;
// i-th record has value ID i, and last record has value null
if (startId == null && endId == null) {
//entry for getting null value
ConciseSet s = new ConciseSet();
s.add(getRecordCount() - 1);
return s;
}
int start = 0;
int end = MAX_ID;
if (startId != null) {
start = startId;
}
if (endId != null) {
end = endId;
}
ConciseSet ret = new ConciseSet();
for (int i = start; i <= end; ++i) {
ConciseSet temp = getBitMap(col, i);
ret.addAll(temp);
}
return ret;
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:30,
代码来源:BitMapFilterEvaluatorTest.java
示例18: testLogicalAnd
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Test
public void testLogicalAnd() {
for (int i = 0; i < basicFilters.size(); i++) {
for (int j = 0; j < basicFilters.size(); j++) {
LogicalTupleFilter f = logical(FilterOperatorEnum.AND, basicFilters.get(i), basicFilters.get(j));
ConciseSet r = basicResults.get(i).clone();
r.retainAll(basicResults.get(j));
assertEquals(r, eval.evaluate(f));
}
}
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:12,
代码来源:BitMapFilterEvaluatorTest.java
示例19: testLogicalOr
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Test
public void testLogicalOr() {
for (int i = 0; i < basicFilters.size(); i++) {
for (int j = 0; j < basicFilters.size(); j++) {
LogicalTupleFilter f = logical(FilterOperatorEnum.OR, basicFilters.get(i), basicFilters.get(j));
ConciseSet r = basicResults.get(i).clone();
r.addAll(basicResults.get(j));
assertEquals(r, eval.evaluate(f));
}
}
}
开发者ID:KylinOLAP,
项目名称:Kylin,
代码行数:12,
代码来源:BitMapFilterEvaluatorTest.java
示例20: toConcise
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
static ConciseSet toConcise(int[] dat) {
ConciseSet ans = new ConciseSet();
for (int i : dat) {
ans.add(i);
}
return ans;
}
开发者ID:lemire,
项目名称:RoaringVSConciseBenchmark,
代码行数:8,
代码来源:GenericBenchmark.java
示例21: toArray
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
static int[] toArray(ConciseSet s) {
ArrayList<Integer> answer = new ArrayList<Integer>();
IntIterator i = s.iterator();
while (i.hasNext())
answer.add(i.next());
int[] ta = new int[answer.size()];
for (int k = 0; k < ta.length; ++k)
ta[k] = answer.get(k);
return ta;
}
开发者ID:lemire,
项目名称:RoaringVSConciseBenchmark,
代码行数:11,
代码来源:TestMemoryMappedBitmaps.java
示例22: benchmark
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Test
public void benchmark() throws Exception {
ZipRealDataRetriever dataRetriever = new ZipRealDataRetriever(dataset);
long optiSize = 0;
long conciseSize = 0;
long wahSize = 0;
long sparseSize = 0;
long bitsetSize = 0;
for (int[] data : dataRetriever.fetchBitPositions()) {
RoaringBitmap basic = RoaringBitmap.bitmapOf(data);
basic.runOptimize();
ConciseSet concise = toConcise(data);
ConciseSet w = toWAH(data);
SparseBitSet ss = toSparseBitSet(data);
optiSize += sizeOf.deepSizeOf(basic);
conciseSize += sizeOf.deepSizeOf(concise);
wahSize += sizeOf.deepSizeOf(w);
sparseSize += sizeOf.deepSizeOf(ss);
bitsetSize += sizeOf.deepSizeOf(toBitSet(data));
}
System.out.println();
System.out.println("==============");
System.out
.println(dataset + " / bitset size = " + RealDataDetailedBenchmark.humanReadable(bitsetSize)
+ " / Roaring size = " + RealDataDetailedBenchmark.humanReadable(optiSize)
+ " / concise size = " + RealDataDetailedBenchmark.humanReadable(conciseSize)
+ " / WAH size = " + RealDataDetailedBenchmark.humanReadable(wahSize)
+ " / SparseBitSet size = " + RealDataDetailedBenchmark.humanReadable(sparseSize));
System.out.println("==============");
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:34,
代码来源:RealDataMemoryBenchmark.java
示例23: toConcise
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private static ConciseSet toConcise(int[] dat) {
ConciseSet ans = new ConciseSet();
for (int i : dat) {
ans.add(i);
}
return ans;
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:8,
代码来源:RealDataMemoryBenchmark.java
示例24: toWAH
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private static ConciseSet toWAH(int[] dat) {
ConciseSet ans = new ConciseSet(true);
for (int i : dat) {
ans.add(i);
}
return ans;
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:8,
代码来源:RealDataMemoryBenchmark.java
示例25: toConcise
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
static ConciseSet toConcise(int[] dat) {
ConciseSet ans = new ConciseSet();
for (int i : dat) {
ans.add(i);
}
return ans;
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:8,
代码来源:AllRunHorizontalOrBenchmark.java
示例26: toWAH
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
static ConciseSet toWAH(int[] dat) {
ConciseSet ans = new ConciseSet(true);
for (int i : dat) {
ans.add(i);
}
return ans;
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:8,
代码来源:AllRunHorizontalOrBenchmark.java
示例27: OrConcise
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Benchmark
public int OrConcise(BenchmarkState benchmarkState) {
ConciseSet base = benchmarkState.cc.get(0);
for (int k = 1; k < benchmarkState.cc.size(); ++k)
base.union(benchmarkState.cc.get(k));
return base.size();
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:8,
代码来源:AllRunHorizontalOrBenchmark.java
示例28: OrWAH
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Benchmark
public int OrWAH(BenchmarkState benchmarkState) {
ConciseSet base = benchmarkState.wah.get(0);
for (int k = 1; k < benchmarkState.wah.size(); ++k)
base.union(benchmarkState.wah.get(k));
return base.size();
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:8,
代码来源:AllRunHorizontalOrBenchmark.java
示例29: BenchmarkState
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
public BenchmarkState() {
int N = 30;
Random rand = new Random(1234);
for (int k = 0; k < N; ++k) {
RoaringBitmap rb = new RoaringBitmap();
int start = rand.nextInt(10000);
for (int z = 0; z < 50; ++z) {
int end = start + rand.nextInt(10000);
rb.add(start, end);
start = end + rand.nextInt(1000);
}
ConciseSet ccs = toConcise(rb.toArray());
cc.add(ccs);
wah.add(toWAH(rb.toArray()));
icc.add(ImmutableConciseSet.newImmutableFromMutable(ccs));
ac.add(rb);
rb = rb.clone();
rb.runOptimize();
rc.add(rb);
ewah.add(EWAHCompressedBitmap.bitmapOf(rb.toArray()));
ewah32.add(EWAHCompressedBitmap32.bitmapOf(rb.toArray()));
}
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:28,
代码来源:AllRunHorizontalOrBenchmark.java
示例30: newConciseSet
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
private static ConciseSet newConciseSet(int[] data, boolean simulateWAH) {
ConciseSet concise = new ConciseSet(simulateWAH);
for (int i : data) {
concise.add(i);
}
return concise;
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:8,
代码来源:BitmapFactory.java
示例31: naiveAndAggregator
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Override
public BitmapAggregator naiveAndAggregator() {
return new BitmapAggregator() {
@Override
public Bitmap aggregate(Iterable<Bitmap> bitmaps) {
final Iterator<Bitmap> i = bitmaps.iterator();
ConciseSet bitmap = ((ConciseSetWrapper) i.next()).bitmap;
while (i.hasNext()) {
bitmap = bitmap.intersection(((ConciseSetWrapper) i.next()).bitmap);
}
return new ConciseSetWrapper(bitmap);
}
};
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:15,
代码来源:ConciseSetWrapper.java
示例32: naiveOrAggregator
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Override
public BitmapAggregator naiveOrAggregator() {
return new BitmapAggregator() {
@Override
public Bitmap aggregate(Iterable<Bitmap> bitmaps) {
final Iterator<Bitmap> i = bitmaps.iterator();
ConciseSet bitmap = ((ConciseSetWrapper) i.next()).bitmap;
while (i.hasNext()) {
bitmap = bitmap.union(((ConciseSetWrapper) i.next()).bitmap);
}
return new ConciseSetWrapper(bitmap);
}
};
}
开发者ID:RoaringBitmap,
项目名称:RoaringBitmap,
代码行数:15,
代码来源:ConciseSetWrapper.java
示例33: or
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Override
public void or(MutableBitmap mutableBitmap)
{
WrappedConciseBitmap other = (WrappedConciseBitmap) mutableBitmap;
ConciseSet unwrappedOtherBitmap = other.bitmap;
bitmap.addAll(unwrappedOtherBitmap);
}
开发者ID:metamx,
项目名称:bytebuffer-collections,
代码行数:8,
代码来源:WrappedConciseBitmap.java
示例34: and
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Override
public void and(MutableBitmap mutableBitmap)
{
WrappedConciseBitmap other = (WrappedConciseBitmap) mutableBitmap;
ConciseSet unwrappedOtherBitmap = other.bitmap;
bitmap = bitmap.intersection(unwrappedOtherBitmap);
}
开发者ID:metamx,
项目名称:bytebuffer-collections,
代码行数:8,
代码来源:WrappedConciseBitmap.java
示例35: xor
点赞 2
import it.uniroma3.mat.extendedset.intset.ConciseSet; //导入依赖的package包/类
@Override
public void xor(MutableBitmap mutableBitmap)
{
WrappedConciseBitmap other = (WrappedConciseBitmap) mutableBitmap;
ConciseSet unwrappedOtherBitmap = other.bitmap;
bitmap = bitmap.symmetricDifference(unwrappedOtherBitmap);
}
开发者ID:metamx,
项目名称:bytebuffer-collections,
代码行数:8,
代码来源:WrappedConciseBitmap.java