org.wso2.carbon.databridge.commons.Event.setArbitraryDataMap()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(2.9k)|赞(0)|评价(0)|浏览(161)

本文整理了Java中org.wso2.carbon.databridge.commons.Event.setArbitraryDataMap()方法的一些代码示例,展示了Event.setArbitraryDataMap()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Event.setArbitraryDataMap()方法的具体详情如下:
包路径:org.wso2.carbon.databridge.commons.Event
类名称:Event
方法名:setArbitraryDataMap

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);

相关文章