• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Bolt类代码示例

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

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



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

示例1: getTerminalUserBoltNames

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
public static Set<String> getTerminalUserBoltNames(StormTopology topology) {
    Set<String> terminalBolts = new HashSet<>();
    Set<String> inputs = new HashSet<>();
    for (Map.Entry<String, Bolt> entry : topology.get_bolts().entrySet()) {
        String name = entry.getKey();
        Set<GlobalStreamId> inputsForBolt = entry.getValue().get_common().get_inputs().keySet();
        if (!isSystemComponent(name)) {
            for (GlobalStreamId streamId : inputsForBolt) {
                inputs.add(streamId.get_componentId());
            }
        }
    }

    for (String boltName : topology.get_bolts().keySet()) {
        if (!isSystemComponent(boltName) && !inputs.contains(boltName)) {
            terminalBolts.add(boltName);
        }
    }

    return terminalBolts;
}
 
开发者ID:apache,项目名称:incubator-atlas,代码行数:22,代码来源:StormTopologyUtil.java


示例2: getAdjacencyMap

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
public static Map<String, Set<String>> getAdjacencyMap(StormTopology topology,
                                                       boolean removeSystemComponent)
throws Exception {
    Map<String, Set<String>> adjacencyMap = new HashMap<>();

    for (Map.Entry<String, Bolt> entry : topology.get_bolts().entrySet()) {
        String boltName = entry.getKey();
        Map<GlobalStreamId, Grouping> inputs = entry.getValue().get_common().get_inputs();
        for (Map.Entry<GlobalStreamId, Grouping> input : inputs.entrySet()) {
            String inputComponentId = input.getKey().get_componentId();
            Set<String> components = adjacencyMap.containsKey(inputComponentId)
                    ? adjacencyMap.get(inputComponentId) : new HashSet<String>();
            components.add(boltName);
            components = removeSystemComponent ? removeSystemComponents(components)
                    : components;
            if (!removeSystemComponent || !isSystemComponent(inputComponentId)) {
                adjacencyMap.put(inputComponentId, components);
            }
        }
    }

    return adjacencyMap;
}
 
开发者ID:apache,项目名称:incubator-atlas,代码行数:24,代码来源:StormTopologyUtil.java


示例3: addTopologyOutputs

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
private void addTopologyOutputs(Referenceable topologyReferenceable,
                                StormTopology stormTopology, String topologyOwner,
                                Map stormConf, List<Referenceable> dependentEntities) throws Exception {
    final ArrayList<Referenceable> outputDataSets = new ArrayList<>();

    Map<String, Bolt> bolts = stormTopology.get_bolts();
    Set<String> terminalBoltNames = StormTopologyUtil.getTerminalUserBoltNames(stormTopology);
    for (String terminalBoltName : terminalBoltNames) {
        Serializable instance = Utils.javaDeserialize(bolts.get(terminalBoltName)
                .get_bolt_object().get_serialized_java(), Serializable.class);

        String dataSetType = instance.getClass().getSimpleName();
        final Referenceable datasetRef = createDataSet(dataSetType, topologyOwner, instance, stormConf, dependentEntities);
        if (datasetRef != null) {
            outputDataSets.add(datasetRef);
        }
    }

    topologyReferenceable.set("outputs", outputDataSets);
}
 
开发者ID:apache,项目名称:incubator-atlas,代码行数:21,代码来源:StormAtlasHook.java


示例4: getRawTopology

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
/**
 * Gets the Thrift object representing the topology.
 *
 * @return the Thrift definition representing the topology
 */
@SuppressWarnings("deprecation")
public StormTopology getRawTopology() {

  StormTopology stormTopology = new StormTopology();
  Map<String, SpoutSpec> spouts = new HashMap<>();
  for (TopologyAPI.Spout spout : this.delegate.getRawTopology().getSpoutsList()) {
    spouts.put(spout.getComp().getName(), new SpoutSpec(spout));
  }

  Map<String, Bolt> bolts = new HashMap<>();
  for (TopologyAPI.Bolt bolt : this.delegate.getRawTopology().getBoltsList()) {
    bolts.put(bolt.getComp().getName(), new Bolt(bolt));
  }

  stormTopology.set_spouts(spouts);
  stormTopology.set_bolts(bolts);
  return stormTopology;
}
 
开发者ID:twitter,项目名称:heron,代码行数:24,代码来源:GeneralTopologyContext.java


示例5: testAddTaskHook

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@Test(expected = UnsupportedOperationException.class)
public void testAddTaskHook() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.addTaskHook(null);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:8,代码来源:FlinkTopologyContextTest.java


