Java Event类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.wso2.siddhi.core.event.Event类的典型用法代码示例。如果您正苦于以下问题：Java Event类的具体用法？Java Event怎么用？Java Event使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Event类属于org.wso2.siddhi.core.event包，在下文中一共展示了Event类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testClusTree2D_24

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testClusTree2D_24() throws Exception {
    logger.info("ClusTreeStreamProcessorExtension Test - Test case with non-numeric event data");
    SiddhiManager siddhiManager = new SiddhiManager();
    String inputStream = "define stream InputStream (x double, y double);";

    String query = (
            "@info(name = 'query1') " +
                    "from InputStream#streamingml:clusTree(2, x, y) " +
                    "select closestCentroidCoordinate1, closestCentroidCoordinate2, x, y " +
                    "insert into OutputStream;");
    SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(inputStream + query);

    siddhiAppRuntime.addCallback("query1", new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(inEvents);
        }
    });


    siddhiAppRuntime.start();
    InputHandler inputHandler = siddhiAppRuntime.getInputHandler("InputStream");
    inputHandler.send(new Object[]{5.7905, "hi"});
}

开发者ID:wso2-extensions，项目名称:siddhi-gpl-execution-streamingml，代码行数:26，代码来源:ClusTreeStreamProcessorExtensionTest.java

示例2: mapAndSend

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Override
public void mapAndSend(Event[] events, OptionHolder optionHolder,
                       Map<String, TemplateBuilder> payloadTemplateBuilderMap, SinkListener sinkListener) {

    StringBuilder sb = new StringBuilder();
    if (payloadTemplateBuilderMap == null) {
        String jsonString = constructJsonForDefaultMapping(events);
        sb.append(jsonString);
    } else {
        sb.append(constructJsonForCustomMapping(events,
                payloadTemplateBuilderMap.get(payloadTemplateBuilderMap.keySet().iterator().next())));
    }

    if (!isJsonValidationEnabled) {
        sinkListener.publish(sb.toString());
    } else if (isValidJson(sb.toString())) {
        sinkListener.publish(sb.toString());
    } else {
        log.error("Invalid json string : " + sb.toString() + ". Hence dropping the message.");
    }
}

开发者ID:wso2-extensions，项目名称:siddhi-map-json，代码行数:22，代码来源:JsonSinkMapper.java

示例3: testConvertFunctionQuery8

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testConvertFunctionQuery8() throws InterruptedException {
    log.info("ConvertFunction test8");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream("define stream typeStream (typeS string, typeF float, typeD double, typeI int, typeL long, typeB bool) ");


    String queryReference = siddhiManager.addQuery("from typeStream " +
                                                   " select convert(typeL,string,'dd:MM:yy') as type1;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            eventCount++;
            Assert.assertEquals("05:07:13", inEvents[0].getData0());
        }
    });

    inputHandler.send(new Object[]{"23:01:13", 1f, 1d, 1, 1373043027082l, true});
    junit.framework.Assert.assertEquals(1, eventCount);
    siddhiManager.shutdown();
}

开发者ID:redBorder，项目名称:rb-bi，代码行数:25，代码来源:ConvertTestCase.java

示例4: testFilterQuery89

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testFilterQuery89() throws InterruptedException {
    log.info("Filter test89");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream(QueryFactory.createStreamDefinition().name("cseEventStream").attribute("symbol", Attribute.Type.STRING).attribute("price", Attribute.Type.FLOAT).attribute("volume", Attribute.Type.DOUBLE).attribute("quantity", Attribute.Type.INT));

    String queryReference = siddhiManager.addQuery("from cseEventStream[quantity < 50d] select symbol,price,quantity;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            count++;
        }
    });

    inputHandler.send(new Object[]{"WSO2", 50f, 60d, 6});
    inputHandler.send(new Object[]{"WSO2", 70f, 40d, 10});
    inputHandler.send(new Object[]{"WSO2", 44f, 200d, 56});
    Thread.sleep(100);
    Assert.assertEquals(2, count);
    siddhiManager.shutdown();

}

开发者ID:redBorder，项目名称:rb-bi，代码行数:26，代码来源:FilterTestCase.java

