本文整理汇总了Java中org.apache.cassandra.db.columniterator.SSTableSliceIterator类的典型用法代码示例。如果您正苦于以下问题:Java SSTableSliceIterator类的具体用法?Java SSTableSliceIterator怎么用?Java SSTableSliceIterator使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SSTableSliceIterator类属于org.apache.cassandra.db.columniterator包,在下文中一共展示了SSTableSliceIterator类的4个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getSSTableColumnIterator
import org.apache.cassandra.db.columniterator.SSTableSliceIterator; //导入依赖的package包/类
public OnDiskAtomIterator getSSTableColumnIterator(SSTableReader sstable, DecoratedKey key)
{
return new SSTableSliceIterator(sstable, key, slices, reversed);
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:5,代码来源:SliceQueryFilter.java
示例2: build
import org.apache.cassandra.db.columniterator.SSTableSliceIterator; //导入依赖的package包/类
@Override
public void build()
{
for (Map.Entry<SSTableReader, Map<ByteBuffer, ColumnIndex>> e : sstables.entrySet())
{
SSTableReader sstable = e.getKey();
Map<ByteBuffer, ColumnIndex> indexes = e.getValue();
if (!sstable.acquireReference())
{
bytesProcessed += getPrimaryIndexLength(sstable);
continue;
}
try
{
PerSSTableIndexWriter indexWriter = newWriter(sstable.descriptor.asTemporary(true), indexes, Source.COMPACTION);
long previousKeyPosition = 0;
try (KeyIterator keys = new KeyIterator(sstable.descriptor))
{
while (keys.hasNext())
{
if (isStopRequested())
throw new CompactionInterruptedException(getCompactionInfo());
final DecoratedKey key = keys.next();
final long keyPosition = keys.getKeyPosition();
indexWriter.startRow(key, keyPosition);
try (SSTableSliceIterator row = new SSTableSliceIterator(sstable, key, ColumnSlice.ALL_COLUMNS_ARRAY, false))
{
while (row.hasNext())
{
OnDiskAtom atom = row.next();
if (atom != null && atom instanceof Column)
indexWriter.nextColumn((Column) atom);
}
}
catch (IOException ex)
{
throw new FSReadError(ex, sstable.getFilename());
}
bytesProcessed += keyPosition - previousKeyPosition;
previousKeyPosition = keyPosition;
}
completeSSTable(indexWriter, sstable, indexes.values());
}
}
finally
{
sstable.releaseReference();
}
}
}
开发者ID:xedin,项目名称:sasi,代码行数:58,代码来源:SSTableAttachedSecondaryIndex.java
示例3: getSSTableColumnIterator
import org.apache.cassandra.db.columniterator.SSTableSliceIterator; //导入依赖的package包/类
public ISSTableColumnIterator getSSTableColumnIterator(SSTableReader sstable, DecoratedKey key)
{
return new SSTableSliceIterator(sstable, key, slices, reversed);
}
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:5,代码来源:SliceQueryFilter.java
示例4: getSSTableColumnIterator
import org.apache.cassandra.db.columniterator.SSTableSliceIterator; //导入依赖的package包/类
public IColumnIterator getSSTableColumnIterator(SSTableReader sstable, DecoratedKey key)
{
return new SSTableSliceIterator(sstable, key, start, finish, reversed);
}
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:5,代码来源:SliceQueryFilter.java
注:本文中的org.apache.cassandra.db.columniterator.SSTableSliceIterator类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论