我想知道在条件查询期间是否可以初始化实体的瞬态属性.
例
@Entity
public SampleEntity{
@Id
private long id;
[more attributes]
@Transient
private String someTransientString;
[getters and setters]
}
现在我想编写一个CriteriaQuery来加载所有SampleEntitys并自动设置someTransientString为imamightlyfinestring.我有类似以下SQL的内容:
SELECT ID AS ID, [..], 'imamightilyfinestring' AS SOME_TRANSIENT_STRING FROM SAMPLE_ENTITY
我当然知道我可以简单地迭代生成的集合并手动设置属性,但我想知道是否有办法在JPA2中完成它.
谢谢 :)
我要求我需要处理JMS消息(通过MDB),使得属于某个组(设置了组ID)的消息被同一个bean实例使用.我在此要求的行为是,顺序处理具有相同组ID的消息(尽管消息排序无关紧要),并将它们绑定到同一个MDB实例应该提供.
消息不带任何类型的序列号(因为它是无关紧要的),我们不知道组中的第一个或最后一个消息是什么(理论上"永远不会"是组中的最后一个消息).我们希望一旦消费者能够接收它们就能交付它们.
ActiveMQ 通过简单地设置JMSXGroupID来提供这个确切的功能(http://activemq.apache.org/message-groups.html).但是,我们必须使用WebSphere MQ.到目前为止,我发现的是,可以收集队列中同一组的消息,并使用MessageSelector接收"组中的最后一条消息"消息,如http://www.ibm.com/中所述. developerworks/websphere/library/techarticles/0602_currie/0602_currie.html.我们更喜欢更清洁的方式(如在ActiveMQ中).有谁知道如何在WebSphere中实现这种行为？
谢谢!
我对Kafka Streams有一个问题(0.10.1.1).我正在尝试创建一个KStream和一个KTable相同的主题.
我尝试的第一种方法是简单地KStreamBuilder在同一主题上调用流和表的方法.这导致了
org.apache.kafka.streams.errors.TopologyBuilderException: Invalid topology building: Topic <topicName> has already been registered by another source.
好吧,这似乎是Kafka Streams内置的一些限制.
我的第二种方法是最初创建一个KTable并toStream()在其上使用该方法.这有一个KTables内部缓冲/刷新的问题,因此如果一个键出现多次,输出流不会反映所有输入元素.这是一个问题,因为我正在计算密钥的出现次数.
似乎有效的方法是最初创建一个KStream,按键对其进行分组,然后通过丢弃旧聚合并仅保留新值来"减少"它.我对这种方法不太满意,因为a)它似乎非常复杂,并且b)Reducer接口没有指定哪一个是已经聚合的值,哪一个是新的.我参加了会议并保留了第二个,但是......嗯.
所以问题归结为:有更好的方法吗？我错过了一些非常明显的东西吗？
请记住,我没有处理正确的用例 - 这只是我了解Streams-API.
我刚刚尝试了GWT的编辑器框架并将其用于一个小例子.但我想知道为什么副编辑需要包私有？
链接页面中的示例中有一条注释专门提到了受包保护的字段,但我找不到原因.
// Sub-editors are retrieved from package-protected fields, usually initialized with UiBinder.
// Many Editors have no interesting logic in them
public class PersonEditor extends Dialog implements Editor<Person> {
Label nameEditor;
AddressEditor addressEditor;
...
}
在我尝试自己的例子中,如果我的子编辑器是包私有的,我只能使用它,如果我将它们设为私有,则绑定不再起作用.
任何人都可以向我解释为什么存在这种限制？它使我的编码风格看起来有点不一致.谢谢!