示例5: testFilterQuery87

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testFilterQuery87() throws InterruptedException {
    log.info("Filter test87");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream(QueryFactory.createStreamDefinition().name("cseEventStream").attribute("symbol", Attribute.Type.STRING).attribute("price", Attribute.Type.FLOAT).attribute("volume", Attribute.Type.DOUBLE));

    String queryReference = siddhiManager.addQuery("from cseEventStream[price < 50d] select symbol,price;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            count++;
        }
    });

    inputHandler.send(new Object[]{"WSO2", 50f, 60d});
    inputHandler.send(new Object[]{"WSO2", 70f, 40d});
    inputHandler.send(new Object[]{"WSO2", 44f, 200d});
    Thread.sleep(100);
    Assert.assertEquals(1, count);
    siddhiManager.shutdown();

}

开发者ID:redBorder，项目名称:rb-bi，代码行数:26，代码来源:FilterTestCase.java

示例6: process

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
public BundleEvent process(BundleEvent bundleEvent) {
    BundleEvent resultEvent = bundleEvent.getNewInstance();
    for (AtomicEvent event : bundleEvent.getEvents()) {
        if (conditionExecutor.execute(event)) {
            if (bundleEvent instanceof ListEvent) {
                ((ListEvent) resultEvent).addEvent((Event) event);
            } else {
                ((ListAtomicEvent) resultEvent).addEvent(event);

            }
        }
    }
    if (resultEvent.getActiveEvents() > 0) {
        return resultEvent;
    }
    return null;
}

开发者ID:redBorder，项目名称:rb-bi，代码行数:18，代码来源:FilterProcessor.java

示例7: testFilterQuery35

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testFilterQuery35() throws InterruptedException {
    log.info("Filter test35");

    SiddhiManager siddhiManager = new SiddhiManager();

    InputHandler inputHandler = siddhiManager.defineStream("define stream cseEventStream (symbol string, price double, volume int)");
    String queryReference = siddhiManager.addQuery("from cseEventStream[price != 50f ] select symbol,price,volume insert into outputStream ;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            count++;
        }
    });

    inputHandler.send(new Object[]{"WSO2", 50d, 50});
    inputHandler.send(new Object[]{"IBM", 55d, 100});
    Thread.sleep(100);
    Assert.assertEquals(1, count);
    siddhiManager.shutdown();
}

开发者ID:redBorder，项目名称:rb-bi，代码行数:24，代码来源:FilterTestCase.java

示例8: testFilterQuery102

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testFilterQuery102() throws InterruptedException {
    log.info("Filter test102");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream(QueryFactory.createStreamDefinition().name("cseEventStream").attribute("symbol", Attribute.Type.STRING).attribute("price", Attribute.Type.FLOAT).attribute("volume", Attribute.Type.DOUBLE));

    String queryReference = siddhiManager.addQuery("from cseEventStream[price >= 55f] select symbol,price;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            count++;
        }
    });

    inputHandler.send(new Object[]{"WSO2", 50f, 60d});
    inputHandler.send(new Object[]{"WSO2", 70f, 40d});
    inputHandler.send(new Object[]{"WSO2", 44f, 200d});
    Thread.sleep(100);
    Assert.assertEquals(1, count);
    siddhiManager.shutdown();

}

开发者ID:redBorder，项目名称:rb-bi，代码行数:26，代码来源:FilterTestCase.java

示例9: testConvertFunctionQuery7

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test(expected = QueryCreationException.class)
public void testConvertFunctionQuery7() throws InterruptedException {
    log.info("ConvertFunction test7");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream("define stream typeStream (typeS string, typeF float, typeD double, typeI int, typeL long, typeB bool) ");


    String queryReference = siddhiManager.addQuery("from typeStream " +
                                                   " select convert(typeS,int,'dd:MM:yy') as type1;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            eventCount++;
        }
    });

    inputHandler.send(new Object[]{"23:01:13", 1f, 1d, 1, 1l, true});
    junit.framework.Assert.assertEquals(1, eventCount);
    siddhiManager.shutdown();
}

开发者ID:redBorder，项目名称:rb-bi，代码行数:24，代码来源:ConvertTestCase.java

