backtype.storm.tuple.Tuple.size()方法的使用及代码示例

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

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

Tuple.size介绍

[英]Returns the number of fields in this tuple.
[中]

代码示例

代码示例来源:origin: mayconbordin/storm-applications

@Override
public String format(Tuple tuple) {
  Fields schema = context.getComponentOutputFields(tuple.getSourceComponent(), tuple.getSourceStreamId());
  
  String line = "";
    
  for (int i=0; i<tuple.size(); i++) {
    if (i != 0) line += ", ";
    line += String.format("%s=%s", schema.get(i), tuple.getValue(i));
  }
  
  return line;
}

代码示例来源:origin: mayconbordin/storm-applications

@Override
public String format(Tuple tuple) {
  Fields schema = context.getComponentOutputFields(tuple.getSourceComponent(), tuple.getSourceStreamId());
  String values = "";
  for (int i=0; i<tuple.size(); i++) {
    if (i != 0) values += ", ";
    values += String.format("%s=%s", schema.get(i), tuple.getValue(i));
  }
  
  return String.format(TEMPLATE, tuple.getSourceComponent(), tuple.getSourceTask(),
      tuple.getSourceStreamId(), tuple.getMessageId().toString(), values);
}

代码示例来源:origin: apache/eagle

public static Tuple2<Object,Map> tupleToEvent(Tuple input) {
    Map event = null;
    Object key = input.getValue(0);
    if (input.size() < 2) {
      event = StreamConvertHelper.tupleToMap(input);
    } else {
      Object value = input.getValue(1);
      if (value != null) {
        if (value instanceof Map) {
          event = (Map) input.getValue(1);
        } else {
          event = StreamConvertHelper.tupleToMap(input);
        }
      }
    }
    return new Tuple2<>(key, event);
  }
}

相关文章