Java ValidationRequest类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: RepairJob

import org.apache.cassandra.repair.messages.ValidationRequest; //导入依赖的package包/类
/**
 * Create repair job to run on specific columnfamily
 */
public RepairJob(UUID sessionId, String keyspace, String columnFamily, Range<Token> range, boolean isSequential)
{
    this.desc = new RepairJobDesc(sessionId, keyspace, columnFamily, range);
    this.isSequential = isSequential;
    this.treeRequests = new RequestCoordinator<InetAddress>(isSequential)
    {
        public void send(InetAddress endpoint)
        {
            ValidationRequest request = new ValidationRequest(desc, gcBefore);
            MessagingService.instance().sendOneWay(request.createMessage(), endpoint);
        }
    };
    this.differencers = new RequestCoordinator<Differencer>(isSequential)
    {
        public void send(Differencer d)
        {
            StageManager.getStage(Stage.ANTI_ENTROPY).execute(d);
        }
    };
}

开发者ID:pgaref，项目名称:ACaZoo，代码行数:24，代码来源:RepairJob.java

示例2: doVerb

import org.apache.cassandra.repair.messages.ValidationRequest; //导入依赖的package包/类
public void doVerb(MessageIn<RepairMessage> message, int id)
{
    // TODO add cancel/interrupt message
    RepairJobDesc desc = message.payload.desc;
    switch (message.payload.messageType)
    {
        case VALIDATION_REQUEST:
            ValidationRequest validationRequest = (ValidationRequest) message.payload;
            // trigger read-only compaction
            ColumnFamilyStore store = Keyspace.open(desc.keyspace).getColumnFamilyStore(desc.columnFamily);
            Validator validator = new Validator(desc, message.from, validationRequest.gcBefore);
            CompactionManager.instance.submitValidation(store, validator);
            break;

        case SYNC_REQUEST:
            // forwarded sync request
            SyncRequest request = (SyncRequest) message.payload;
            StreamingRepairTask task = new StreamingRepairTask(desc, request);
            task.run();
            break;

        default:
            ActiveRepairService.instance.handleMessage(message.from, message.payload);
            break;
    }
}

开发者ID:pgaref，项目名称:ACaZoo，代码行数:27，代码来源:RepairMessageVerbHandler.java

示例3: RepairJob

import org.apache.cassandra.repair.messages.ValidationRequest; //导入依赖的package包/类
/**
 * Create repair job to run on specific columnfamily
 */
public RepairJob(IRepairJobEventListener listener,
                 UUID parentSessionId,
                 UUID sessionId,
                 String keyspace,
                 String columnFamily,
                 Range<Token> range,
                 boolean isSequential,
                 ListeningExecutorService taskExecutor)
{
    this.listener = listener;
    this.desc = new RepairJobDesc(parentSessionId, sessionId, keyspace, columnFamily, range);
    this.isSequential = isSequential;
    this.taskExecutor = taskExecutor;
    this.treeRequests = new RequestCoordinator<InetAddress>(isSequential)
    {
        public void send(InetAddress endpoint)
        {
            ValidationRequest request = new ValidationRequest(desc, gcBefore);
            MessagingService.instance().sendOneWay(request.createMessage(), endpoint);
        }
    };
}

开发者ID:daidong，项目名称:GraphTrek，代码行数:26，代码来源:RepairJob.java

示例4: RepairJob

import org.apache.cassandra.repair.messages.ValidationRequest; //导入依赖的package包/类
/**
 * Create repair job to run on specific columnfamily
 */
public RepairJob(IRepairJobEventListener listener,
                 UUID parentSessionId,
                 UUID sessionId,
                 String keyspace,
                 String columnFamily,
                 Range<Token> range,
                 RepairParallelism parallelismDegree,
                 ListeningExecutorService taskExecutor)
{
    this.listener = listener;
    this.desc = new RepairJobDesc(parentSessionId, sessionId, keyspace, columnFamily, range);
    this.parallelismDegree = parallelismDegree;
    this.taskExecutor = taskExecutor;

    IRequestProcessor<InetAddress> processor = new IRequestProcessor<InetAddress>()
    {
        @Override
        public void process(InetAddress endpoint)
        {
            ValidationRequest request = new ValidationRequest(desc, gcBefore);
            MessagingService.instance().sendOneWay(request.createMessage(), endpoint);
        }
    };

    switch (parallelismDegree)
    {
        case SEQUENTIAL:
            this.treeRequests = new SequentialRequestCoordinator<>(processor);
            break;
        case PARALLEL:
            this.treeRequests = new ParallelRequestCoordinator<>(processor);
            break;
        case DATACENTER_AWARE:
            this.treeRequests = new DatacenterAwareRequestCoordinator(processor);
            break;
        default:
            throw new AssertionError("Unknown degree of parallelism specified");
    }
}

