本文整理了Java中org.wso2.carbon.databridge.commons.Event.setArbitraryDataMap()
方法的一些代码示例,展示了Event.setArbitraryDataMap()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Event.setArbitraryDataMap()
方法的具体详情如下:
包路径:org.wso2.carbon.databridge.commons.Event
类名称:Event
方法名:setArbitraryDataMap
暂无
代码示例来源:origin: org.wso2.extension.siddhi.map.wso2event/siddhi-map-wso2event
);
wso2event.setArbitraryDataMap(arbitraryDataMap);
代码示例来源:origin: org.wso2.carbon.analytics/org.wso2.carbon.analytics.datasink
private void updateEvent(Event oldEvent, Event newEvent) {
oldEvent.setArbitraryDataMap(newEvent.getArbitraryDataMap());
oldEvent.setCorrelationData(newEvent.getCorrelationData());
oldEvent.setMetaData(newEvent.getMetaData());
oldEvent.setPayloadData(newEvent.getPayloadData());
oldEvent.setStreamId(newEvent.getStreamId());
oldEvent.setTimeStamp(newEvent.getTimeStamp());
}
}
代码示例来源:origin: org.wso2.carbon.analytics-common/org.wso2.carbon.databridge.receiver.binary
public Event getEvent(ByteBuffer byteBuffer, StreamTypeHolder streamTypeHolder) throws MalformedEventException {
long timeStamp = byteBuffer.getLong();
int streamIdSize = byteBuffer.getInt();
String streamId = BinaryMessageConverterUtil.getString(byteBuffer, streamIdSize);
Event event = new Event();
event.setStreamId(streamId);
event.setTimeStamp(timeStamp);
AttributeType[][] attributeTypeOrder = streamTypeHolder.getDataType(event.getStreamId());
if (attributeTypeOrder == null) {
streamTypeHolder.reloadStreamTypeHolder();
attributeTypeOrder = streamTypeHolder.getDataType(event.getStreamId());
if (attributeTypeOrder == null) {
throw new EventConversionException("No StreamDefinition for streamId " + event.getStreamId()
+ " present in cache ");
}
}
event.setMetaData(this.toObjectArray(byteBuffer, attributeTypeOrder[0],
BinaryDataReceiverConstants.META_DATA_FIELD));
event.setCorrelationData(this.toObjectArray(byteBuffer, attributeTypeOrder[1],
BinaryDataReceiverConstants.CORRELATION_DATA_FIELD));
event.setPayloadData(this.toObjectArray(byteBuffer, attributeTypeOrder[2],
BinaryDataReceiverConstants.PAYLOAD_DATA_FIELD));
event.setArbitraryDataMap(this.toStringMap(byteBuffer));
return event;
}
代码示例来源:origin: org.wso2.carbon.analytics-common/org.wso2.carbon.databridge.receiver.thrift
Map<String, String> arbitraryData = thriftEventBundle.getArbitraryDataMapMap().get(i);
if (null != arbitraryData) {
event.setArbitraryDataMap(arbitraryData);
代码示例来源:origin: org.wso2.carbon.analytics/org.wso2.carbon.databridge.receiver.thrift
Map<String, String> arbitraryData = thriftEventBundle.getArbitraryDataMapMap().get(i);
if (null != arbitraryData) {
event.setArbitraryDataMap(arbitraryData);
代码示例来源:origin: org.wso2.carbon.commons/org.wso2.carbon.databridge.receiver.thrift
Map<String, String> arbitraryData = thriftEventBundle.getArbitraryDataMapMap().get(i);
if (null != arbitraryData) {
event.setArbitraryDataMap(arbitraryData);
内容来源于网络,如有侵权,请联系作者删除!