本文整理了Java中backtype.storm.tuple.Tuple.size()
方法的一些代码示例,展示了Tuple.size()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tuple.size()
方法的具体详情如下:
包路径:backtype.storm.tuple.Tuple
类名称: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);
}
}
内容来源于网络,如有侵权,请联系作者删除!