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

Java WriteType类代码示例

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

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



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

示例1: DatacenterSyncWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public DatacenterSyncWriteResponseHandler(Collection<InetAddress> naturalEndpoints,
                                          Collection<InetAddress> pendingEndpoints,
                                          ConsistencyLevel consistencyLevel,
                                          Keyspace keyspace,
                                          Runnable callback,
                                          WriteType writeType)
{
    // Response is been managed by the map so make it 1 for the superclass.
    super(keyspace, naturalEndpoints, pendingEndpoints, consistencyLevel, callback, writeType);
    assert consistencyLevel == ConsistencyLevel.EACH_QUORUM;

    strategy = (NetworkTopologyStrategy) keyspace.getReplicationStrategy();

    for (String dc : strategy.getDatacenters())
    {
        int rf = strategy.getReplicationFactor(dc);
        responses.put(dc, new AtomicInteger((rf / 2) + 1));
    }

    // During bootstrap, we have to include the pending endpoints or we may fail the consistency level
    // guarantees (see #833)
    for (InetAddress pending : pendingEndpoints)
    {
        responses.get(snitch.getDatacenter(pending)).incrementAndGet();
    }
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:27,代码来源:DatacenterSyncWriteResponseHandler.java


示例2: AbstractWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
/**
 * @param callback A callback to be called when the write is successful.
 */
protected AbstractWriteResponseHandler(Keyspace keyspace,
                                       Collection<InetAddress> naturalEndpoints,
                                       Collection<InetAddress> pendingEndpoints,
                                       ConsistencyLevel consistencyLevel,
                                       Runnable callback,
                                       WriteType writeType)
{
    this.keyspace = keyspace;
    this.pendingEndpoints = pendingEndpoints;
    this.start = System.nanoTime();
    this.consistencyLevel = consistencyLevel;
    this.naturalEndpoints = naturalEndpoints;
    this.callback = callback;
    this.writeType = writeType;
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:19,代码来源:AbstractWriteResponseHandler.java


示例3: toThrift

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public static TimedOutException toThrift(RequestTimeoutException e)
{
    TimedOutException toe = new TimedOutException();
    if (e instanceof WriteTimeoutException)
    {
        WriteTimeoutException wte = (WriteTimeoutException)e;
        toe.setAcknowledged_by(wte.received);
        if (wte.writeType == WriteType.BATCH_LOG)
            toe.setAcknowledged_by_batchlog(false);
        else if (wte.writeType == WriteType.BATCH)
            toe.setAcknowledged_by_batchlog(true);
        else if (wte.writeType == WriteType.CAS)
            toe.setPaxos_in_progress(true);
    }
    return toe;
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:17,代码来源:ThriftConversion.java


示例4: AbstractWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
/**
 * @param pendingEndpoints
 * @param callback A callback to be called when the write is successful.
 */
protected AbstractWriteResponseHandler(Keyspace keyspace,
                                       Collection<InetAddress> naturalEndpoints,
                                       Collection<InetAddress> pendingEndpoints,
                                       ConsistencyLevel consistencyLevel,
                                       Runnable callback,
                                       WriteType writeType)
{
    this.keyspace = keyspace;
    this.pendingEndpoints = pendingEndpoints;
    this.start = System.nanoTime();
    this.consistencyLevel = consistencyLevel;
    this.naturalEndpoints = naturalEndpoints;
    this.callback = callback;
    this.writeType = writeType;
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:20,代码来源:AbstractWriteResponseHandler.java


示例5: getWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public <T> AbstractWriteResponseHandler<T> getWriteResponseHandler(Collection<InetAddress> naturalEndpoints,
                                                            Collection<InetAddress> pendingEndpoints,
                                                            ConsistencyLevel consistency_level,
                                                            Runnable callback,
                                                            WriteType writeType)
{
    if (consistency_level.isDatacenterLocal())
    {
        // block for in this context will be localnodes block.
        return new DatacenterWriteResponseHandler<T>(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
    }
    else if (consistency_level == ConsistencyLevel.EACH_QUORUM && (this instanceof NetworkTopologyStrategy))
    {
        return new DatacenterSyncWriteResponseHandler<T>(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
    }
    return new WriteResponseHandler<T>(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:18,代码来源:AbstractReplicationStrategy.java


示例6: DatacenterSyncWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public DatacenterSyncWriteResponseHandler(Collection<InetAddress> naturalEndpoints,
                                          Collection<InetAddress> pendingEndpoints,
                                          ConsistencyLevel consistencyLevel,
                                          Keyspace keyspace,
                                          Runnable callback,
                                          WriteType writeType)
{
    // Response is been managed by the map so make it 1 for the superclass.
    super(keyspace, naturalEndpoints, pendingEndpoints, consistencyLevel, callback, writeType);
    assert consistencyLevel == ConsistencyLevel.EACH_QUORUM;

    NetworkTopologyStrategy strategy = (NetworkTopologyStrategy) keyspace.getReplicationStrategy();

    for (String dc : strategy.getDatacenters())
    {
        int rf = strategy.getReplicationFactor(dc);
        responses.put(dc, new AtomicInteger((rf / 2) + 1));
    }

    // During bootstrap, we have to include the pending endpoints or we may fail the consistency level
    // guarantees (see #833)
    for (InetAddress pending : pendingEndpoints)
    {
        responses.get(snitch.getDatacenter(pending)).incrementAndGet();
    }
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:27,代码来源:DatacenterSyncWriteResponseHandler.java


示例7: DatacenterSyncWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public DatacenterSyncWriteResponseHandler(Collection<InetAddress> naturalEndpoints,
                                          Collection<InetAddress> pendingEndpoints,
                                          ConsistencyLevel consistencyLevel,
                                          Table table,
                                          Runnable callback,
                                          WriteType writeType)
{
    // Response is been managed by the map so make it 1 for the superclass.
    super(table, naturalEndpoints, pendingEndpoints, consistencyLevel, callback, writeType);
    assert consistencyLevel == ConsistencyLevel.EACH_QUORUM;

    strategy = (NetworkTopologyStrategy) table.getReplicationStrategy();

    for (String dc : strategy.getDatacenters())
    {
        int rf = strategy.getReplicationFactor(dc);
        responses.put(dc, new AtomicInteger((rf / 2) + 1));
    }

    // During bootstrap, we have to include the pending endpoints or we may fail the consistency level
    // guarantees (see #833)
    for (InetAddress pending : pendingEndpoints)
    {
        responses.get(snitch.getDatacenter(pending)).incrementAndGet();
    }
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:27,代码来源:DatacenterSyncWriteResponseHandler.java


示例8: AbstractWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
/**
 * @param pendingEndpoints
 * @param callback A callback to be called when the write is successful.
 */
protected AbstractWriteResponseHandler(Table table,
                                       Collection<InetAddress> naturalEndpoints,
                                       Collection<InetAddress> pendingEndpoints,
                                       ConsistencyLevel consistencyLevel,
                                       Runnable callback,
                                       WriteType writeType)
{
    this.table = table;
    this.pendingEndpoints = pendingEndpoints;
    this.startTime = System.currentTimeMillis();
    this.consistencyLevel = consistencyLevel;
    this.naturalEndpoints = naturalEndpoints;
    this.callback = callback;
    this.writeType = writeType;
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:20,代码来源:AbstractWriteResponseHandler.java


示例9: getWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public AbstractWriteResponseHandler getWriteResponseHandler(Collection<InetAddress> naturalEndpoints, Collection<InetAddress> pendingEndpoints, ConsistencyLevel consistency_level, Runnable callback, WriteType writeType)
{
    if (consistency_level.isDatacenterLocal())
    {
        // block for in this context will be localnodes block.
        return new DatacenterWriteResponseHandler(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
    }
    else if (consistency_level == ConsistencyLevel.EACH_QUORUM && (this instanceof NetworkTopologyStrategy))
    {
        return new DatacenterSyncWriteResponseHandler(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
    }
    return new WriteResponseHandler(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:14,代码来源:AbstractReplicationStrategy.java


示例10: DatacenterWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public DatacenterWriteResponseHandler(Collection<InetAddress> naturalEndpoints,
                                      Collection<InetAddress> pendingEndpoints,
                                      ConsistencyLevel consistencyLevel,
                                      Keyspace keyspace,
                                      Runnable callback,
                                      WriteType writeType)
{
    super(naturalEndpoints, pendingEndpoints, consistencyLevel, keyspace, callback, writeType);
    assert consistencyLevel.isDatacenterLocal();
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:11,代码来源:DatacenterWriteResponseHandler.java


示例11: await

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public void await() throws WriteTimeoutException
{
    try
    {
        if (!latch.await(DatabaseDescriptor.getWriteRpcTimeout(), TimeUnit.MILLISECONDS))
            throw new WriteTimeoutException(WriteType.CAS, consistency, getResponseCount(), targets);
    }
    catch (InterruptedException ex)
    {
        throw new AssertionError("This latch shouldn't have been interrupted.");
    }
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:13,代码来源:AbstractPaxosCallback.java


示例12: WriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public WriteResponseHandler(Collection<InetAddress> writeEndpoints,
                            Collection<InetAddress> pendingEndpoints,
                            ConsistencyLevel consistencyLevel,
                            Keyspace keyspace,
                            Runnable callback,
                            WriteType writeType)
{
    super(keyspace, writeEndpoints, pendingEndpoints, consistencyLevel, callback, writeType);
    responses = totalBlockFor();
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:11,代码来源:WriteResponseHandler.java


示例13: get

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public void get() throws WriteTimeoutException
{
    long requestTimeout = writeType == WriteType.COUNTER
                        ? DatabaseDescriptor.getCounterWriteRpcTimeout()
                        : DatabaseDescriptor.getWriteRpcTimeout();

    long timeout = TimeUnit.MILLISECONDS.toNanos(requestTimeout) - (System.nanoTime() - start);

    boolean success;
    try
    {
        success = condition.await(timeout, TimeUnit.NANOSECONDS);
    }
    catch (InterruptedException ex)
    {
        throw new AssertionError(ex);
    }

    if (!success)
    {
        int acks = ackCount();
        int blockedFor = totalBlockFor();
        // It's pretty unlikely, but we can race between exiting await above and here, so
        // that we could now have enough acks. In that case, we "lie" on the acks count to
        // avoid sending confusing info to the user (see CASSANDRA-6491).
        if (acks >= blockedFor)
            acks = blockedFor - 1;
        throw new WriteTimeoutException(writeType, consistencyLevel, acks, blockedFor);
    }
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:31,代码来源:AbstractWriteResponseHandler.java


示例14: getWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public AbstractWriteResponseHandler getWriteResponseHandler(Collection<InetAddress> naturalEndpoints, Collection<InetAddress> pendingEndpoints, ConsistencyLevel consistency_level, Runnable callback, WriteType writeType)
{
    if (consistency_level == ConsistencyLevel.LOCAL_QUORUM)
    {
        // block for in this context will be localnodes block.
        return new DatacenterWriteResponseHandler(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
    }
    else if (consistency_level == ConsistencyLevel.EACH_QUORUM)
    {
        return new DatacenterSyncWriteResponseHandler(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
    }
    return new WriteResponseHandler(naturalEndpoints, pendingEndpoints, consistency_level, getKeyspace(), callback, writeType);
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:14,代码来源:AbstractReplicationStrategy.java


示例15: DatacenterWriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public DatacenterWriteResponseHandler(Collection<InetAddress> naturalEndpoints,
                                      Collection<InetAddress> pendingEndpoints,
                                      ConsistencyLevel consistencyLevel,
                                      Keyspace keyspace,
                                      Runnable callback,
                                      WriteType writeType)
{
    super(naturalEndpoints, pendingEndpoints, consistencyLevel, keyspace, callback, writeType);
    assert consistencyLevel == ConsistencyLevel.LOCAL_QUORUM;
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:11,代码来源:DatacenterWriteResponseHandler.java


示例16: await

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public void await() throws WriteTimeoutException
{
    try
    {
        if (!latch.await(DatabaseDescriptor.getWriteRpcTimeout(), TimeUnit.MILLISECONDS))
            throw new WriteTimeoutException(WriteType.CAS, ConsistencyLevel.SERIAL, getResponseCount(), targets);
    }
    catch (InterruptedException ex)
    {
        throw new AssertionError("This latch shouldn't have been interrupted.");
    }
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:13,代码来源:AbstractPaxosCallback.java


示例17: WriteResponseHandler

import org.apache.cassandra.db.WriteType; //导入依赖的package包/类
public WriteResponseHandler(Collection<InetAddress> writeEndpoints,
                            Collection<InetAddress> pendingEndpoints,
                            ConsistencyLevel consistencyLevel,
                            Keyspace keyspace,
                            Runnable callback,
                            WriteType writeType)
{
    super(keyspace, writeEndpoints, pendingEndpoints, consistencyLevel, callback, writeType);
    responses = new AtomicInteger(totalBlockFor());
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:11,代码来源:WriteResponseHandler.java



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

专题导读
上一篇:
Java NoopTransducerTrainer类代码示例发布时间:2022-05-22
下一篇:
Java FinalizeLogSegmentResponseProto类代码示例发布时间: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