org.elasticsearch.transport.TransportService.submitRequest()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(9.9k)|赞(0)|评价(0)|浏览(133)

本文整理了Java中org.elasticsearch.transport.TransportService.submitRequest()方法的一些代码示例，展示了TransportService.submitRequest()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TransportService.submitRequest()方法的具体详情如下：
包路径：org.elasticsearch.transport.TransportService
类名称：TransportService
方法名：submitRequest

TransportService.submitRequest介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

public <T extends TransportResponse> TransportFuture<T> submitRequest(DiscoveryNode node, String action, TransportRequest request,
                                   TransportResponseHandler<T> handler) throws TransportException {
  return submitRequest(node, action, request, TransportRequestOptions.EMPTY, handler);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public long indexTranslogOperations(List<Translog.Operation> operations, int totalTranslogOps,
                  long maxSeenAutoIdTimestampOnPrimary, long maxSeqNoOfDeletesOrUpdatesOnPrimary) {
  final RecoveryTranslogOperationsRequest translogOperationsRequest = new RecoveryTranslogOperationsRequest(
    recoveryId, shardId, operations, totalTranslogOps, maxSeenAutoIdTimestampOnPrimary, maxSeqNoOfDeletesOrUpdatesOnPrimary);
  final TransportFuture<RecoveryTranslogOperationsResponse> future = transportService.submitRequest(
      targetNode,
      PeerRecoveryTargetService.Actions.TRANSLOG_OPS,
      translogOperationsRequest,
      translogOpsRequestOptions,
      RecoveryTranslogOperationsResponse.HANDLER);
  return future.txGet().localCheckpoint;
}

代码示例来源：origin: org.elasticsearch/elasticsearch

/**
 * Validates the join request, throwing a failure if it failed.
 */
public void sendValidateJoinRequestBlocking(DiscoveryNode node, ClusterState state, TimeValue timeout) {
  transportService.submitRequest(node, DISCOVERY_JOIN_VALIDATE_ACTION_NAME, new ValidateJoinRequest(state),
    EmptyTransportResponseHandler.INSTANCE_SAME).txGet(timeout.millis(), TimeUnit.MILLISECONDS);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public void sendLeaveRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, TimeValue timeout) {
  transportService.submitRequest(masterNode, DISCOVERY_LEAVE_ACTION_NAME, new LeaveRequest(node),
    EmptyTransportResponseHandler.INSTANCE_SAME).txGet(timeout.millis(), TimeUnit.MILLISECONDS);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

public void sendJoinRequestBlocking(DiscoveryNode masterNode, DiscoveryNode node, TimeValue timeout) {
  transportService.submitRequest(masterNode, DISCOVERY_JOIN_ACTION_NAME, new JoinRequest(node),
    EmptyTransportResponseHandler.INSTANCE_SAME).txGet(timeout.millis(), TimeUnit.MILLISECONDS);
}

代码示例来源：origin: org.elasticsearch/elasticsearch

transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.FILE_CHUNK,
  new RecoveryFileChunkRequest(recoveryId, shardId, fileMetaData, position, content, lastChunk,
    totalTranslogOps,

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void ensureClusterStateVersion(long clusterStateVersion) {
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.WAIT_CLUSTERSTATE,
    new RecoveryWaitForClusterStateRequest(recoveryId, shardId, clusterStateVersion),
    TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionLongTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void receiveFileInfo(List<String> phase1FileNames, List<Long> phase1FileSizes, List<String> phase1ExistingFileNames,
              List<Long> phase1ExistingFileSizes, int totalTranslogOps) {
  RecoveryFilesInfoRequest recoveryInfoFilesRequest = new RecoveryFilesInfoRequest(recoveryId, shardId,
      phase1FileNames, phase1FileSizes, phase1ExistingFileNames, phase1ExistingFileSizes, totalTranslogOps);
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.FILES_INFO, recoveryInfoFilesRequest,
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void prepareForTranslogOperations(boolean fileBasedRecovery, int totalTranslogOps) throws IOException {
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.PREPARE_TRANSLOG,
      new RecoveryPrepareForTranslogOperationsRequest(recoveryId, shardId, totalTranslogOps, fileBasedRecovery),
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void finalizeRecovery(final long globalCheckpoint) {
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.FINALIZE,
    new RecoveryFinalizeRecoveryRequest(recoveryId, shardId, globalCheckpoint),
    TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionLongTimeout()).build(),
    EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void handoffPrimaryContext(final ReplicationTracker.PrimaryContext primaryContext) {
  transportService.submitRequest(
      targetNode,
      PeerRecoveryTargetService.Actions.HANDOFF_PRIMARY_CONTEXT,
      new RecoveryHandoffPrimaryContextRequest(recoveryId, shardId, primaryContext),
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public void cleanFiles(int totalTranslogOps, Store.MetadataSnapshot sourceMetaData) throws IOException {
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.CLEAN_FILES,
      new RecoveryCleanFilesRequest(recoveryId, shardId, sourceMetaData, totalTranslogOps),
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: org.elasticsearch/elasticsearch

final AtomicReference<RecoveryResponse> responseHolder = new AtomicReference<>();
cancellableThreads.execute(() -> responseHolder.set(
    transportService.submitRequest(request.sourceNode(), PeerRecoverySourceService.Actions.START_RECOVERY, request,
        new FutureTransportResponseHandler<RecoveryResponse>() {
          @Override

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
public void receiveFileInfo(List<String> phase1FileNames, List<Long> phase1FileSizes, List<String> phase1ExistingFileNames,
              List<Long> phase1ExistingFileSizes, int totalTranslogOps) {
  RecoveryFilesInfoRequest recoveryInfoFilesRequest = new RecoveryFilesInfoRequest(recoveryId, shardId,
      phase1FileNames, phase1FileSizes, phase1ExistingFileNames, phase1ExistingFileSizes, totalTranslogOps);
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.FILES_INFO, recoveryInfoFilesRequest,
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public void prepareForTranslogOperations(boolean fileBasedRecovery, int totalTranslogOps) throws IOException {
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.PREPARE_TRANSLOG,
      new RecoveryPrepareForTranslogOperationsRequest(recoveryId, shardId, totalTranslogOps, fileBasedRecovery),
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public void handoffPrimaryContext(final ReplicationTracker.PrimaryContext primaryContext) {
  transportService.submitRequest(
      targetNode,
      PeerRecoveryTargetService.Actions.HANDOFF_PRIMARY_CONTEXT,
      new RecoveryHandoffPrimaryContextRequest(recoveryId, shardId, primaryContext),
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public void receiveFileInfo(List<String> phase1FileNames, List<Long> phase1FileSizes, List<String> phase1ExistingFileNames,
              List<Long> phase1ExistingFileSizes, int totalTranslogOps) {
  RecoveryFilesInfoRequest recoveryInfoFilesRequest = new RecoveryFilesInfoRequest(recoveryId, shardId,
      phase1FileNames, phase1FileSizes, phase1ExistingFileNames, phase1ExistingFileSizes, totalTranslogOps);
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.FILES_INFO, recoveryInfoFilesRequest,
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: harbby/presto-connectors

@Override
  public void run() throws InterruptedException {
    final RecoveryTranslogOperationsRequest translogOperationsRequest = new RecoveryTranslogOperationsRequest(
        request.recoveryId(), request.shardId(), operations, snapshot.estimatedTotalOperations());
    transportService.submitRequest(request.targetNode(), RecoveryTarget.Actions.TRANSLOG_OPS, translogOperationsRequest,
        recoveryOptions, EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
  }
});

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
public void prepareForTranslogOperations(int totalTranslogOps, long maxUnsafeAutoIdTimestamp) throws IOException {
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.PREPARE_TRANSLOG,
      new RecoveryPrepareForTranslogOperationsRequest(recoveryId, shardId, totalTranslogOps, maxUnsafeAutoIdTimestamp),
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
public void cleanFiles(int totalTranslogOps, Store.MetadataSnapshot sourceMetaData) throws IOException {
  transportService.submitRequest(targetNode, PeerRecoveryTargetService.Actions.CLEAN_FILES,
      new RecoveryCleanFilesRequest(recoveryId, shardId, sourceMetaData, totalTranslogOps),
      TransportRequestOptions.builder().withTimeout(recoverySettings.internalActionTimeout()).build(),
      EmptyTransportResponseHandler.INSTANCE_SAME).txGet();
}

内容来源于网络，如有侵权，请联系作者删除！

TransportService

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    TransportService类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com