示例6: testGetHooks

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@Test(expected = UnsupportedOperationException.class)
public void testGetHooks() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.getHooks();
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:8,代码来源:FlinkTopologyContextTest.java


示例7: testRegisteredMetric1

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
@Test(expected = UnsupportedOperationException.class)
public void testRegisteredMetric1() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.registerMetric(null, (ICombiner) null, 0);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:9,代码来源:FlinkTopologyContextTest.java


示例8: testRegisteredMetric2

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
@Test(expected = UnsupportedOperationException.class)
public void testRegisteredMetric2() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.registerMetric(null, (IReducer) null, 0);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:9,代码来源:FlinkTopologyContextTest.java


示例9: testRegisteredMetric3

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@Test(expected = UnsupportedOperationException.class)
public void testRegisteredMetric3() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.registerMetric(null, (IMetric) null, 0);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:8,代码来源:FlinkTopologyContextTest.java


示例10: testGetRegisteredMetricByName

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@Test(expected = UnsupportedOperationException.class)
public void testGetRegisteredMetricByName() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.getRegisteredMetricByName(null);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:8,代码来源:FlinkTopologyContextTest.java


示例11: testSetAllSubscribedState

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@Test(expected = UnsupportedOperationException.class)
public void testSetAllSubscribedState() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.setAllSubscribedState(null);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:8,代码来源:FlinkTopologyContextTest.java


示例12: testSetSubscribedState1

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@Test(expected = UnsupportedOperationException.class)
public void testSetSubscribedState1() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.setSubscribedState(null, null);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:8,代码来源:FlinkTopologyContextTest.java


示例13: testSetSubscribedState2

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
@Test(expected = UnsupportedOperationException.class)
public void testSetSubscribedState2() {
	new FlinkTopologyContext(new StormTopology(new HashMap<String, SpoutSpec>(),
			new HashMap<String, Bolt>(), new HashMap<String, StateSpoutSpec>()), null, null,
			null, null, null, null, null, null, null, null, null, null, null, null, null)
	.setSubscribedState(null, null, null);
}
 
开发者ID:axbaretto,项目名称:flink,代码行数:8,代码来源:FlinkTopologyContextTest.java


示例14: createTopologyGraph

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
private ArrayList<Referenceable> createTopologyGraph(StormTopology stormTopology,
                                                     Map<String, SpoutSpec> spouts,
                                                     Map<String, Bolt> bolts) throws Exception {
    // Add graph of nodes in the topology
    final Map<String, Referenceable> nodeEntities = new HashMap<>();
    addSpouts(spouts, nodeEntities);
    addBolts(bolts, nodeEntities);

    addGraphConnections(stormTopology, nodeEntities);

    ArrayList<Referenceable> nodes = new ArrayList<>();
    nodes.addAll(nodeEntities.values());
    return nodes;
}
 
开发者ID:apache,项目名称:incubator-atlas,代码行数:15,代码来源:StormAtlasHook.java


示例15: addBolts

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
private void addBolts(Map<String, Bolt> bolts,
                      Map<String, Referenceable> nodeEntities) throws IllegalAccessException {
    for (Map.Entry<String, Bolt> entry : bolts.entrySet()) {
        Referenceable boltInstance = createBoltInstance(entry.getKey(), entry.getValue());
        nodeEntities.put(entry.getKey(), boltInstance);
    }
}
 
开发者ID:apache,项目名称:incubator-atlas,代码行数:8,代码来源:StormAtlasHook.java


示例16: createBoltInstance

import org.apache.storm.generated.Bolt; //导入依赖的package包/类
private Referenceable createBoltInstance(String boltName,
                                         Bolt stormBolt) throws IllegalAccessException {
    Referenceable boltReferenceable = new Referenceable(StormDataTypes.STORM_BOLT.getName());

    boltReferenceable.set(AtlasClient.NAME, boltName);

    Serializable instance = Utils.javaDeserialize(
            stormBolt.get_bolt_object().get_serialized_java(), Serializable.class);
    boltReferenceable.set("driverClass", instance.getClass().getName());

    Map<String, String> flatConfigMap = StormTopologyUtil.getFieldValues(instance, true, null);
    boltReferenceable.set("conf", flatConfigMap);

    return boltReferenceable;
}
 
开发者ID:apache,项目名称:incubator-atlas,代码行数:16,代码来源:StormAtlasHook.java



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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java RequestCall类代码示例发布时间:2022-05-22
下一篇:
Java ListenerMethod类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap