org.wso2.siddhi.core.event.Event类的使用及代码示例

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

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

Event介绍

暂无

代码示例

代码示例来源：origin: org.wso2.extension.siddhi.map.json/siddhi-map-json

private Event doPartialProcessing(Event event) {
  Object[] data = event.getData();
  for (int i = 0; i < data.length; i++) {
    if (data[i] == null) {
      data[i] = UNDEFINED;
    }
  }
  return event;
}

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.stream.processor.core

public static Event getEvent(ByteBuffer byteBuffer, String[] attributeTypes) throws UnsupportedEncodingException {
  Event event = new Event();
  long timeStamp = byteBuffer.getLong();
  event.setTimestamp(timeStamp);
  event.setData(toObjectArray(byteBuffer, attributeTypes));
  return event;
}

代码示例来源：origin: org.wso2.carbon.event-processing/org.wso2.carbon.event.processor.core

@Override
public void sendEvent(Event event) throws InterruptedException {
  inputHandler.send(event.getTimestamp(), event.getData());
}

代码示例来源：origin: org.wso2.carbon.event-processing/org.wso2.carbon.event.processor.common

public Event (long timestamp, Object[] data, String streamId){
  super.setTimestamp(timestamp);
  super.setData(data);
  this.streamId = streamId;
}

代码示例来源：origin: org.wso2.extension.siddhi.map.json/siddhi-map-json

Event event = new Event(streamAttributes.size());
Object[] data = event.getData();

代码示例来源：origin: org.wso2.extension.siddhi.map.csv/siddhi-map-csv

Event event = new Event(this.streamDefinition.getAttributeList().size());
Object[] data = event.getData();
Attribute.Type type;
for (int j = 0; j < attributeList.size(); j++) {
            + "event '" + event.toString() + "' when check the event data in "
            + "the stream '" + streamDefinition.getId()
            + "' of siddhi CSV input mapper.");

代码示例来源：origin: Stratio/Decision

@Override
public StratioStreamingMessage deserialize(Event object) {
  List<ColumnNameTypeValue> columns = new ArrayList<>();
  for (int i = 0; i < object.getData().length; i++) {
    Object data = object.getData()[i];
    Attribute attribute = streamMetadataService.getAttribute(object.getStreamId(), i);
    columns.add(new ColumnNameTypeValue(attribute.getName(), encodeSiddhiType(attribute.getType()), data));
  }
  return new StratioStreamingMessage(object.getStreamId(), object.getTimeStamp(), columns);
}

代码示例来源：origin: stackoverflow.com

public class EventComparator implements Comparator<Event>, Serializable {

  private static final long serialVersionUID = 1L;

  @Override
  public int compare(Event o1, Event o2) {
    return (o1.getTimestamp() < o2.getTimestamp() ? -1
        : (o1.getTimestamp() == o2.getTimestamp() ? 0 : 1));
  }

}

代码示例来源：origin: org.wso2.carbon.event-processing/org.wso2.carbon.event.processor.core

@Override
public void receive(String streamId, long timestamp, Object[] eventData, Map<String, String> arbitraryMapData) {
  SiddhiOutputStreamListener outputStreamListener = streamNameToOutputStreamListenerMap.get(streamId);
  if (outputStreamListener != null) {
    outputStreamListener.sendEvent(new Event(timestamp, eventData));
    inputThroughputProbe.update();
  } else {
    log.warn("Cannot find output event listener for stream " + streamId + " in execution plan " + executionPlanConfiguration.getName()
        + " of tenant " + tenantId + ". Discarding Event:" + streamId +
        ":" + Arrays.deepToString(eventData) + "@" + timestamp);
  }
}

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.event.simulator.core

/**
 * resume() method
 */
@Override
public void resume() {
  if ("-1".equals(csvConfiguration.getTimestampAttribute())) {
    startTimestamp = System.currentTimeMillis();
    nextEvent.setTimestamp(startTimestamp);
  }
  if (log.isDebugEnabled()) {
    log.debug("Stop random generator for stream '" + csvConfiguration.getStreamName() + "'");
  }
}

代码示例来源：origin: org.wso2.extension.siddhi.map.text/siddhi-map-text

isValidEvent.set(true);
List<Event> eventList = new ArrayList<>();
Event event = new Event(this.streamDefinition.getAttributeList().size());
Object[] data = event.getData();
String[] events = eventObject.split(ATTRIBUTE_SEPARATOR + endOfLine);
if ((events.length < attributeList.size()) && (failOnMissingAttribute)) {

代码示例来源：origin: org.wso2.extension.siddhi.map.csv/siddhi-map-csv

Event event = new Event(this.streamDefinition.getAttributeList().size());
Object[] data = event.getData();
Attribute.Type type;
int position;
          + "event '" + event.toString() + "' when check the event data in "
          + "the stream '" + streamDefinition.getId()
          + "' of siddhi CSV input mapper.");

代码示例来源：origin: stackoverflow.com

public class MyActivity {

 private int times = 0;
 private long lastTimestamp;

 private void onTouchEvent(Event evt) {
  if (times > 0) {
   long delay = evt.getTimestamp() - lastTimestamp;
   // do something with the delay
  }
  lastTimestamp = evt.getTimestamp();
  times++;
 }
}