示例10: testFilterQuery36

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testFilterQuery36() throws InterruptedException {
    log.info("Filter test36");

    SiddhiManager siddhiManager = new SiddhiManager();

    InputHandler inputHandler = siddhiManager.defineStream("define stream cseEventStream (symbol string, price double, volume int)");
    String queryReference = siddhiManager.addQuery("from cseEventStream[price != 50d ] select symbol,price,volume insert into outputStream ;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            count++;
        }
    });

    inputHandler.send(new Object[]{"WSO2", 50d, 50});
    inputHandler.send(new Object[]{"IBM", 55d, 100});
    Thread.sleep(100);
    Assert.assertEquals(1, count);
    siddhiManager.shutdown();
}

开发者ID:redBorder，项目名称:rb-bi，代码行数:24，代码来源:FilterTestCase.java

示例11: testConvertFunctionQuery14

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testConvertFunctionQuery14() throws InterruptedException {
    log.info("ConvertFunction test14");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream("define stream typeStream (typeS string, typeSF string, typeSF2 string, typeD double, typeI int, typeL long, typeB bool) ");


    String queryReference = siddhiManager.addQuery("from typeStream " +
                                                   " select convert(typeS, string,\"dd:MM:yy\",typeSF2) as type1;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            eventCount++;
            Assert.assertEquals("01-23-13", inEvents[0].getData0());
        }
    });

    inputHandler.send(new Object[]{"23:01:13", "", "MM-dd-yy", 1d, 1, 1373043027082l, true});
    junit.framework.Assert.assertEquals(1, eventCount);
    siddhiManager.shutdown();
}

开发者ID:redBorder，项目名称:rb-bi，代码行数:25，代码来源:ConvertTestCase.java

示例12: testFilterQuery64

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testFilterQuery64() throws InterruptedException {
    log.info("Filter test64");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream(QueryFactory.createStreamDefinition().name("cseEventStream").attribute("symbol", Attribute.Type.STRING).attribute("price", Attribute.Type.FLOAT).attribute("volume", Attribute.Type.LONG));

    String queryReference = siddhiManager.addQuery("from cseEventStream[volume == 40f ] select symbol,price insert into outputStream;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            count++;
        }
    });

    inputHandler.send(new Object[]{"WSO2", 50f, 60l});
    inputHandler.send(new Object[]{"WSO2", 70f, 40l});
    inputHandler.send(new Object[]{"WSO2", 44f, 200l});
    Thread.sleep(100);
    Assert.assertEquals(1, count);
    siddhiManager.shutdown();

}

开发者ID:redBorder，项目名称:rb-bi，代码行数:26，代码来源:FilterTestCase.java

示例13: testConvertFunctionQuery4

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test(expected = QueryCreationException.class)
public void testConvertFunctionQuery4() throws InterruptedException {
    log.info("ConvertFunction test4");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream("define stream typeStream (typeS string, typeF float, typeD double, typeI int, typeL long, typeB bool) ");


    String queryReference = siddhiManager.addQuery("from typeStream " +
                                                   " select convert(string) as type1;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            eventCount++;
        }
    });

    inputHandler.send(new Object[]{"true", 1f, 1d, 1, 1l, true});
    junit.framework.Assert.assertEquals(0, eventCount);
    siddhiManager.shutdown();

}

开发者ID:redBorder，项目名称:rb-bi，代码行数:25，代码来源:ConvertTestCase.java

示例14: testFilterQuery41

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testFilterQuery41() throws InterruptedException {
    log.info("Filter test41");

    SiddhiManager siddhiManager = new SiddhiManager();

    InputHandler inputHandler = siddhiManager.defineStream("define stream cseEventStream (symbol string, price double, volume int)");
    String queryReference = siddhiManager.addQuery("from cseEventStream[price > 50 ] select symbol,price,volume insert into outputStream ;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            count++;
        }
    });

    inputHandler.send(new Object[]{"WSO2", 50d, 50});
    inputHandler.send(new Object[]{"IBM", 55d, 100});
    Thread.sleep(100);
    Assert.assertEquals(1, count);
    siddhiManager.shutdown();
}

开发者ID:redBorder，项目名称:rb-bi，代码行数:24，代码来源:FilterTestCase.java

