@ Override public StormTopology getTopology ( String id ) throws TException { StormTopology topology ; try { StormTopology stormtopology = StormConfig . read_nimbus_topology_code ( id , data . getBlobStore ( ) ) ; if ( stormtopology == null ) { throw new NotAliveException ( "No topology of " + id ) ; } Map < Object , Object > topologyConf = ( Map < Object , Object > ) StormConfig . read_nimbus_topology_conf ( id , data . getBlobStore ( ) ) ; topology = Common . system_topology ( topologyConf , stormtopology ) ; } catch ( Exception e ) { LOG . error ( "Failed to get topology " + id + "," , e ) ; throw new TException ( "Failed to get system_topology" ) ; } return topology ; }
get StormTopology throw deserialize local files