class FlinkTopologyContext extends TopologyContext {

	@Override
	public <T extends ISubscribedState> T setSubscribedState(final String componentId, final T obj) {
		throw new UnsupportedOperationException("Not supported by Flink");
	}

	  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);

}