示例15: testFilterQuery68

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testFilterQuery68() throws InterruptedException {
    log.info("Filter test68");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream(QueryFactory.createStreamDefinition().name("cseEventStream").attribute("symbol", Attribute.Type.STRING).attribute("price", Attribute.Type.DOUBLE).attribute("volume", Attribute.Type.LONG));

    String queryReference = siddhiManager.addQuery("from cseEventStream[price <= 100f] select symbol,price insert into outputStream;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            count++;
        }
    });

    inputHandler.send(new Object[]{"WSO2", 50d, 60l});
    inputHandler.send(new Object[]{"WSO2", 70d, 40l});
    inputHandler.send(new Object[]{"WSO2", 44d, 200l});
    Thread.sleep(100);
    Assert.assertEquals(3, count);
    siddhiManager.shutdown();

}

开发者ID:redBorder，项目名称:rb-bi，代码行数:26，代码来源:FilterTestCase.java

示例16: testConvertFunctionQuery10

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testConvertFunctionQuery10() throws InterruptedException {
    log.info("ConvertFunction test10");

    SiddhiManager siddhiManager = new SiddhiManager();
    InputHandler inputHandler = siddhiManager.defineStream("define stream typeStream (typeS string, typeSF string, typeD double, typeI int, typeL long, typeB bool) ");


    String queryReference = siddhiManager.addQuery("from typeStream " +
                                                   " select convert(typeS,long,typeSF) as type1;");

    siddhiManager.addCallback(queryReference, new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(timeStamp, inEvents, removeEvents);
            eventCount++;
            Assert.assertEquals(1358899200000l, inEvents[0].getData0());

        }
    });

    inputHandler.send(new Object[]{"23:01:13", "DD:MM:yy", 1d, 1, 1l, true});
    junit.framework.Assert.assertEquals(1, eventCount);
    siddhiManager.shutdown();
}

开发者ID:redBorder，项目名称:rb-bi，代码行数:26，代码来源:ConvertTestCase.java

示例17: testClusTree2D_27

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testClusTree2D_27() throws Exception {
    logger.info("ClusTreeStreamProcessorExtension Test - Test case to demo separate thread training");
    SiddhiManager siddhiManager = new SiddhiManager();
    String inputStream = "define stream InputStream (x double, y double);";

    String query = (
            "@info(name = 'query1') " +
                    "from InputStream#streamingml:clusTree(2, x, y) " +
                    "select closestCentroidCoordinate1, closestCentroidCoordinate2, x, y " +
                    "insert into OutputStream;");
    SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(inputStream + query);

    siddhiAppRuntime.addCallback("query1", new QueryCallback() {
        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            EventPrinter.print(inEvents);
        }
    });

    siddhiAppRuntime.start();
    InputHandler inputHandler = siddhiAppRuntime.getInputHandler("InputStream");
    Random random = new Random();
    try {
        for (int i = 0; i < 1100; i++) {
            inputHandler.send(new Object[]{random.nextInt(50), random.nextInt(50)});
            inputHandler.send(new Object[]{random.nextInt(50) + 100, random.nextInt(50) + 100});
        }
    } catch (Exception e) {
        logger.error(e.getCause().getMessage());
    } finally {
        siddhiAppRuntime.shutdown();
    }
}

开发者ID:wso2-extensions，项目名称:siddhi-gpl-execution-streamingml，代码行数:35，代码来源:ClusTreeStreamProcessorExtensionTest.java

