Class RedisKeyValueStateProvider

    • Constructor Detail

      • RedisKeyValueStateProvider

        public RedisKeyValueStateProvider()
    • Method Detail

      • newState

        public State newState​(String namespace,
                              Map<String,​Object> topoConf,
                              TopologyContext context)
        Description copied from interface: StateProvider
        Returns a new state instance. Each state belongs unique namespace which is typically the componentid-task of the task, so that each task can have its own unique state.
        Specified by:
        newState in interface StateProvider
        Parameters:
        namespace - a namespace of the state
        topoConf - the storm topology configuration
        context - the TopologyContext
        Returns:
        a previously saved state if one exists otherwise a newly initialized state.