本文整理汇总了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；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论