官术网_书友最值得收藏!

The Storm data model

The basic unit of data that can be processed by a Storm application is called a tuple. Each tuple consists of a predefined list of fields. The value of each field can be a byte, char, integer, long, float, double, Boolean, or byte array. Storm also provides an API to define your own datatypes, which can be serialized as fields in a tuple.

A tuple is dynamically typed, that is, you just need to define the names of the fields in a tuple and not their datatype. The choice of dynamic typing helps to simplify the API and makes it easy to use. Also, since a processing unit in Storm can process multiple types of tuples, it's not practical to declare field types.

Each of the fields in a tuple can be accessed by its name, getValueByField(String), or its positional index, getValue(int), in the tuple. Tuples also provide convenient methods such as getIntegerByField(String) that save you from typecasting the objects. For example, if you have a Fraction (numerator, denominator) tuple, representing fractional numbers, then you can get the value of the numerator by either using getIntegerByField("numerator") or getInteger(0).

You can see the full set of operations supported by org.apache.storm.tuple.Tuple in the Java doc that is located at https://storm.apache.org/releases/1.0.2/javadocs/org/apache/storm/tuple/Tuple.html.

主站蜘蛛池模板: 团风县| 通城县| 西吉县| 建瓯市| 大石桥市| 浮山县| 昭通市| 大冶市| 乌兰县| 大余县| 和静县| 柳河县| 商城县| 阿城市| 平安县| 十堰市| 紫金县| 铁岭市| 宁安市| 瓦房店市| 舒兰市| 察雅县| 客服| 高平市| 阳信县| 绥宁县| 临夏市| 泰州市| 虹口区| 南京市| 额尔古纳市| 宁海县| 庆安县| 来安县| 枣强县| 岳阳县| 松潘县| 宝丰县| 乌鲁木齐县| 江达县| 弋阳县|