开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:43，代码来源:RepairJob.java

示例5: RepairJob

import org.apache.cassandra.repair.messages.ValidationRequest; //导入依赖的package包/类
/**
 * Create repair job to run on specific columnfamily
 */
public RepairJob(UUID parentSessionId, UUID sessionId, String keyspace, String columnFamily, Range<Token> range, boolean isSequential, ListeningExecutorService taskExecutor)
{
    this.desc = new RepairJobDesc(parentSessionId, sessionId, keyspace, columnFamily, range);
    this.isSequential = isSequential;
    this.taskExecutor = taskExecutor;
    this.treeRequests = new RequestCoordinator<InetAddress>(isSequential)
    {
        public void send(InetAddress endpoint)
        {
            ValidationRequest request = new ValidationRequest(desc, gcBefore);
            MessagingService.instance().sendOneWay(request.createMessage(), endpoint);
        }
    };
}

开发者ID:rajath26，项目名称:cassandra-trunk，代码行数:18，代码来源:RepairJob.java

示例6: run

import org.apache.cassandra.repair.messages.ValidationRequest; //导入依赖的package包/类
/**
 * Send ValidationRequest to replica
 */
public void run()
{
    ValidationRequest request = new ValidationRequest(desc, gcBefore);
    MessagingService.instance().sendOneWay(request.createMessage(), endpoint);
}

开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:9，代码来源:ValidationTask.java

示例7: doVerb

import org.apache.cassandra.repair.messages.ValidationRequest; //导入依赖的package包/类
public void doVerb(MessageIn<RepairMessage> message, int id)
{
    // TODO add cancel/interrupt message
    RepairJobDesc desc = message.payload.desc;
    switch (message.payload.messageType)
    {
        case PREPARE_MESSAGE:
            PrepareMessage prepareMessage = (PrepareMessage) message.payload;
            List<ColumnFamilyStore> columnFamilyStores = new ArrayList<>(prepareMessage.cfIds.size());
            for (UUID cfId : prepareMessage.cfIds)
            {
                Pair<String, String> kscf = Schema.instance.getCF(cfId);
                ColumnFamilyStore columnFamilyStore = Keyspace.open(kscf.left).getColumnFamilyStore(kscf.right);
                columnFamilyStores.add(columnFamilyStore);
            }
            ActiveRepairService.instance.registerParentRepairSession(prepareMessage.parentRepairSession,
                                                                     columnFamilyStores,
                                                                     prepareMessage.ranges);
            MessagingService.instance().sendReply(new MessageOut(MessagingService.Verb.INTERNAL_RESPONSE), id, message.from);
            break;

        case VALIDATION_REQUEST:
            ValidationRequest validationRequest = (ValidationRequest) message.payload;
            // trigger read-only compaction
            ColumnFamilyStore store = Keyspace.open(desc.keyspace).getColumnFamilyStore(desc.columnFamily);

            Validator validator = new Validator(desc, message.from, validationRequest.gcBefore);
            CompactionManager.instance.submitValidation(store, validator);
            break;

        case SYNC_REQUEST:
            // forwarded sync request
            SyncRequest request = (SyncRequest) message.payload;
            StreamingRepairTask task = new StreamingRepairTask(desc, request);
            task.run();
            break;

        case ANTICOMPACTION_REQUEST:
            logger.debug("Got anticompaction request");
            AnticompactionRequest anticompactionRequest = (AnticompactionRequest) message.payload;
            try
            {
                List<Future<?>> futures = ActiveRepairService.instance.doAntiCompaction(anticompactionRequest.parentRepairSession);
                FBUtilities.waitOnFutures(futures);
            }
            catch (Exception e)
            {
                throw new RuntimeException(e);
            }

            break;

        default:
            ActiveRepairService.instance.handleMessage(message.from, message.payload);
            break;
    }
}

开发者ID:rajath26，项目名称:cassandra-trunk，代码行数:58，代码来源:RepairMessageVerbHandler.java

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