org.elasticsearch.common.xcontent.XContentBuilder.timeField()方法的使用及代码示例

x33g5p2x  于2022-02-02 转载在 其他  
字(16.3k)|赞(0)|评价(0)|浏览(73)

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

XContentBuilder.timeField介绍

[英]Write a time-based field and value, if the passed timeValue is null a null value is written, otherwise a date transformers lookup is performed.
[中]写入基于时间的字段和值,如果传递的时间值为空,则写入空值,否则执行日期转换器查找。

代码示例

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

@Override
public XContentBuilder toXContent(final XContentBuilder builder, final Params params) throws IOException {
  builder.startObject();
  builder.field(INDEX_KEY);
  index.toXContent(builder, params);
  builder.timeField(DELETE_DATE_IN_MILLIS_KEY, DELETE_DATE_KEY, deleteDateInMillis);
  return builder.endObject();
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.field("node", taskId.getNodeId());
  builder.field("id", taskId.getId());
  builder.field("type", type);
  builder.field("action", action);
  if (status != null) {
    builder.field("status", status, params);
  }
  if (description != null) {
    builder.field("description", description);
  }
  builder.timeField("start_time_in_millis", "start_time", startTime);
  if (builder.humanReadable()) {
    builder.field("running_time", new TimeValue(runningTimeNanos, TimeUnit.NANOSECONDS).toString());
  }
  builder.field("running_time_in_nanos", runningTimeNanos);
  builder.field("cancellable", cancellable);
  if (parentTaskId.isSet()) {
    builder.field("parent_task_id", parentTaskId.toString());
  }
  builder.startObject("headers");
  for(Map.Entry<String, String> attribute : headers.entrySet()) {
    builder.field(attribute.getKey(), attribute.getValue());
  }
  builder.endObject();
  return builder;
}

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

builder.field(Fields.STAGE, stage.toString());
builder.field(Fields.PRIMARY, primary);
builder.timeField(Fields.START_TIME_IN_MILLIS, Fields.START_TIME, timer.startTime);
if (timer.stopTime > 0) {
  builder.timeField(Fields.STOP_TIME_IN_MILLIS, Fields.STOP_TIME, timer.stopTime);

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject(Fields.JVM);
  builder.field(Fields.PID, pid);
  builder.field(Fields.VERSION, version);
  builder.field(Fields.VM_NAME, vmName);
  builder.field(Fields.VM_VERSION, vmVersion);
  builder.field(Fields.VM_VENDOR, vmVendor);
  builder.timeField(Fields.START_TIME_IN_MILLIS, Fields.START_TIME, startTime);
  builder.startObject(Fields.MEM);
  builder.humanReadableField(Fields.HEAP_INIT_IN_BYTES, Fields.HEAP_INIT, new ByteSizeValue(mem.heapInit));
  builder.humanReadableField(Fields.HEAP_MAX_IN_BYTES, Fields.HEAP_MAX, new ByteSizeValue(mem.heapMax));
  builder.humanReadableField(Fields.NON_HEAP_INIT_IN_BYTES, Fields.NON_HEAP_INIT, new ByteSizeValue(mem.nonHeapInit));
  builder.humanReadableField(Fields.NON_HEAP_MAX_IN_BYTES, Fields.NON_HEAP_MAX, new ByteSizeValue(mem.nonHeapMax));
  builder.humanReadableField(Fields.DIRECT_MAX_IN_BYTES, Fields.DIRECT_MAX, new ByteSizeValue(mem.directMemoryMax));
  builder.endObject();
  builder.array(Fields.GC_COLLECTORS, gcCollectors);
  builder.array(Fields.MEMORY_POOLS, memoryPools);
  builder.field(Fields.USING_COMPRESSED_OOPS, useCompressedOops);
  builder.field(Fields.INPUT_ARGUMENTS, inputArguments);
  builder.endObject();
  return builder;
}

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

@Override
public XContentBuilder toXContent(final XContentBuilder builder, final Params params) throws IOException {
  builder.startObject();
  builder.field(INDEX_KEY);
  index.toXContent(builder, params);
  builder.timeField(DELETE_DATE_IN_MILLIS_KEY, DELETE_DATE_KEY, deleteDateInMillis);
  return builder.endObject();
}

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

