• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java UUIDSerializer类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.cassandra.utils.UUIDSerializer的典型用法代码示例。如果您正苦于以下问题:Java UUIDSerializer类的具体用法?Java UUIDSerializer怎么用?Java UUIDSerializer使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



UUIDSerializer类属于org.apache.cassandra.utils包,在下文中一共展示了UUIDSerializer类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public PrepareResponse deserialize(DataInput in, int version) throws IOException
{
    boolean success = in.readBoolean();
    ByteBuffer key = ByteBufferUtil.readWithShortLength(in);
    return new PrepareResponse(success,
                               new Commit(key,
                                          UUIDSerializer.serializer.deserialize(in, version),
                                          ColumnFamily.serializer.deserialize(in,
                                                                              ArrayBackedSortedColumns.factory,
                                                                              ColumnSerializer.Flag.LOCAL, version)),
                               new Commit(key,
                                          UUIDSerializer.serializer.deserialize(in, version),
                                          ColumnFamily.serializer.deserialize(in,
                                                                              ArrayBackedSortedColumns.factory,
                                                                              ColumnSerializer.Flag.LOCAL, version)));
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:17,代码来源:PrepareResponse.java


示例2: serialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public void serialize(FileMessageHeader header, DataOutputPlus out, int version) throws IOException
{
    UUIDSerializer.serializer.serialize(header.cfId, out, version);
    out.writeInt(header.sequenceNumber);
    out.writeUTF(header.version);
    out.writeLong(header.estimatedKeys);

    out.writeInt(header.sections.size());
    for (Pair<Long, Long> section : header.sections)
    {
        out.writeLong(section.left);
        out.writeLong(section.right);
    }
    CompressionInfo.serializer.serialize(header.compressionInfo, out, version);
    out.writeLong(header.repairedAt);
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:17,代码来源:FileMessageHeader.java


示例3: serializedSize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public long serializedSize(FileMessageHeader header, int version)
{
    long size = UUIDSerializer.serializer.serializedSize(header.cfId, version);
    size += TypeSizes.NATIVE.sizeof(header.sequenceNumber);
    size += TypeSizes.NATIVE.sizeof(header.version);
    size += TypeSizes.NATIVE.sizeof(header.estimatedKeys);

    size += TypeSizes.NATIVE.sizeof(header.sections.size());
    for (Pair<Long, Long> section : header.sections)
    {
        size += TypeSizes.NATIVE.sizeof(section.left);
        size += TypeSizes.NATIVE.sizeof(section.right);
    }
    size += CompressionInfo.serializer.serializedSize(header.compressionInfo, version);
    return size;
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:17,代码来源:FileMessageHeader.java


示例4: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public HintMessage deserialize(DataInputPlus in, int version) throws IOException
{
    UUID hostId = UUIDSerializer.serializer.deserialize(in, version);

    long hintSize = in.readUnsignedVInt();
    TrackedDataInputPlus countingIn = new TrackedDataInputPlus(in);
    try
    {
        return new HintMessage(hostId, Hint.serializer.deserialize(countingIn, version));
    }
    catch (UnknownColumnFamilyException e)
    {
        in.skipBytes(Ints.checkedCast(hintSize - countingIn.getBytesRead()));
        return new HintMessage(hostId, e.cfId);
    }
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:17,代码来源:HintMessage.java


示例5: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public PrepareResponse deserialize(DataInputPlus in, int version) throws IOException
{
    boolean success = in.readBoolean();
    Commit inProgress = Commit.serializer.deserialize(in, version);
    Commit mostRecent;
    if (version < MessagingService.VERSION_30)
    {
        UUID ballot = UUIDSerializer.serializer.deserialize(in, version);
        PartitionUpdate update = PartitionUpdate.serializer.deserialize(in, version, SerializationHelper.Flag.LOCAL, inProgress.update.partitionKey());
        mostRecent = new Commit(ballot, update);
    }
    else
    {
        mostRecent = Commit.serializer.deserialize(in, version);
    }
    return new PrepareResponse(success, inProgress, mostRecent);
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:18,代码来源:PrepareResponse.java


示例6: serializedSize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public long serializedSize(PrepareResponse response, int version)
{
    long size = TypeSizes.sizeof(response.promised)
              + Commit.serializer.serializedSize(response.inProgressCommit, version);

    if (version < MessagingService.VERSION_30)
    {
        size += UUIDSerializer.serializer.serializedSize(response.mostRecentCommit.ballot, version);
        size += PartitionUpdate.serializer.serializedSize(response.mostRecentCommit.update, version);
    }
    else
    {
        size += Commit.serializer.serializedSize(response.mostRecentCommit, version);
    }
    return size;
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:17,代码来源:PrepareResponse.java


示例7: serialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public void serialize(RepairJobDesc desc, DataOutputPlus out, int version) throws IOException
{
    if (version >= MessagingService.VERSION_21)
    {
        out.writeBoolean(desc.parentSessionId != null);
        if (desc.parentSessionId != null)
            UUIDSerializer.serializer.serialize(desc.parentSessionId, out, version);
    }
    UUIDSerializer.serializer.serialize(desc.sessionId, out, version);
    out.writeUTF(desc.keyspace);
    out.writeUTF(desc.columnFamily);
    MessagingService.validatePartitioner(desc.ranges);
    out.writeInt(desc.ranges.size());
    for (Range<Token> rt : desc.ranges)
        AbstractBounds.tokenSerializer.serialize(rt, out, version);
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:17,代码来源:RepairJobDesc.java


示例8: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public RepairJobDesc deserialize(DataInputPlus in, int version) throws IOException
{
    UUID parentSessionId = null;
    if (version >= MessagingService.VERSION_21)
    {
        if (in.readBoolean())
            parentSessionId = UUIDSerializer.serializer.deserialize(in, version);
    }
    UUID sessionId = UUIDSerializer.serializer.deserialize(in, version);
    String keyspace = in.readUTF();
    String columnFamily = in.readUTF();

    int nRanges = in.readInt();
    Collection<Range<Token>> ranges = new ArrayList<>();
    Range<Token> range;

    for (int i = 0; i < nRanges; i++)
    {
        range = (Range<Token>) AbstractBounds.tokenSerializer.deserialize(in,
                MessagingService.globalPartitioner(), version);
        ranges.add(range);
    }

    return new RepairJobDesc(parentSessionId, sessionId, keyspace, columnFamily, ranges);
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:26,代码来源:RepairJobDesc.java


示例9: serializedSize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public long serializedSize(RepairJobDesc desc, int version)
{
    int size = 0;
    if (version >= MessagingService.VERSION_21)
    {
        size += TypeSizes.sizeof(desc.parentSessionId != null);
        if (desc.parentSessionId != null)
            size += UUIDSerializer.serializer.serializedSize(desc.parentSessionId, version);
    }
    size += UUIDSerializer.serializer.serializedSize(desc.sessionId, version);
    size += TypeSizes.sizeof(desc.keyspace);
    size += TypeSizes.sizeof(desc.columnFamily);
    size += TypeSizes.sizeof(desc.ranges.size());
    for (Range<Token> rt : desc.ranges)
    {
        size += AbstractBounds.tokenSerializer.serializedSize(rt, version);
    }
    return size;
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:20,代码来源:RepairJobDesc.java


示例10: serialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public void serialize(PrepareMessage message, DataOutputPlus out, int version) throws IOException
{
    out.writeInt(message.cfIds.size());
    for (UUID cfId : message.cfIds)
        UUIDSerializer.serializer.serialize(cfId, out, version);
    UUIDSerializer.serializer.serialize(message.parentRepairSession, out, version);
    out.writeInt(message.ranges.size());
    for (Range<Token> r : message.ranges)
    {
        MessagingService.validatePartitioner(r);
        Range.tokenSerializer.serialize(r, out, version);
    }
    out.writeBoolean(message.isIncremental);
    out.writeLong(message.timestamp);
    out.writeBoolean(message.isGlobal);
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:17,代码来源:PrepareMessage.java


示例11: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public PrepareMessage deserialize(DataInputPlus in, int version) throws IOException
{
    int cfIdCount = in.readInt();
    List<UUID> cfIds = new ArrayList<>(cfIdCount);
    for (int i = 0; i < cfIdCount; i++)
        cfIds.add(UUIDSerializer.serializer.deserialize(in, version));
    UUID parentRepairSession = UUIDSerializer.serializer.deserialize(in, version);
    int rangeCount = in.readInt();
    List<Range<Token>> ranges = new ArrayList<>(rangeCount);
    for (int i = 0; i < rangeCount; i++)
        ranges.add((Range<Token>) Range.tokenSerializer.deserialize(in, MessagingService.globalPartitioner(), version));
    boolean isIncremental = in.readBoolean();
    long timestamp = in.readLong();
    boolean isGlobal = in.readBoolean();
    return new PrepareMessage(parentRepairSession, cfIds, ranges, isIncremental, timestamp, isGlobal);
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:17,代码来源:PrepareMessage.java


示例12: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public FileMessageHeader deserialize(DataInputPlus in, int version) throws IOException
{
    UUID cfId = UUIDSerializer.serializer.deserialize(in, MessagingService.current_version);
    int sequenceNumber = in.readInt();
    Version sstableVersion = DatabaseDescriptor.getSSTableFormat().info.getVersion(in.readUTF());

    SSTableFormat.Type format = SSTableFormat.Type.LEGACY;
    if (version >= StreamMessage.VERSION_22)
        format = SSTableFormat.Type.validate(in.readUTF());

    long estimatedKeys = in.readLong();
    int count = in.readInt();
    List<Pair<Long, Long>> sections = new ArrayList<>(count);
    for (int k = 0; k < count; k++)
        sections.add(Pair.create(in.readLong(), in.readLong()));
    CompressionInfo compressionInfo = CompressionInfo.serializer.deserialize(in, MessagingService.current_version);
    long repairedAt = in.readLong();
    int sstableLevel = in.readInt();
    SerializationHeader.Component header = version >= StreamMessage.VERSION_30 && sstableVersion.storeRows()
                                         ? SerializationHeader.serializer.deserialize(sstableVersion, in)
                                         : null;

    return new FileMessageHeader(cfId, sequenceNumber, sstableVersion, format, estimatedKeys, sections, compressionInfo, repairedAt, sstableLevel, header);
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:25,代码来源:FileMessageHeader.java


示例13: serializedSize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public long serializedSize(FileMessageHeader header, int version)
{
    long size = UUIDSerializer.serializer.serializedSize(header.cfId, version);
    size += TypeSizes.sizeof(header.sequenceNumber);
    size += TypeSizes.sizeof(header.version.toString());

    if (version >= StreamMessage.VERSION_22)
        size += TypeSizes.sizeof(header.format.name);

    size += TypeSizes.sizeof(header.estimatedKeys);

    size += TypeSizes.sizeof(header.sections.size());
    for (Pair<Long, Long> section : header.sections)
    {
        size += TypeSizes.sizeof(section.left);
        size += TypeSizes.sizeof(section.right);
    }
    size += CompressionInfo.serializer.serializedSize(header.compressionInfo, version);
    size += TypeSizes.sizeof(header.sstableLevel);

    if (version >= StreamMessage.VERSION_30)
        size += SerializationHeader.serializer.serializedSize(header.version, header.header);

    return size;
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:26,代码来源:FileMessageHeader.java


示例14: serialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public void serialize(StreamRequest srm, DataOutput dos, int version) throws IOException
{
    UUIDSerializer.serializer.serialize(srm.sessionId, dos, MessagingService.current_version);
    CompactEndpointSerializationHelper.serialize(srm.target, dos);
    if (srm.file != null)
    {
        dos.writeBoolean(true);
        PendingFile.serializer.serialize(srm.file, dos, version);
    }
    else
    {
        dos.writeBoolean(false);
        dos.writeUTF(srm.table);
        dos.writeInt(srm.ranges.size());
        for (Range<Token> range : srm.ranges)
            AbstractBounds.serializer.serialize(range, dos, version);

        dos.writeUTF(srm.type.name());

        dos.writeInt(Iterables.size(srm.columnFamilies));
        for (ColumnFamilyStore cfs : srm.columnFamilies)
            ColumnFamily.serializer.serializeCfId(cfs.metadata.cfId, dos, version);
    }
}
 
开发者ID:jackliu8722,项目名称:cassandra-1.2.16,代码行数:25,代码来源:StreamRequest.java


示例15: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public CFMetaData deserialize(DataInputPlus in, int version) throws IOException
{
    UUID cfId = UUIDSerializer.serializer.deserialize(in, version);
    CFMetaData metadata = Schema.instance.getCFMetaData(cfId);
    if (metadata == null)
    {
        String message = String.format("Couldn't find table for cfId %s. If a table was just " +
                "created, this is likely due to the schema not being fully propagated.  Please wait for schema " +
                "agreement on table creation.", cfId);
        throw new UnknownColumnFamilyException(message, cfId);
    }

    return metadata;
}
 
开发者ID:Netflix,项目名称:sstable-adaptor,代码行数:15,代码来源:CFMetaData.java


示例16: serialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public void serialize(PrepareResponse response, DataOutputPlus out, int version) throws IOException
{
    out.writeBoolean(response.promised);
    ByteBufferUtil.writeWithShortLength(response.inProgressCommit.key, out);
    UUIDSerializer.serializer.serialize(response.inProgressCommit.ballot, out, version);
    ColumnFamily.serializer.serialize(response.inProgressCommit.update, out, version);
    UUIDSerializer.serializer.serialize(response.mostRecentCommit.ballot, out, version);
    ColumnFamily.serializer.serialize(response.mostRecentCommit.update, out, version);
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:10,代码来源:PrepareResponse.java


示例17: serializedSize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public long serializedSize(PrepareResponse response, int version)
{
    return 1
           + 2 + response.inProgressCommit.key.remaining()
           + UUIDSerializer.serializer.serializedSize(response.inProgressCommit.ballot, version)
           + ColumnFamily.serializer.serializedSize(response.inProgressCommit.update, version)
           + UUIDSerializer.serializer.serializedSize(response.mostRecentCommit.ballot, version)
           + ColumnFamily.serializer.serializedSize(response.mostRecentCommit.update, version);
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:10,代码来源:PrepareResponse.java


示例18: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public Commit deserialize(DataInput in, int version) throws IOException
{
    return new Commit(ByteBufferUtil.readWithShortLength(in),
                      UUIDSerializer.serializer.deserialize(in, version),
                      ColumnFamily.serializer.deserialize(in,
                                                          ArrayBackedSortedColumns.factory,
                                                          ColumnSerializer.Flag.LOCAL,
                                                          version));
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:10,代码来源:Commit.java


示例19: serialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public void serialize(RepairJobDesc desc, DataOutputPlus out, int version) throws IOException
{
    if (version >= MessagingService.VERSION_21)
    {
        out.writeBoolean(desc.parentSessionId != null);
        if (desc.parentSessionId != null)
            UUIDSerializer.serializer.serialize(desc.parentSessionId, out, version);
    }
    UUIDSerializer.serializer.serialize(desc.sessionId, out, version);
    out.writeUTF(desc.keyspace);
    out.writeUTF(desc.columnFamily);
    AbstractBounds.serializer.serialize(desc.range, out, version);
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:14,代码来源:RepairJobDesc.java


示例20: deserialize

import org.apache.cassandra.utils.UUIDSerializer; //导入依赖的package包/类
public RepairJobDesc deserialize(DataInput in, int version) throws IOException
{
    UUID parentSessionId = null;
    if (version >= MessagingService.VERSION_21)
    {
        if (in.readBoolean())
            parentSessionId = UUIDSerializer.serializer.deserialize(in, version);
    }
    UUID sessionId = UUIDSerializer.serializer.deserialize(in, version);
    String keyspace = in.readUTF();
    String columnFamily = in.readUTF();
    Range<Token> range = (Range<Token>)AbstractBounds.serializer.deserialize(in, version);
    return new RepairJobDesc(parentSessionId, sessionId, keyspace, columnFamily, range);
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:15,代码来源:RepairJobDesc.java



注:本文中的org.apache.cassandra.utils.UUIDSerializer类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java AbstractWebScript类代码示例发布时间:2022-05-22
下一篇:
Java PsiAnonymousClass类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap