flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamInMemOutputHandler.java [89:98]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Map<String, Object> toMap(Event event) {
        Map<String, Object> map = new LinkedHashMap<>();
        for (int i = 0; i < definition.getAttributeNameArray().length; i++) {
            map.put(definition.getAttributeNameArray()[i], event.getData(i));
        }
        return map;
    }

    private <T extends Tuple> T toTuple(Event event) {
        return SiddhiTupleFactory.newTuple(event.getData());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamOutputHandler.java [90:99]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Map<String, Object> toMap(Event event) {
        Map<String, Object> map = new LinkedHashMap<>();
        for (int i = 0; i < definition.getAttributeNameArray().length; i++) {
            map.put(definition.getAttributeNameArray()[i], event.getData(i));
        }
        return map;
    }

    private <T extends Tuple> T toTuple(Event event) {
        return SiddhiTupleFactory.newTuple(event.getData());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -