本文整理汇总了Java中backtype.storm.testing.FeederSpout类的典型用法代码示例。如果您正苦于以下问题:Java FeederSpout类的具体用法?Java FeederSpout怎么用?Java FeederSpout使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
FeederSpout类属于backtype.storm.testing包,在下文中一共展示了FeederSpout类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: main
import backtype.storm.testing.FeederSpout; //导入依赖的package包/类
public static void main(String[] args) {
FeederSpout genderSpout = new FeederSpout(new Fields("id", "gender"));
FeederSpout ageSpout = new FeederSpout(new Fields("id", "age"));
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("gender", genderSpout);
builder.setSpout("age", ageSpout);
builder.setBolt("join", new SingleJoinBolt(new Fields("gender", "age"))).fieldsGrouping("gender", new Fields("id"))
.fieldsGrouping("age", new Fields("id"));
Config conf = new Config();
conf.setDebug(true);
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("join-example", conf, builder.createTopology());
for (int i = 0; i < 10; i++) {
String gender;
if (i % 2 == 0) {
gender = "male";
}
else {
gender = "female";
}
genderSpout.feed(new Values(i, gender));
}
for (int i = 9; i >= 0; i--) {
ageSpout.feed(new Values(i, i + 20));
}
Utils.sleep(2000);
cluster.shutdown();
}
开发者ID:luozhaoyu,项目名称:big-data-system,代码行数:35,代码来源:SingleJoinExample.java
示例2: test_single_join
import backtype.storm.testing.FeederSpout; //导入依赖的package包/类
@Test
public void test_single_join() {
try {
FeederSpout genderSpout = new FeederSpout(new Fields("id", "gender"));
FeederSpout ageSpout = new FeederSpout(new Fields("id", "age"));
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("gender", genderSpout);
builder.setSpout("age", ageSpout);
builder.setBolt("join", new SingleJoinBolt(new Fields("gender", "age"))).fieldsGrouping("gender", new Fields("id"))
.fieldsGrouping("age", new Fields("id"));
Config conf = new Config();
conf.setDebug(true);
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("join-example", conf, builder.createTopology());
for (int i = 0; i < 10; i++) {
String gender;
if (i % 2 == 0) {
gender = "male";
} else {
gender = "female";
}
genderSpout.feed(new Values(i, gender));
}
for (int i = 9; i >= 0; i--) {
ageSpout.feed(new Values(i, i + 20));
}
JStormUtils.sleepMs(60 * 1000);
cluster.shutdown();
} catch (Exception e) {
Assert.fail("Failed to run SingleJoinExample");
}
}
开发者ID:kkllwww007,项目名称:jstrom,代码行数:39,代码来源:SingleJoinTest.java
示例3: main
import backtype.storm.testing.FeederSpout; //导入依赖的package包/类
public static void main(String[] args) {
FeederSpout genderSpout = new FeederSpout(new Fields("id", "gender"));
FeederSpout ageSpout = new FeederSpout(new Fields("id", "age"));
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("gender", genderSpout);
builder.setSpout("age", ageSpout);
builder.setBolt("join", new SimpleJoinBolt(new Fields("gender", "age"))).fieldsGrouping("gender", new Fields("id"))
.fieldsGrouping("age", new Fields("id"));
builder.setBolt("printer", new PrinterBolt()).shuffleGrouping("join");
Config conf = new Config();
conf.setDebug(true);
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("join-example", conf, builder.createTopology());
for (int i = 0; i < 10; i++) {
String gender;
if (i % 2 == 0) {
gender = "male";
}
else {
gender = "female";
}
genderSpout.feed(new Values(i, gender));
}
for (int i = 9; i >= 0; i--) {
ageSpout.feed(new Values(i, i + 20));
}
Utils.sleep(2000);
cluster.shutdown();
}
开发者ID:allaves,项目名称:storm-query-operators,代码行数:36,代码来源:SingleJoinExample.java
示例4: main
import backtype.storm.testing.FeederSpout; //导入依赖的package包/类
public static void main(String[] args) {
// Define the spouts
FeederSpout observationSpout = new FeederSpout(new Fields("obsId", "observedProperty", "value", "uom", "timestamp", "sensorId"));
FeederSpout sensorSpout = new FeederSpout(new Fields("sensorId", "lat", "lon"));
// Define the topology
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("observation", observationSpout);
builder.setSpout("sensor", sensorSpout);
builder.setBolt("join", new ExtendedSingleJoinBolt(new Fields("obsId", "observedProperty", "value", "uom", "timestamp", "lat", "lon")))
.fieldsGrouping("sensor", new Fields("sensorId")).fieldsGrouping("observation", new Fields("sensorId"));
builder.setBolt("printer", new AckerPrinterBolt()).shuffleGrouping("join");
Config conf = new Config();
//conf.setDebug(true);
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("extended-join-example", conf, builder.createTopology());
try {
// Simulate data - Feed the spouts
for (int i = 9; i >= 0; i--) {
sensorSpout.feed(new Values(i, 40.4055389 - i, 10.8399527 - i));
Thread.sleep(500);
}
for (int i = 0; i < 50; i++) {
observationSpout.feed(new Values(i, "temperature", Math.random()%10, "degrees Celsius", new Date(System.currentTimeMillis()), i%10));
Thread.sleep(100);
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Utils.sleep(10000);
cluster.shutdown();
}
开发者ID:allaves,项目名称:storm-query-operators,代码行数:40,代码来源:ExtendedSingleJoinExample.java
示例5: main
import backtype.storm.testing.FeederSpout; //导入依赖的package包/类
public static void main(String[] args) {
FeederSpout genderSpout = new FeederSpout(new Fields("id", "gender"));
FeederSpout ageSpout = new FeederSpout(new Fields("id", "age"));
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("gender", genderSpout);
builder.setSpout("age", ageSpout);
builder.setBolt("join", new SingleJoinBolt(new Fields("gender", "age")))
.fieldsGrouping("gender", new Fields("id"))
.fieldsGrouping("age", new Fields("id"));
Config conf = new Config();
conf.setDebug(true);
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("join-example", conf, builder.createTopology());
for(int i=0; i<10; i++) {
String gender;
if(i % 2 == 0) {
gender = "male";
} else {
gender = "female";
}
genderSpout.feed(new Values(i, gender));
}
for(int i=9; i>=0; i--) {
ageSpout.feed(new Values(i, i+20));
}
Utils.sleep(2000);
cluster.shutdown();
}
开发者ID:adarshms,项目名称:sentweet,代码行数:35,代码来源:SingleJoinExample.java
示例6: test_single_join
import backtype.storm.testing.FeederSpout; //导入依赖的package包/类
@Test
public void test_single_join() {
try {
FeederSpout genderSpout = new FeederSpout(
new Fields("id", "gender"));
FeederSpout ageSpout = new FeederSpout(new Fields("id", "age"));
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("gender", genderSpout);
builder.setSpout("age", ageSpout);
builder.setBolt("join",
new SingleJoinBolt(new Fields("gender", "age")))
.fieldsGrouping("gender", new Fields("id"))
.fieldsGrouping("age", new Fields("id"));
Config conf = new Config();
conf.setDebug(true);
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("join-example", conf,
builder.createTopology());
for (int i = 0; i < 10; i++) {
String gender;
if (i % 2 == 0) {
gender = "male";
} else {
gender = "female";
}
genderSpout.feed(new Values(i, gender));
}
for (int i = 9; i >= 0; i--) {
ageSpout.feed(new Values(i, i + 20));
}
JStormUtils.sleepMs(60 * 1000);
cluster.shutdown();
} catch (Exception e) {
Assert.fail("Failed to run SingleJoinExample");
}
}
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:43,代码来源:SingleJoinTest.java
示例7: test_single_join
import backtype.storm.testing.FeederSpout; //导入依赖的package包/类
@Test
public void test_single_join() {
receiveCounter.set(0);
try {
FeederSpout genderSpout = new FeederSpout(new Fields("id", "gender"));
FeederSpout ageSpout = new FeederSpout(new Fields("id", "age"));
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("gender", genderSpout);
builder.setSpout("age", ageSpout);
builder.setBolt("join", new SingleJoinBolt(new Fields("gender", "age")))
.fieldsGrouping("gender", new Fields("id")).fieldsGrouping("age", new Fields("id"));
Config conf = new Config();
conf.setDebug(true);
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("join-example", conf, builder.createTopology());
for (int i = 0; i < 10; i++) {
String gender;
if (i % 2 == 0) {
gender = "male";
} else {
gender = "female";
}
genderSpout.feed(new Values(i, gender));
}
for (int i = 9; i >= 0; i--) {
ageSpout.feed(new Values(i, i + 20));
}
JStormUtils.sleepMs(60 * 1000);
assertNotSame(0, receiveCounter.get());
cluster.shutdown();
} catch (Exception e) {
Assert.fail("Failed to run SingleJoinExample");
}
}
开发者ID:alibaba,项目名称:jstorm,代码行数:43,代码来源:SingleJoinTest.java
注:本文中的backtype.storm.testing.FeederSpout类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论