@Override
public XContentBuilder toXContent(final XContentBuilder builder, final Params params) throws IOException {
  builder.startObject();
  builder.field(INDEX_KEY);
  index.toXContent(builder, params);
  builder.timeField(DELETE_DATE_IN_MILLIS_KEY, DELETE_DATE_KEY, deleteDateInMillis);
  return builder.endObject();
}

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

@Override
  public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
    builder.startObject();
    builder.field(FLUSHED.getPreferredName(), flushed);
    if (lastFinalizedBucketEnd != null) {
      builder.timeField(LAST_FINALIZED_BUCKET_END.getPreferredName(),
        LAST_FINALIZED_BUCKET_END.getPreferredName() + "_string", lastFinalizedBucketEnd.getTime());
    }
    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(DESCRIPTION.getPreferredName(), description);
  builder.timeField(START_TIME.getPreferredName(), START_TIME.getPreferredName() + "_string", startTime.getTime());
  builder.timeField(END_TIME.getPreferredName(), END_TIME.getPreferredName() + "_string", endTime.getTime());
  builder.field(Calendar.ID.getPreferredName(), calendarId);
  if (eventId != null) {
    builder.field(EVENT_ID.getPreferredName(), eventId);
  }
  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(POLICY_NAME_FIELD.getPreferredName(), policyName);
    if (phase != null) {
      builder.field(PHASE_DEFINITION_FIELD.getPreferredName(), phase);
    }
    builder.field(VERSION_FIELD.getPreferredName(), version);
    builder.timeField(MODIFIED_DATE_IN_MILLIS_FIELD.getPreferredName(), "modified_date", modifiedDate);
    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.timeField(Result.TIMESTAMP.getPreferredName(), Result.TIMESTAMP.getPreferredName() + "_string", timestamp.getTime());
  builder.field(BUCKET_SPAN.getPreferredName(), bucketSpan);
  builder.field(OVERALL_SCORE.getPreferredName(), overallScore);
  builder.field(JOBS.getPreferredName(), jobs);
  builder.field(Result.IS_INTERIM.getPreferredName(), isInterim);
  builder.field(Result.RESULT_TYPE.getPreferredName(), RESULT_TYPE_VALUE);
  builder.endObject();
  return builder;
}

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

builder.field(Job.ID.getPreferredName(), jobId);
if (timestamp != null) {
  builder.timeField(TIMESTAMP.getPreferredName(), TIMESTAMP.getPreferredName() + "_string", timestamp.getTime());
  builder.timeField(LATEST_RECORD_TIME.getPreferredName(), LATEST_RECORD_TIME.getPreferredName() + "_string",
    latestRecordTimeStamp.getTime());
  builder.timeField(LATEST_RESULT_TIME.getPreferredName(), LATEST_RESULT_TIME.getPreferredName() + "_string",
    latestResultTimeStamp.getTime());

代码示例来源: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);
  builder.field(Result.RESULT_TYPE.getPreferredName(), RESULT_TYPE_VALUE);
  builder.field(MODEL_BYTES_FIELD.getPreferredName(), modelBytes);
  builder.field(TOTAL_BY_FIELD_COUNT_FIELD.getPreferredName(), totalByFieldCount);
  builder.field(TOTAL_OVER_FIELD_COUNT_FIELD.getPreferredName(), totalOverFieldCount);
  builder.field(TOTAL_PARTITION_FIELD_COUNT_FIELD.getPreferredName(), totalPartitionFieldCount);
  builder.field(BUCKET_ALLOCATION_FAILURES_COUNT_FIELD.getPreferredName(), bucketAllocationFailuresCount);
  builder.field(MEMORY_STATUS_FIELD.getPreferredName(), memoryStatus);
  builder.timeField(LOG_TIME_FIELD.getPreferredName(), LOG_TIME_FIELD.getPreferredName() + "_string", logTime.getTime());
  if (timestamp != null) {
    builder.timeField(TIMESTAMP_FIELD.getPreferredName(), TIMESTAMP_FIELD.getPreferredName() + "_string", timestamp.getTime());
  }
  builder.endObject();
  return builder;
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.field("node", taskId.getNodeId());
  builder.field("id", taskId.getId());
  builder.field("type", type);
  builder.field("action", action);
  if (status != null) {
    builder.field("status", status, params);
  }
  if (description != null) {
    builder.field("description", description);
  }
  builder.timeField("start_time_in_millis", "start_time", startTime);
  if (builder.humanReadable()) {
    builder.field("running_time", new TimeValue(runningTimeNanos, TimeUnit.NANOSECONDS).toString());
  }
  builder.field("running_time_in_nanos", runningTimeNanos);
  builder.field("cancellable", cancellable);
  if (parentTaskId.isSet()) {
    builder.field("parent_task_id", parentTaskId.toString());
  }
  builder.startObject("headers");
  for(Map.Entry<String, String> attribute : headers.entrySet()) {
    builder.field(attribute.getKey(), attribute.getValue());
  }
  builder.endObject();
  return builder;
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.field("node", taskId.getNodeId());
  builder.field("id", taskId.getId());
  builder.field("type", type);
  builder.field("action", action);
  if (status != null) {
    builder.field("status", status, params);
  }
  if (description != null) {
    builder.field("description", description);
  }
  builder.timeField("start_time_in_millis", "start_time", startTime);
  if (builder.humanReadable()) {
    builder.field("running_time", new TimeValue(runningTimeNanos, TimeUnit.NANOSECONDS).toString());
  }
  builder.field("running_time_in_nanos", runningTimeNanos);
  builder.field("cancellable", cancellable);
  if (parentTaskId.isSet()) {
    builder.field("parent_task_id", parentTaskId.toString());
  }
  builder.startObject("headers");
  for(Map.Entry<String, String> attribute : headers.entrySet()) {
    builder.field(attribute.getKey(), attribute.getValue());
  }
  builder.endObject();
  return builder;
}

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

