test_class.file: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/FlinkTopologyContextTest.java
test_class.identifier: FlinkTopologyContextTest
test_class.superclass: extends AbstractTest
test_case.body: @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);
  	}
test_case.class_method_signature: FlinkTopologyContextTest.testSetSubscribedState1()
test_case.full_signature: @Test(expected = UnsupportedOperationException.class) public void testSetSubscribedState1()
test_case.identifier: testSetSubscribedState1
test_case.invocations: setSubscribedState
test_case.modifiers: @Test(expected = UnsupportedOperationException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSetSubscribedState1()
focal_class.file: flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/FlinkTopologyContext.java
focal_class.identifier: FlinkTopologyContext
focal_class.class_method_signature: FlinkTopologyContext.FlinkTopologyContext(final StormTopology topology,
  			@SuppressWarnings("rawtypes") final Map stormConf,
  			final Map<Integer, String> taskToComponent, final Map<String, List<Integer>> componentToSortedTasks,
  			final Map<String, Map<String, Fields>> componentToStreamToFields, final String stormId, final String codeDir,
  			final String pidDir, final Integer taskId, final Integer workerPort, final List<Integer> workerTasks,
  			final Map<String, Object> defaultResources, final Map<String, Object> userResources,
  			final Map<String, Object> executorData, @SuppressWarnings("rawtypes") final Map registeredMetrics,
  			final Atom openOrPrepareWasCalled)
focal_class.full_signature:   FlinkTopologyContext(final StormTopology topology,
  			@SuppressWarnings("rawtypes") final Map stormConf,
  			final Map<Integer, String> taskToComponent, final Map<String, List<Integer>> componentToSortedTasks,
  			final Map<String, Map<String, Fields>> componentToStreamToFields, final String stormId, final String codeDir,
  			final String pidDir, final Integer taskId, final Integer workerPort, final List<Integer> workerTasks,
  			final Map<String, Object> defaultResources, final Map<String, Object> userResources,
  			final Map<String, Object> executorData, @SuppressWarnings("rawtypes") final Map registeredMetrics,
  			final Atom openOrPrepareWasCalled)
focal_class.identifier: FlinkTopologyContext
focal_class.parameters: (final StormTopology topology,
  			@SuppressWarnings("rawtypes") final Map stormConf,
  			final Map<Integer, String> taskToComponent, final Map<String, List<Integer>> componentToSortedTasks,
  			final Map<String, Map<String, Fields>> componentToStreamToFields, final String stormId, final String codeDir,
  			final String pidDir, final Integer taskId, final Integer workerPort, final List<Integer> workerTasks,
  			final Map<String, Object> defaultResources, final Map<String, Object> userResources,
  			final Map<String, Object> executorData, @SuppressWarnings("rawtypes") final Map registeredMetrics,
  			final Atom openOrPrepareWasCalled)
focal_class.signature:  FlinkTopologyContext(final StormTopology topology,
  			@SuppressWarnings("rawtypes") final Map stormConf,
  			final Map<Integer, String> taskToComponent, final Map<String, List<Integer>> componentToSortedTasks,
  			final Map<String, Map<String, Fields>> componentToStreamToFields, final String stormId, final String codeDir,
  			final String pidDir, final Integer taskId, final Integer workerPort, final List<Integer> workerTasks,
  			final Map<String, Object> defaultResources, final Map<String, Object> userResources,
  			final Map<String, Object> executorData, @SuppressWarnings("rawtypes") final Map registeredMetrics,
  			final Atom openOrPrepareWasCalled)
focal_class.class_method_signature: FlinkTopologyContext.addTaskHook(final ITaskHook hook)
focal_class.full_signature: @Override public void addTaskHook(final ITaskHook hook)
focal_class.identifier: addTaskHook
focal_class.modifiers: @Override public
focal_class.parameters: (final ITaskHook hook)
focal_class.return: void
focal_class.signature: void addTaskHook(final ITaskHook hook)
focal_class.class_method_signature: FlinkTopologyContext.getHooks()
focal_class.full_signature: @Override public Collection<ITaskHook> getHooks()
focal_class.identifier: getHooks
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<ITaskHook>
focal_class.signature: Collection<ITaskHook> getHooks()
focal_class.class_method_signature: FlinkTopologyContext.getRegisteredMetricByName(final String name)
focal_class.full_signature: @Override public IMetric getRegisteredMetricByName(final String name)
focal_class.identifier: getRegisteredMetricByName
focal_class.modifiers: @Override public
focal_class.parameters: (final String name)
focal_class.return: IMetric
focal_class.signature: IMetric getRegisteredMetricByName(final String name)
focal_class.class_method_signature: FlinkTopologyContext.registerMetric(final String name, final ICombiner combiner, final int timeBucketSizeInSecs)
focal_class.full_signature: @SuppressWarnings("rawtypes") @Override public CombinedMetric registerMetric(final String name, final ICombiner combiner, final int timeBucketSizeInSecs)
focal_class.identifier: registerMetric
focal_class.modifiers: @SuppressWarnings("rawtypes") @Override public
focal_class.parameters: (final String name, final ICombiner combiner, final int timeBucketSizeInSecs)
focal_class.return: CombinedMetric
focal_class.signature: CombinedMetric registerMetric(final String name, final ICombiner combiner, final int timeBucketSizeInSecs)
focal_class.class_method_signature: FlinkTopologyContext.registerMetric(final String name, final IReducer combiner, final int timeBucketSizeInSecs)
focal_class.full_signature: @SuppressWarnings("rawtypes") @Override public ReducedMetric registerMetric(final String name, final IReducer combiner, final int timeBucketSizeInSecs)
focal_class.identifier: registerMetric
focal_class.modifiers: @SuppressWarnings("rawtypes") @Override public
focal_class.parameters: (final String name, final IReducer combiner, final int timeBucketSizeInSecs)
focal_class.return: ReducedMetric
focal_class.signature: ReducedMetric registerMetric(final String name, final IReducer combiner, final int timeBucketSizeInSecs)
focal_class.class_method_signature: FlinkTopologyContext.registerMetric(final String name, final IMetric metric, final int timeBucketSizeInSecs)
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public IMetric registerMetric(final String name, final IMetric metric, final int timeBucketSizeInSecs)
focal_class.identifier: registerMetric
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: (final String name, final IMetric metric, final int timeBucketSizeInSecs)
focal_class.return: IMetric
focal_class.signature: IMetric registerMetric(final String name, final IMetric metric, final int timeBucketSizeInSecs)
focal_class.class_method_signature: FlinkTopologyContext.setAllSubscribedState(final T obj)
focal_class.full_signature: @Override public T setAllSubscribedState(final T obj)
focal_class.identifier: setAllSubscribedState
focal_class.modifiers: @Override public
focal_class.parameters: (final T obj)
focal_class.return: T
focal_class.signature: T setAllSubscribedState(final T obj)
focal_class.class_method_signature: FlinkTopologyContext.setSubscribedState(final String componentId, final T obj)
focal_class.full_signature: @Override public T setSubscribedState(final String componentId, final T obj)
focal_class.identifier: setSubscribedState
focal_class.modifiers: @Override public
focal_class.parameters: (final String componentId, final T obj)
focal_class.return: T
focal_class.signature: T setSubscribedState(final String componentId, final T obj)
focal_class.class_method_signature: FlinkTopologyContext.setSubscribedState(final String componentId, final String streamId, final T
  			obj)
focal_class.full_signature: @Override public T setSubscribedState(final String componentId, final String streamId, final T
  			obj)
focal_class.identifier: setSubscribedState
focal_class.modifiers: @Override public
focal_class.parameters: (final String componentId, final String streamId, final T
  			obj)
focal_class.return: T
focal_class.signature: T setSubscribedState(final String componentId, final String streamId, final T
  			obj)
focal_class.superclass: extends TopologyContext
focal_method.body: @Override
  	public <T extends ISubscribedState> T setSubscribedState(final String componentId, final T obj) {
  		throw new UnsupportedOperationException("Not supported by Flink");
  	}
focal_method.class_method_signature: FlinkTopologyContext.setSubscribedState(final String componentId, final T obj)
focal_method.full_signature: @Override public T setSubscribedState(final String componentId, final T obj)
focal_method.identifier: setSubscribedState
focal_method.modifiers: @Override public
focal_method.parameters: (final String componentId, final T obj)
focal_method.return: T
focal_method.signature: T setSubscribedState(final String componentId, final T obj)