本文整理汇总了Java中org.apache.cassandra.io.sstable.metadata.MetadataComponent类的典型用法代码示例。如果您正苦于以下问题：Java MetadataComponent类的具体用法？Java MetadataComponent怎么用？Java MetadataComponent使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
MetadataComponent类属于org.apache.cassandra.io.sstable.metadata包，在下文中一共展示了MetadataComponent类的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: writeMetadata
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
private static void writeMetadata(Descriptor desc, Map<MetadataType, MetadataComponent> components)
{
SequentialWriter out = SequentialWriter.open(new File(desc.filenameFor(Component.STATS)));
try
{
desc.getMetadataSerializer().serialize(components, out.stream);
}
catch (IOException e)
{
throw new FSWriteError(e, out.getPath());
}
finally
{
out.close();
}
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:17，代码来源:SSTableWriter.java
示例2: close
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
private Pair<Descriptor, StatsMetadata> close(long repairedAt)
{
// index and filter
iwriter.close();
// main data, close will truncate if necessary
dataFile.close();
dataFile.writeFullChecksum(descriptor);
// write sstable statistics
Map<MetadataType, MetadataComponent> metadataComponents = sstableMetadataCollector.finalizeMetadata(
partitioner.getClass().getCanonicalName(),
metadata.getBloomFilterFpChance(),
repairedAt);
writeMetadata(descriptor, metadataComponents);
// save the table of components
SSTable.appendTOC(descriptor, components);
// remove the 'tmp' marker from all components
return Pair.create(rename(descriptor, components), (StatsMetadata) metadataComponents.get(MetadataType.STATS));
}
开发者ID:daidong，项目名称:GraphTrek，代码行数:23，代码来源:SSTableWriter.java
示例3: close
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
public Pair<Descriptor, StatsMetadata> close()
{
// index and filter
iwriter.close();
// main data, close will truncate if necessary
dataFile.close();
// write sstable statistics
Map<MetadataType, MetadataComponent> metadataComponents = sstableMetadataCollector.finalizeMetadata(
partitioner.getClass().getCanonicalName(),
metadata.getBloomFilterFpChance());
writeMetadata(descriptor, metadataComponents);
// save the table of components
SSTable.appendTOC(descriptor, components);
// remove the 'tmp' marker from all components
return Pair.create(rename(descriptor, components), (StatsMetadata) metadataComponents.get(MetadataType.STATS));
}
开发者ID:mafernandez-stratio，项目名称:cassandra-cqlMod，代码行数:19，代码来源:SSTableWriter.java
示例4: writeMetadata
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
private static void writeMetadata(Descriptor desc, Map<MetadataType, MetadataComponent> components)
{
SequentialWriter out = SequentialWriter.open(new File(desc.filenameFor(Component.STATS)), true);
try
{
desc.getMetadataSerializer().serialize(components, out.stream);
}
catch (IOException e)
{
throw new FSWriteError(e, out.getPath());
}
finally
{
out.close();
}
}
开发者ID:mafernandez-stratio，项目名称:cassandra-cqlMod，代码行数:17，代码来源:SSTableWriter.java
示例5: close
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
private Pair<Descriptor, StatsMetadata> close(long repairedAt)
{
dataFile.writeFullChecksum(descriptor);
// index and filter
iwriter.close();
// main data, close will truncate if necessary
dataFile.close();
// write sstable statistics
Map<MetadataType, MetadataComponent> metadataComponents = sstableMetadataCollector.finalizeMetadata(
partitioner.getClass().getCanonicalName(),
metadata.getBloomFilterFpChance(),
repairedAt);
writeMetadata(descriptor, metadataComponents);
// save the table of components
SSTable.appendTOC(descriptor, components);
// remove the 'tmp' marker from all components
return Pair.create(rename(descriptor, components), (StatsMetadata) metadataComponents.get(MetadataType.STATS));
}
开发者ID:rajath26，项目名称:cassandra-trunk，代码行数:22，代码来源:SSTableWriter.java
示例6: newPartitioner
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
/**
* Create a new instance of a partitioner defined in an SSTable Descriptor
* @param desc Descriptor of an sstable
* @return a new IPartitioner instance
* @throws IOException
*/
public static IPartitioner newPartitioner(Descriptor desc) throws IOException
{
EnumSet<MetadataType> types = EnumSet.of(MetadataType.VALIDATION, MetadataType.HEADER);
Map<MetadataType, MetadataComponent> sstableMetadata = desc.getMetadataSerializer().deserialize(desc, types);
ValidationMetadata validationMetadata = (ValidationMetadata) sstableMetadata.get(MetadataType.VALIDATION);
SerializationHeader.Component header = (SerializationHeader.Component) sstableMetadata.get(MetadataType.HEADER);
return newPartitioner(validationMetadata.partitioner, Optional.of(header.getKeyType()));
}
开发者ID:Netflix，项目名称:sstable-adaptor，代码行数:15，代码来源:FBUtilities.java
示例7: writeMetadata
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
private void writeMetadata(Descriptor desc, Map<MetadataType, MetadataComponent> components)
{
try (SequentialWriter out = new SequentialWriter(desc.filenameFor(Component.STATS), writerOption, desc.getConfiguration()))
{
desc.getMetadataSerializer().serialize(components, out, desc.version);
out.finish();
}
catch (IOException e)
{
throw new FSWriteError(e, desc.filenameFor(Component.STATS));
}
}
开发者ID:Netflix，项目名称:sstable-adaptor，代码行数:13，代码来源:BigTableWriter.java
示例8: finalizeMetadata
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
protected Map<MetadataType, MetadataComponent> finalizeMetadata()
{
return metadataCollector.finalizeMetadata(getPartitioner().getClass().getCanonicalName(),
metadata.params.bloomFilterFpChance,
repairedAt,
header);
}
开发者ID:Netflix，项目名称:sstable-adaptor，代码行数:8，代码来源:SSTableWriter.java
示例9: close
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
private Pair<Descriptor, StatsMetadata> close(FinishType type, long repairedAt)
{
switch (type)
{
case EARLY: case CLOSE: case NORMAL:
iwriter.close();
dataFile.close();
if (type == FinishType.CLOSE)
iwriter.bf.close();
}
// write sstable statistics
Map<MetadataType, MetadataComponent> metadataComponents ;
metadataComponents = sstableMetadataCollector
.finalizeMetadata(partitioner.getClass().getCanonicalName(),
metadata.getBloomFilterFpChance(),repairedAt);
// remove the 'tmp' marker from all components
Descriptor descriptor = this.descriptor;
if (type.isFinal)
{
dataFile.writeFullChecksum(descriptor);
writeMetadata(descriptor, metadataComponents);
// save the table of components
SSTable.appendTOC(descriptor, components);
descriptor = rename(descriptor, components);
}
return Pair.create(descriptor, (StatsMetadata) metadataComponents.get(MetadataType.STATS));
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:31，代码来源:SSTableWriter.java
示例10: writeMetadata
import org.apache.cassandra.io.sstable.metadata.MetadataComponent; //导入依赖的package包/类
private static void writeMetadata(Descriptor desc, Map<MetadataType, MetadataComponent> components)
{
File file = new File(desc.filenameFor(Component.STATS));
try (SequentialWriter out = SequentialWriter.open(file))
{
desc.getMetadataSerializer().serialize(components, out, desc.version);
out.setDescriptor(desc).finish();
}
catch (IOException e)
{
throw new FSWriteError(e, file.getPath());
}
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:14，代码来源:BigTableWriter.java
注：本文中的org.apache.cassandra.io.sstable.metadata.MetadataComponent类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论