builder.field(Fields.STAGE, stage.toString());
builder.field(Fields.PRIMARY, primary);
builder.timeField(Fields.START_TIME_IN_MILLIS, Fields.START_TIME, timer.startTime);
if (timer.stopTime > 0) {
  builder.timeField(Fields.STOP_TIME_IN_MILLIS, Fields.STOP_TIME, timer.stopTime);

代码示例来源: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);
  builder.field(Result.RESULT_TYPE.getPreferredName(), RESULT_TYPE_VALUE);
  builder.field(INFLUENCER_FIELD_NAME.getPreferredName(), influenceField);
  builder.field(INFLUENCER_FIELD_VALUE.getPreferredName(), influenceValue);
  builder.field(INFLUENCER_SCORE.getPreferredName(), influencerScore);
  builder.field(INITIAL_INFLUENCER_SCORE.getPreferredName(), initialInfluencerScore);
  builder.field(PROBABILITY.getPreferredName(), probability);
  builder.field(BUCKET_SPAN.getPreferredName(), bucketSpan);
  builder.field(Result.IS_INTERIM.getPreferredName(), isInterim);
  builder.timeField(Result.TIMESTAMP.getPreferredName(), Result.TIMESTAMP.getPreferredName() + "_string", timestamp.getTime());
  builder.endObject();
  return builder;
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject(Fields.JVM);
  builder.field(Fields.PID, pid);
  builder.field(Fields.VERSION, version);
  builder.field(Fields.VM_NAME, vmName);
  builder.field(Fields.VM_VERSION, vmVersion);
  builder.field(Fields.VM_VENDOR, vmVendor);
  builder.timeField(Fields.START_TIME_IN_MILLIS, Fields.START_TIME, startTime);
  builder.startObject(Fields.MEM);
  builder.humanReadableField(Fields.HEAP_INIT_IN_BYTES, Fields.HEAP_INIT, new ByteSizeValue(mem.heapInit));
  builder.humanReadableField(Fields.HEAP_MAX_IN_BYTES, Fields.HEAP_MAX, new ByteSizeValue(mem.heapMax));
  builder.humanReadableField(Fields.NON_HEAP_INIT_IN_BYTES, Fields.NON_HEAP_INIT, new ByteSizeValue(mem.nonHeapInit));
  builder.humanReadableField(Fields.NON_HEAP_MAX_IN_BYTES, Fields.NON_HEAP_MAX, new ByteSizeValue(mem.nonHeapMax));
  builder.humanReadableField(Fields.DIRECT_MAX_IN_BYTES, Fields.DIRECT_MAX, new ByteSizeValue(mem.directMemoryMax));
  builder.endObject();
  builder.array(Fields.GC_COLLECTORS, gcCollectors);
  builder.array(Fields.MEMORY_POOLS, memoryPools);
  builder.field(Fields.USING_COMPRESSED_OOPS, useCompressedOops);
  builder.field(Fields.INPUT_ARGUMENTS, inputArguments);
  builder.endObject();
  return builder;
}

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

