com.hurence.logisland.record.Record.getType()方法的使用及代码示例

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

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

Record.getType介绍

暂无

代码示例

代码示例来源:origin: com.hurence.logisland/logisland-api

public StandardRecord(Record toClone) {
  this();
  this.setType(toClone.getType());
  this.setTime(toClone.getTime());
  this.setId(UUID.randomUUID().toString());
  toClone.getAllFieldsSorted().forEach(this::setField);
  this.errors = (List<String>) toClone.getErrors();
}

代码示例来源:origin: com.hurence.logisland/logisland-querymatcher-plugin

@Override
public void handleMatch(final Record record,
            final ProcessContext context,
            final MatchingRule matchingRule,
            MatchQuery.RecordTypeUpdatePolicy recordTypeUpdatePolicy) {
  this.outRecords.add(
      new StandardRecord(record)
          .setType(
            (recordTypeUpdatePolicy == MatchQuery.RecordTypeUpdatePolicy.overwrite) ?
                context.getPropertyValue(MatchQuery.OUTPUT_RECORD_TYPE).asString() : record.getType()
          )
          .setStringField(ALERT_MATCH_NAME, matchingRule.getName())
          .setStringField(ALERT_MATCH_QUERY, matchingRule.getLegacyQuery()));
}

代码示例来源:origin: com.hurence.logisland/logisland-sampling-plugin

/**
   * retrun the same record as input by keeping only time and value fields.
   *
   * @param record
   * @return
   */
  public Record getTimeValueRecord(Record record){
    Record tvRecord = new StandardRecord(record.getType());
    Double value = getRecordValue(record);
    if(value != null)
      tvRecord.setField(valueFieldName, record.getField(valueFieldName).getType(), value);

    Long time = getRecordTime(record);
    if(time != null)
      tvRecord.setField(timeFieldName, record.getField(timeFieldName).getType(), time);

    return tvRecord;
  }
}

代码示例来源:origin: com.hurence.logisland/logisland-outlier-detection-plugin

double value = record.getField(valueField).asDouble();
DataPoint dp = new DataPoint(timestamp, value, new HashMap<>(), record.getType());

代码示例来源:origin: com.hurence.logisland/logisland-querymatcher-plugin

.setType(
        (recordTypeUpdatePolicy == MatchQuery.RecordTypeUpdatePolicy.overwrite) ?
            context.getPropertyValue(MatchQuery.OUTPUT_RECORD_TYPE).asString() : record.getType()
    );
this.outRecords.put(record.getId(), outRecord);

相关文章