Package org.apache.storm.flux
Class FluxBuilder
java.lang.Object
org.apache.storm.flux.FluxBuilder
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic ConfigbuildConfig(TopologyDef topologyDef) Given a topology definition, return a populated `org.apache.storm.Config` instance.static StormTopologybuildTopology(ExecutionContext context) Given a topology definition, return a Storm topology that can be run either locally or remotely.static voidinvokeConfigMethods(ObjectDef bean, Object instance, ExecutionContext context) Invokes configuration methods on an class instance.static booleanisPrimitiveBoolean(Class clazz) static booleanisPrimitiveNumber(Class clazz) 
- 
Constructor Details- 
FluxBuilderpublic FluxBuilder()
 
- 
- 
Method Details- 
buildConfigGiven a topology definition, return a populated `org.apache.storm.Config` instance.- Parameters:
- topologyDef- topology definition
- Returns:
- a Storm Config object
 
- 
buildTopologypublic static StormTopology buildTopology(ExecutionContext context) throws IllegalAccessException, InstantiationException, ClassNotFoundException, NoSuchMethodException, InvocationTargetException, NoSuchFieldException Given a topology definition, return a Storm topology that can be run either locally or remotely.- Parameters:
- context- execution context
- Returns:
- A runable Storm topology
- Throws:
- IllegalAccessException- if security policy disallows operation
- InstantiationException- if a class can't be instantiated
- ClassNotFoundException- if a class can't be found
- NoSuchMethodException- if a method can't be found
- InvocationTargetException- if method invocation fails
- NoSuchFieldException- if a referenced field does not exist
 
- 
invokeConfigMethodspublic static void invokeConfigMethods(ObjectDef bean, Object instance, ExecutionContext context) throws InvocationTargetException, IllegalAccessException Invokes configuration methods on an class instance.- Parameters:
- bean- the bean/component definition
- instance- the class instance being operated on
- context- execution context
- Throws:
- InvocationTargetException- if method invocation fails
- IllegalAccessException- if security policy prefents invocation
 
- 
isPrimitiveNumber
- 
isPrimitiveBoolean
 
-