Storm【设计细节】 -Fields对象

2019-03-02 23:58|来源: 网路

       


本章主题:

        记录一个小小的Tips


     1 Storm在Emit

public class Values extens ArrayList<Object>
{


public Values()
{
}

public Values(Object ...vals)
{
    super(vals.length);
    for(Object o:val)
    {
        add(o);
    }

}


   1 Values 继承自ArrayList, 通过super(vals.lengh) 初始化List的长度

   2 通过for循环add将vals 将其初始化

   3 emit在发射数据的时候,通过values对象封装成为Fields对象


  通过对Fields对象的封装,在发射的过程之中直接传递 JAVABEAN。



转自:http://my.oschina.net/u/1791874/blog/293313

相关问答

更多

Java类字段,Beanshell中的对象使用(Java class fields, object use in Beanshell)

在JMeter的Beanshell或更好的JSR223 Sampler(Java语言)中,您可以将对象放入JMeter变量中,如下所示: JMeterVariables vars = JMeterContextService.getContext().getVariables(); vars.putObject("stringList", stringList); 得到: vars.getObject("stringList"); 在Java一般情况下,您需要使用set方法将变量添加到Bean ...

Apache strom - 包backtype.storm.tuple不存在(Apache strom - package backtype.storm.tuple does not exist)

我遇到了另一个旧的Apache Storm教程的类似问题。 结果只是因为教程使用了以前版本(0.9.6)中的弃用类,而我使用的是新版本(1.1.0)。 因此,我的建议是要查看较新的库中相应的资源,并相应地更改库加载语句,或检查您使用的依赖项是否未被类似命名的库屏蔽。 I ran into similar problems with another old Apache Storm tutorial. It turned out to simply be because of the tutoria ...

Storm Fields分组示例(Storm Fields grouping example)

您需要将json属性从json对象中拉出,并将两个值(json对象和String groupId)作为双值元组传递。 当您将流声明为拓扑规范逻辑的一部分时,您将为第二个字段指定名称“groupId”,并且事情应该正常工作。 如果您不想修改Kafka喷口,则需要有一个中间螺栓,其唯一目的是将groupId从json对象中分离出来。 中间螺栓还可以使用定向流(emitDirect()方法),将目标放在json对象中的groupId上。 这就是为什么我不重复使用Kafka喷口的一个原因 - 除了盲目地将 ...

在_meta.get_fields()之后调用模板中的对象(Call object in template after _meta.get_fields())

您获得的part对象是模型实例。 您可以将其用作模型实例。 所以这才有效: {% for image_object in part.image_part.all %} <img src="{{ image_object.image.url }}" /> {% endfor %} 也就是说,删除此行后: part = part._meta.get_fields() 没有任何理由这样做。 您需要访问_meta的情况很少见。 The part object you get is a mode ...

Apache Storm:记住spout的旧数量输出字段(Apache Storm: Remembering old number of output fields for spout)

Nimbus缓冲区在storm.local.dir提交了拓扑。 您应该能够删除那里的缓冲拓扑(即jar文件)。 但要小心:删除“错误”文件将中断运行拓扑! The issue was because I had an original compiled jar of the same program in the storm directory, from previous building and deploying when testing set up of the cluster. Wha ...

将数据对象结构和字段隐藏到WebServices客户端(Hiding data objects structure and fields to WebServices clients)

您不应该跨进程边界传递数据对象。 它会使您的应用程序变得脆弱,并且每次进行架构更改时都会保证很多返工。 我的建议如下: - 数据访问层应该只是:处理创建,读取,更新和删除数据库对象。 DAL的用户必须知道数据库的工作方式才能使用它。 ex(在伪代码中): Person = { PERSON_ID:'1234567jksjgkhsduw0909wueioksgt', FIRST_NAME:'CHRIS', LAST_NAME:'MCCALL', TITLE:'', GENDER:'M', LAST_ ...

Redis错误在Storm拓扑上(Redis Error On a Storm topology)

我终于来了! 我只是简单了,我创建了一个非常简单的redis bolt,它发布了内容,我监视了redis数据库,它正在运行。 我的工作螺栓: public class RedisBolt implements IRichBolt { protected String channel = "Somriures"; // protected String configChannel; protected OutputCollector coll ...

如何响应Delphi中对象属性字段的变化(How to respond to changes in fields of object properties in Delphi)

将事件处理程序分配给TFont.OnChange事件。 在处理程序中, Invalidate()您的控件以触发重绘。 例如: type TMyControl = class(TGraphicControl) private FMyFont: TFont; procedure MyFontChanged(Sender: TObject); procedure SetMyFont(Value: TFont); protected procedure Pain ...

在XCode,MVC中设计主/细节(Designing Master/Detail in XCode,MVC)

Apple实际上提供了一个很好的教程/示例,说明了您所询问的具体情况: 创建主 - 详细信息界面 值得注意的一点是,Apple的MVC概念与“经典”MVC模式略有不同(或者我怀疑Martin Fowler会这样说,无论如何)。 如果你将现有的MVC概念放在一边并通过Apple提供的一些介绍性示例,我怀疑你会有更轻松的时间。 在30,000英尺处,Cocoa可能更像是Model-View-Presenter,或者不幸的是名为Model-View-ViewModel模式。 记住整个模式可以嵌套或多次实 ...