You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/06/02 17:00:36 UTC
[08/12] storm git commit: STORM-753 Replace wildcard imports to each
single class imports
STORM-753 Replace wildcard imports to each single class imports
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f8906fb4
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f8906fb4
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f8906fb4
Branch: refs/heads/master
Commit: f8906fb4d7750d5f009fccf98943060bb25e2f0c
Parents: 037a975
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Tue Jun 2 06:33:58 2015 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Jun 2 06:33:58 2015 +0900
----------------------------------------------------------------------
.../redis/trident/state/AbstractRedisMapState.java | 13 +++++++++++--
.../redis/trident/state/RedisClusterMapState.java | 15 ++++++++++++---
.../storm/redis/trident/state/RedisMapState.java | 15 ++++++++++++---
3 files changed, 35 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/f8906fb4/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisMapState.java
----------------------------------------------------------------------
diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisMapState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisMapState.java
index 56b37b2..b6fc8d7 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisMapState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisMapState.java
@@ -19,10 +19,19 @@ package org.apache.storm.redis.trident.state;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Maps;
-import storm.trident.state.*;
+import storm.trident.state.JSONNonTransactionalSerializer;
+import storm.trident.state.JSONOpaqueSerializer;
+import storm.trident.state.JSONTransactionalSerializer;
+import storm.trident.state.Serializer;
+import storm.trident.state.StateType;
import storm.trident.state.map.IBackingMap;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.EnumMap;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
public abstract class AbstractRedisMapState<T> implements IBackingMap<T> {
public static final EnumMap<StateType, Serializer> DEFAULT_SERIALIZERS = Maps.newEnumMap(ImmutableMap.of(
http://git-wip-us.apache.org/repos/asf/storm/blob/f8906fb4/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java
----------------------------------------------------------------------
diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java
index 10bf9ea..230f7f0 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java
@@ -19,13 +19,22 @@ package org.apache.storm.redis.trident.state;
import backtype.storm.task.IMetricsContext;
import backtype.storm.tuple.Values;
-import com.google.common.base.Strings;
import com.google.common.collect.Lists;
import org.apache.storm.redis.common.config.JedisClusterConfig;
import org.apache.storm.redis.common.mapper.RedisDataTypeDescription;
import redis.clients.jedis.JedisCluster;
-import storm.trident.state.*;
-import storm.trident.state.map.*;
+import storm.trident.state.OpaqueValue;
+import storm.trident.state.Serializer;
+import storm.trident.state.State;
+import storm.trident.state.StateFactory;
+import storm.trident.state.StateType;
+import storm.trident.state.TransactionalValue;
+import storm.trident.state.map.CachedMap;
+import storm.trident.state.map.MapState;
+import storm.trident.state.map.NonTransactionalMap;
+import storm.trident.state.map.OpaqueMap;
+import storm.trident.state.map.SnapshottableMap;
+import storm.trident.state.map.TransactionalMap;
import java.util.List;
import java.util.Map;
http://git-wip-us.apache.org/repos/asf/storm/blob/f8906fb4/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java
----------------------------------------------------------------------
diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java
index 14b014e..85cbff2 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java
@@ -19,13 +19,22 @@ package org.apache.storm.redis.trident.state;
import backtype.storm.task.IMetricsContext;
import backtype.storm.tuple.Values;
-import com.google.common.base.Strings;
import org.apache.storm.redis.common.config.JedisPoolConfig;
import org.apache.storm.redis.common.mapper.RedisDataTypeDescription;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
-import storm.trident.state.*;
-import storm.trident.state.map.*;
+import storm.trident.state.OpaqueValue;
+import storm.trident.state.Serializer;
+import storm.trident.state.State;
+import storm.trident.state.StateFactory;
+import storm.trident.state.StateType;
+import storm.trident.state.TransactionalValue;
+import storm.trident.state.map.CachedMap;
+import storm.trident.state.map.MapState;
+import storm.trident.state.map.NonTransactionalMap;
+import storm.trident.state.map.OpaqueMap;
+import storm.trident.state.map.SnapshottableMap;
+import storm.trident.state.map.TransactionalMap;
import java.util.List;
import java.util.Map;