示例18: testHoeffdingClassifierLearningExtension5

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
@Test
public void testHoeffdingClassifierLearningExtension5() throws InterruptedException {
    logger.info("HoeffdingClassifierUpdaterStreamProcessorExtension TestCase - Label is of bool type");

    SiddhiManager siddhiManager = new SiddhiManager();

    String inStreamDefinition = "define stream StreamA (attribute_0 double, attribute_1 double, attribute_2 "
            + "double, attribute_3 double, attribute_4 bool );";

    String query = ("@info(name = 'query1') from StreamA#streamingml:updateHoeffdingTree('model1', 2, "
            + "attribute_0, attribute_1 , attribute_2 ,attribute_3,attribute_4) select attribute_0, "
            + "attribute_1, attribute_2, attribute_3, accuracy insert into"
            + " outputStream;");

    SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(inStreamDefinition + query);
    siddhiAppRuntime.addCallback("query1", new QueryCallback() {

        @Override
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) {
            count.incrementAndGet();
            EventPrinter.print(inEvents);
        }
    });
    try {
        InputHandler inputHandler = siddhiAppRuntime.getInputHandler("StreamA");
        siddhiAppRuntime.start();
        inputHandler.send(new Object[]{0.1, 0.8, 0.2, 0.03, true});
        inputHandler.send(new Object[]{0.2, 0.95, 0.22, 0.1, true});
        inputHandler.send(new Object[]{0.8, 0.1, 0.65, 0.92, false});
        inputHandler.send(new Object[]{0.75, 0.1, 0.58, 0.71, false});

        SiddhiTestHelper.waitForEvents(200, 4, count, 60000);

    } catch (Exception e) {
        logger.error(e.getCause().getMessage());
    } finally {
        siddhiAppRuntime.shutdown();
    }
}

开发者ID:wso2-extensions，项目名称:siddhi-gpl-execution-streamingml，代码行数:40，代码来源:HoeffdingClassifierUpdaterStreamProcessorExtensionTestCase.java

示例19: constructSingleEventForDefaultMapping

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
private JsonObject constructSingleEventForDefaultMapping(Event event) {
    Object[] data = event.getData();
    JsonObject jsonEventObject = new JsonObject();
    JsonObject innerParentObject = new JsonObject();
    String attributeName;
    Object attributeValue;
    Gson gson = new Gson();
    for (int i = 0; i < data.length; i++) {
        attributeName = attributeNameArray[i];
        attributeValue = data[i];
        if (attributeValue != null) {
            if (attributeValue.getClass() == String.class) {
                innerParentObject.addProperty(attributeName, attributeValue.toString());
            } else if (attributeValue instanceof Number) {
                innerParentObject.addProperty(attributeName, (Number) attributeValue);
            } else if (attributeValue instanceof Boolean) {
                innerParentObject.addProperty(attributeName, (Boolean) attributeValue);
            } else if (attributeValue instanceof Map) {
                if (!((Map) attributeValue).isEmpty()) {
                    innerParentObject.add(attributeName, gson.toJsonTree(attributeValue));
                }
            }
        }
    }
    jsonEventObject.add(EVENT_PARENT_TAG, innerParentObject);
    return jsonEventObject;
}

开发者ID:wso2-extensions，项目名称:siddhi-map-json，代码行数:28，代码来源:JsonSinkMapper.java

示例20: doPartialProcessing

import org.wso2.siddhi.core.event.Event; //导入依赖的package包/类
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;
}

开发者ID:wso2-extensions，项目名称:siddhi-map-json，代码行数:10，代码来源:JsonSinkMapper.java

注：本文中的org.wso2.siddhi.core.event.Event类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java R类代码示例发布时间：2022-05-21

Java TextureLoader类代码示例发布时间：2022-05-21

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18818|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9870|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8283|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8639|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8569|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9573|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8560|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7959|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8567|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7496|2022-11-06

客服电话

电子邮件

Java Event类代码示例

示例1: testClusTree2D_24

示例2: mapAndSend

示例3: testConvertFunctionQuery8

示例4: testFilterQuery89

示例5: testFilterQuery87

示例6: process

示例7: testFilterQuery35

示例8: testFilterQuery102

示例9: testConvertFunctionQuery7

示例10: testFilterQuery36

示例11: testConvertFunctionQuery14

示例12: testFilterQuery64

示例13: testConvertFunctionQuery4

示例14: testFilterQuery41

示例15: testFilterQuery68

示例16: testConvertFunctionQuery10

示例17: testClusTree2D_27

示例18: testHoeffdingClassifierLearningExtension5

示例19: constructSingleEventForDefaultMapping

示例20: doPartialProcessing

请发表评论

全部评论

上一篇：

下一篇：

krishnaik06/Machine-Learning-in-90-days

CVE-2022-1794

armancodv/building-energy-model-matlab:

美元符号为什么是“$”

edenhill/librdkafka: The Apache Kafka C/

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053