代码示例来源：origin: apache/eagle

e = new Event(base, new Object[] {base, "host" + r.nextInt(), "nova"});
base += 100;
events.add(e);
e = new Event(base, new Object[] {base, "host" + r.nextInt(), "nova"});
base += 100;
events.add(e);
e = new Event(base, new Object[] {base, "host" + r.nextInt(), "nova"});
base += 100;
events.add(e);
e = new Event(base, new Object[] {base, "host" + r.nextInt(), "neutron"});
base += 100;
events.add(e);
e = new Event(base, new Object[] {base, "host" + r.nextInt(), "neutron"});
base += 100;
events.add(e);
e = new Event(base, new Object[] {base, "host" + r.nextInt(), "neutron"});
base += 100;
events.add(e);
e = new Event(base, new Object[] {base, "host" + r.nextInt(), "nova1"});
base += 100;
events.add(e);
e = new Event(base, new Object[] {base, "host" + r.nextInt(), "nova1"});
base += 100;
events.add(e);
e = new Event(base, new Object[] {base, "host" + r.nextInt(), "nova1"});
base += 100;
events.add(e);

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.event.simulator.core

/**
 * resume() method
 */
@Override
public void resume() {
  /*
   * The system timestamp is set to current timestamp to enable the event to have the latest timestamp.
   * This timestamp is used to create the notify timer event in the WindowProcessor
   * If we use the timestamp at the time of pausing the simulator, it will cause issues when generating the timer
   * event because the system timestamp is continously increasing
   */
  currentTimestamp = System.currentTimeMillis();
  nextEvent.setTimestamp(currentTimestamp);
  currentTimestamp += randomSimulationConfig.getTimestampInterval();
  if (log.isDebugEnabled()) {
    log.debug("Stop random generator for stream '" + randomSimulationConfig.getStreamName() + "'");
  }
}

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.stream.processor.core

private static int getEventSize(Event event) {
  int eventSize = 8;
  Object[] data = event.getData();
  if (data != null) {
    for (int i = 0; i < data.length; i++) {
      Object aData = data[i];
      eventSize += BinaryMessageConverterUtil.getSize(aData);
    }
  }
  return eventSize;
}

代码示例来源：origin: org.wso2.carbon.event-processing/org.wso2.carbon.event.processor.common

@Override
  public void receive(Event[] events) {
    for (Event event : events) {
      Object[] eventData = Arrays.copyOf(event.getData(), event.getData().length + 1);
      eventData[event.getData().length] = event.getTimestamp();
      outputCollector.emit(triggerId, Arrays.asList(eventData));
      if (log.isDebugEnabled()) {
        log.debug(logPrefix + "Trigger Event Emitted :" + Arrays.deepToString(eventData));
      }
    }
  }
});

代码示例来源：origin: org.wso2.extension.siddhi.map.keyvalue/siddhi-map-keyvalue

Event event = new Event(attributesSize);
Object data[] = event.getData();

代码示例来源：origin: apache/eagle

private void sendPatternInput(InputHandler handler) throws Exception {
  // validate one
  Event e = new Event(12);
  e.setTimestamp(System.currentTimeMillis());
  e.setData(new Object[] {"facitliy", "SEVERITY_EMERG", "HOSTNAME-" + 0, "MSGID-...", "Timestamp", "conn-sss", "op-msg-UPDOWN", "msgId..", "command-...", "name-", "namespace", System.currentTimeMillis()});
  e = new Event(12);
  e.setTimestamp(System.currentTimeMillis());
  e.setData(new Object[] {"facitliy", "SEVERITY_EMERG", "HOSTNAME-" + 0, "MSGID-...", "Timestamp", "conn-sss", "op-msg-nothing", "msgId..", "command-...", "name-", "namespace", System.currentTimeMillis()});
  e = new Event(12);
  e.setTimestamp(System.currentTimeMillis());
  e.setData(new Object[] {"facitliy", "SEVERITY_EMERG", "HOSTNAME-" + 0, "MSGID-...", "Timestamp", "conn-sss", "op-msg-Abort", "msgId..", "command-...", "name-", "namespace", System.currentTimeMillis()});
  Thread.sleep(61 * 1000);
  e = new Event(12);
  e.setTimestamp(System.currentTimeMillis());
  e.setData(new Object[] {"facitliy", "SEVERITY_EMERG", "HOSTNAME-" + 11, "MSGID-...", "Timestamp", "conn-sss", "op-msg", "msgId..", "command-...", "name-", "namespace", System.currentTimeMillis()});
  handler.send(e);
}

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.stream.processor.core

/**
 * Method that would publish events if this is the Active Node.
 *
 * @param event the event to be published.
 * @param sinkHandlerCallback callback that would publish events.
 */
@Override
public void handle(Event event, SinkHandlerCallback sinkHandlerCallback) {
  if (isActiveNode) {
    lastPublishedEventTimestamp = event.getTimestamp();
    sinkHandlerCallback.mapAndSend(event);
  }
}

内容来源于网络，如有侵权，请联系作者删除！

Event

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com