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

TimeValue.readTimeValue介绍

暂无

代码示例

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

/**
 * Reads the timeout value
 */
protected void readTimeout(StreamInput in) throws IOException {
  timeout = readTimeValue(in);
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  if (in.readBoolean()) {
    keepAlive = readTimeValue(in);
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  masterNodeTimeout = TimeValue.readTimeValue(in);
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  indices = in.readStringArray();
  indicesOptions = IndicesOptions.readIndicesOptions(in);
  timeout = readTimeValue(in);
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  id = in.readInt();
  timeout = readTimeValue(in);
  pingResponse = readPingResponse(in);
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  nodesIds = in.readStringArray();
  if (in.readBoolean()) {
    timeout = TimeValue.readTimeValue(in);
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  took = TimeValue.readTimeValue(in);
  status = new BulkByScrollTask.Status(in);
  int indexingFailuresCount = in.readVInt();
  List<Failure> indexingFailures = new ArrayList<>(indexingFailuresCount);
  for (int i = 0; i < indexingFailuresCount; i++) {
    indexingFailures.add(Failure.PROTOTYPE.readFrom(in));
  }
  this.indexingFailures = unmodifiableList(indexingFailures);
  int searchFailuresCount = in.readVInt();
  List<ShardSearchFailure> searchFailures = new ArrayList<>(searchFailuresCount);
  for (int i = 0; i < searchFailuresCount; i++) {
    searchFailures.add(readShardSearchFailure(in));
  }
  this.searchFailures = unmodifiableList(searchFailures);
  this.timedOut = in.readBoolean();
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  took = TimeValue.readTimeValue(in);
  status = new BulkByScrollTask.Status(in);
  int indexingFailuresCount = in.readVInt();
  List<Failure> indexingFailures = new ArrayList<>(indexingFailuresCount);
  for (int i = 0; i < indexingFailuresCount; i++) {
    indexingFailures.add(Failure.PROTOTYPE.readFrom(in));
  }
  this.indexingFailures = unmodifiableList(indexingFailures);
  int searchFailuresCount = in.readVInt();
  List<ShardSearchFailure> searchFailures = new ArrayList<>(searchFailuresCount);
  for (int i = 0; i < searchFailuresCount; i++) {
    searchFailures.add(readShardSearchFailure(in));
  }
  this.searchFailures = unmodifiableList(searchFailures);
  this.timedOut = in.readBoolean();
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  index = in.readString();
  shardId = in.readInt();
  timeout = TimeValue.readTimeValue(in);
  concreteIndex = in.readOptionalString();
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  threads = in.readInt();
  ignoreIdleThreads = in.readBoolean();
  type = in.readString();
  interval = TimeValue.readTimeValue(in);
  snapshots = in.readInt();
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  taskId = new TaskId(in);
  parentTaskId = new TaskId(in);
  nodesIds = in.readStringArray();
  actions = in.readStringArray();
  if (in.readBoolean()) {
    timeout = TimeValue.readTimeValue(in);
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  searchRequest = new SearchRequest();
  searchRequest.readFrom(in);
  abortOnVersionConflict = in.readBoolean();
  size = in.readVInt();
  refresh = in.readBoolean();
  timeout = TimeValue.readTimeValue(in);
  consistency = WriteConsistencyLevel.fromId(in.readByte());
  retryBackoffInitialTime = TimeValue.readTimeValue(in);
  maxRetries = in.readVInt();
  if (in.getVersion().onOrAfter(Version.V_2_4_0)) {
    requestsPerSecond = in.readFloat();
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  searchRequest = new SearchRequest();
  searchRequest.readFrom(in);
  abortOnVersionConflict = in.readBoolean();
  size = in.readVInt();
  refresh = in.readBoolean();
  timeout = TimeValue.readTimeValue(in);
  consistency = WriteConsistencyLevel.fromId(in.readByte());
  retryBackoffInitialTime = TimeValue.readTimeValue(in);
  maxRetries = in.readVInt();
  if (in.getVersion().onOrAfter(Version.V_2_4_0)) {
    requestsPerSecond = in.readFloat();
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  consistencyLevel = WriteConsistencyLevel.fromId(in.readByte());
  int size = in.readVInt();
  for (int i = 0; i < size; i++) {
    byte type = in.readByte();
    if (type == 0) {
      IndexRequest request = new IndexRequest();
      request.readFrom(in);
      requests.add(request);
    } else if (type == 1) {
      DeleteRequest request = new DeleteRequest();
      request.readFrom(in);
      requests.add(request);
    } else if (type == 2) {
      UpdateRequest request = new UpdateRequest();
      request.readFrom(in);
      requests.add(request);
    }
  }
  refresh = in.readBoolean();
  timeout = TimeValue.readTimeValue(in);
}

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

public Status(StreamInput in) throws IOException {
  total = in.readVLong();
  updated = in.readVLong();
  created = in.readVLong();
  deleted = in.readVLong();
  batches = in.readVInt();
  versionConflicts = in.readVLong();
  noops = in.readVLong();
  retries = in.readVLong();
  if (in.getVersion().onOrAfter(Version.V_2_4_0)) {
    throttled = TimeValue.readTimeValue(in);
    requestsPerSecond = in.readFloat();
  } else {
    throttled = timeValueNanos(0);
    requestsPerSecond = Float.POSITIVE_INFINITY;
  }
  reasonCancelled = in.readOptionalString();
  if (in.getVersion().onOrAfter(Version.V_2_4_0)) {
    throttledUntil = TimeValue.readTimeValue(in);
  } else {
    throttledUntil = timeValueNanos(0);
  }
}

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

public Status(StreamInput in) throws IOException {
  total = in.readVLong();
  updated = in.readVLong();
  created = in.readVLong();
  deleted = in.readVLong();
  batches = in.readVInt();
  versionConflicts = in.readVLong();
  noops = in.readVLong();
  retries = in.readVLong();
  if (in.getVersion().onOrAfter(Version.V_2_4_0)) {
    throttled = TimeValue.readTimeValue(in);
    requestsPerSecond = in.readFloat();
  } else {
    throttled = timeValueNanos(0);
    requestsPerSecond = Float.POSITIVE_INFINITY;
  }
  reasonCancelled = in.readOptionalString();
  if (in.getVersion().onOrAfter(Version.V_2_4_0)) {
    throttledUntil = TimeValue.readTimeValue(in);
  } else {
    throttledUntil = timeValueNanos(0);
  }
}

代码示例来源：origin: org.elasticsearch.plugin/delete-by-query

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  indices = in.readStringArray();
  indicesOptions = IndicesOptions.readIndicesOptions(in);
  types = in.readStringArray();
  source = in.readBytesReference();
  routing = in.readOptionalString();
  size = in.readVInt();
  if (in.readBoolean()) {
    scroll = readScroll(in);
  }
  if (in.readBoolean()) {
    timeout = TimeValue.readTimeValue(in);
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  if (in.readBoolean()) {
    shardId = ShardId.readShardId(in);
  } else {
    shardId = null;
  }
  consistencyLevel = WriteConsistencyLevel.fromId(in.readByte());
  timeout = TimeValue.readTimeValue(in);
  index = in.readString();
  canHaveDuplicates = in.readBoolean();
  // no need to serialize threaded* parameters, since they only matter locally
  if (in.getVersion().onOrAfter(Version.V_2_4_0)) {
    routedBasedOnClusterVersion = in.readVLong();
  }
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  name = in.readString();
  type = ThreadPoolType.fromType(in.readString());
  min = in.readInt();
  max = in.readInt();
  if (in.readBoolean()) {
    keepAlive = TimeValue.readTimeValue(in);
  }
  if (in.readBoolean()) {
    queueSize = SizeValue.readSizeValue(in);
  }
  in.readBoolean(); // here to conform with removed waitTime
  in.readBoolean(); // here to conform with removed rejected setting
  in.readBoolean(); // here to conform with queue type
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  int size = in.readVInt();
  if (size == 0) {
    indices = Strings.EMPTY_ARRAY;
  } else {
    indices = new String[size];
    for (int i = 0; i < indices.length; i++) {
      indices[i] = in.readString();
    }
  }
  timeout = readTimeValue(in);
  if (in.readBoolean()) {
    waitForStatus = ClusterHealthStatus.fromValue(in.readByte());
  }
  waitForRelocatingShards = in.readInt();
  waitForActiveShards = in.readInt();
  waitForNodes = in.readString();
  if (in.readBoolean()) {
    waitForEvents = Priority.readFrom(in);
  }
}