@Override
public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject(Fields.JVM);
  builder.field(Fields.PID, pid);
  builder.field(Fields.VERSION, version);
  builder.field(Fields.VM_NAME, vmName);
  builder.field(Fields.VM_VERSION, vmVersion);
  builder.field(Fields.VM_VENDOR, vmVendor);
  builder.timeField(Fields.START_TIME_IN_MILLIS, Fields.START_TIME, startTime);
  builder.startObject(Fields.MEM);
  builder.humanReadableField(Fields.HEAP_INIT_IN_BYTES, Fields.HEAP_INIT, new ByteSizeValue(mem.heapInit));
  builder.humanReadableField(Fields.HEAP_MAX_IN_BYTES, Fields.HEAP_MAX, new ByteSizeValue(mem.heapMax));
  builder.humanReadableField(Fields.NON_HEAP_INIT_IN_BYTES, Fields.NON_HEAP_INIT, new ByteSizeValue(mem.nonHeapInit));
  builder.humanReadableField(Fields.NON_HEAP_MAX_IN_BYTES, Fields.NON_HEAP_MAX, new ByteSizeValue(mem.nonHeapMax));
  builder.humanReadableField(Fields.DIRECT_MAX_IN_BYTES, Fields.DIRECT_MAX, new ByteSizeValue(mem.directMemoryMax));
  builder.endObject();
  builder.array(Fields.GC_COLLECTORS, gcCollectors);
  builder.array(Fields.MEMORY_POOLS, memoryPools);
  builder.field(Fields.USING_COMPRESSED_OOPS, useCompressedOops);
  builder.field(Fields.INPUT_ARGUMENTS, inputArguments);
  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(Job.ID.getPreferredName(), jobId);
  builder.timeField(Result.TIMESTAMP.getPreferredName(), Result.TIMESTAMP.getPreferredName() + "_string", timestamp.getTime());
  builder.field(ANOMALY_SCORE.getPreferredName(), anomalyScore);
  builder.field(BUCKET_SPAN.getPreferredName(), bucketSpan);
  builder.field(INITIAL_ANOMALY_SCORE.getPreferredName(), initialAnomalyScore);
  if (records.isEmpty() == false) {
    builder.field(RECORDS.getPreferredName(), records);
  }
  builder.field(EVENT_COUNT.getPreferredName(), eventCount);
  builder.field(Result.IS_INTERIM.getPreferredName(), isInterim);
  builder.field(BUCKET_INFLUENCERS.getPreferredName(), bucketInfluencers);
  builder.field(PROCESSING_TIME_MS.getPreferredName(), processingTimeMs);
  if (scheduledEvents.isEmpty() == false) {
    builder.field(SCHEDULED_EVENTS.getPreferredName(), scheduledEvents);
  }
  builder.field(Result.RESULT_TYPE.getPreferredName(), RESULT_TYPE_VALUE);
  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(Job.ID.getPreferredName(), jobId);
  builder.field(Result.RESULT_TYPE.getPreferredName(), RESULT_TYPE_VALUE);
  if (influenceField != null) {
    builder.field(INFLUENCER_FIELD_NAME.getPreferredName(), influenceField);
  }
  builder.field(INITIAL_ANOMALY_SCORE.getPreferredName(), initialAnomalyScore);
  builder.field(ANOMALY_SCORE.getPreferredName(), anomalyScore);
  builder.field(RAW_ANOMALY_SCORE.getPreferredName(), rawAnomalyScore);
  builder.field(PROBABILITY.getPreferredName(), probability);
  builder.timeField(Result.TIMESTAMP.getPreferredName(), Result.TIMESTAMP.getPreferredName() + "_string", timestamp.getTime());
  builder.field(BUCKET_SPAN.getPreferredName(), bucketSpan);
  builder.field(Result.IS_INTERIM.getPreferredName(), isInterim);
  builder.endObject();
  return builder;
}

相关文章

微信公众号

最新文章

更多