org.elasticsearch.common.unit.TimeValue.getStringRep()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.8k)|赞(0)|评价(0)|浏览(167)

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

TimeValue.getStringRep介绍

暂无

代码示例

代码示例来源:origin: spring-projects/spring-data-elasticsearch

Params putParam(String key, TimeValue value) {
  if (value != null) {
    return putParam(key, value.getStringRep());
  }
  return this;
}

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

/**
 * Sets a time value setting with the provided setting key and value.
 *
 * @param key  The setting key
 * @param timeValue The setting timeValue
 * @return The builder
 */
public Builder put(final String key, final TimeValue timeValue) {
  return put(key, timeValue.getStringRep());
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  return builder.field(NAME, value.getStringRep());
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field("scroll_id", scrollId);
  if (scroll != null) {
    builder.field("scroll", scroll.keepAlive().getStringRep());
  }
  builder.endObject();
  return builder;
}

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

public static Setting<TimeValue> timeSetting(String key, TimeValue defaultValue, Property... properties) {
  return new Setting<>(key, (s) -> defaultValue.getStringRep(), (s) -> TimeValue.parseTimeValue(s, key), properties);
}

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

public static Setting<TimeValue> timeSetting(
    final String key, Function<Settings, TimeValue> defaultValue, final TimeValue minValue, final Property... properties) {
  final SimpleKey simpleKey = new SimpleKey(key);
  return new Setting<>(simpleKey, s -> defaultValue.apply(s).getStringRep(), minTimeValueParser(key, minValue), properties);
}

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

private static Function<String, TimeValue> minTimeValueParser(final String key, final TimeValue minValue) {
  return s -> {
    final TimeValue value = TimeValue.parseTimeValue(s, null, key);
    if (value.millis() < minValue.millis()) {
      final String message = String.format(
          Locale.ROOT,
          "failed to parse value [%s] for setting [%s], must be >= [%s]",
          s,
          key,
          minValue.getStringRep());
      throw new IllegalArgumentException(message);
    }
    return value;
  };
}

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

@Override
  public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
    builder.startObject();
    if (username != null) {
      builder.field("username", username);
    }
    if (password != null) {
      builder.field("password", password);
    }
    builder.field("host", scheme + "://" + host + ":" + port +
      (pathPrefix == null ? "" : "/" + pathPrefix));
    if (headers.size() >0 ) {
      builder.field("headers", headers);
    }
    builder.field("socket_timeout", socketTimeout.getStringRep());
    builder.field("connect_timeout", connectTimeout.getStringRep());
    builder.field("query", query);
    builder.endObject();
    return builder;
  }
}

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

final TimeoutException e = new TimeoutException(timeout.getStringRep());
logger.trace("global checkpoint listener timed out", e);
executor.execute(() -> notifyListener(listener, UNASSIGNED_SEQ_NO, e));

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

Params putParam(String key, TimeValue value) {
  if (value != null) {
    return putParam(key, value.getStringRep());
  }
  return this;
}

代码示例来源:origin: com.qiniu/qiniu-pandora-sdk

Params putParam(String key, TimeValue value) {
  if (value != null) {
    return putParam(key, value.getStringRep());
  }
  return this;
}

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

builder.field(TIMEOUT_FIELD.getPreferredName(), timeout.getStringRep());

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field("scroll_id", scrollId);
  if (scroll != null) {
    builder.field("scroll", scroll.keepAlive().getStringRep());
  }
  builder.endObject();
  return builder;
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field("scroll_id", scrollId);
  if (scroll != null) {
    builder.field("scroll", scroll.keepAlive().getStringRep());
  }
  builder.endObject();
  return builder;
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

@Override
public XContentBuilder toXContent(XContentBuilder builder, ToXContent.Params params) throws IOException {
  builder.startObject();
  builder.field(Job.ID.getPreferredName(), jobId);
  if (duration != null) {
    builder.field(DURATION.getPreferredName(), duration.getStringRep());
  }
  if (expiresIn != null) {
    builder.field(EXPIRES_IN.getPreferredName(), expiresIn.getStringRep());
  }
  builder.endObject();
  return builder;
}

代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

public static Setting<TimeValue> timeSetting(
    final String key, Function<Settings, TimeValue> defaultValue, final TimeValue minValue, final Property... properties) {
  final SimpleKey simpleKey = new SimpleKey(key);
  return new Setting<>(simpleKey, s -> defaultValue.apply(s).getStringRep(), minTimeValueParser(key, minValue), properties);
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field(Job.ID.getPreferredName(), jobId);
  if (timeout != null) {
    builder.field(TIMEOUT.getPreferredName(), timeout.getStringRep());
  }
  builder.endObject();
  return builder;
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field(ENABLED.getPreferredName(), enabled);
  if (checkWindow != null) {
    builder.field(CHECK_WINDOW.getPreferredName(), checkWindow.getStringRep());
  }
  builder.endObject();
  return builder;
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field(MODE_FIELD.getPreferredName(), mode);
  if (timeSpan != null) {
    builder.field(TIME_SPAN_FIELD.getPreferredName(), timeSpan.getStringRep());
  }
  builder.endObject();
  return builder;
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field(MIN_AGE.getPreferredName(), minimumAge.getStringRep());
  builder.field(ACTIONS_FIELD.getPreferredName(), actions);
  builder.endObject();
  return builder;
}

相关文章