Package storm.trident.state.map

Examples of storm.trident.state.map.MapState


  @Override
  public State makeState(Map conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
    HBaseAggregateState state = new HBaseAggregateState(config);
    CachedMap c = new CachedMap(state, config.getStateCacheSize());

    MapState ms;
    if (type == StateType.NON_TRANSACTIONAL) {
      ms = NonTransactionalMap.build(c);
    } else if (type == StateType.OPAQUE) {
      ms = OpaqueMap.build(c);
    } else if (type == StateType.TRANSACTIONAL) {
View Full Code Here


        public State makeState(Map conf, IMetricsContext metrics, int partitionIndex, int numPartitions) {
            CassandraMapState state = new CassandraMapState(options, conf);

            CachedMap cachedMap = new CachedMap(state, options.localCacheSize);

            MapState mapState;
            if (stateType == StateType.NON_TRANSACTIONAL) {
                mapState = NonTransactionalMap.build(cachedMap);
            } else if (stateType == StateType.OPAQUE) {
                mapState = OpaqueMap.build(cachedMap);
            } else if (stateType == StateType.TRANSACTIONAL) {
View Full Code Here

TOP

Related Classes of storm.trident.state.map.MapState

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.