From 004bfd4a223c636309356a0b119ebbe8860ed815 Mon Sep 17 00:00:00 2001 From: Jason Jackson Date: Tue, 8 Nov 2011 18:12:11 -0800 Subject: [PATCH] renamed --- ...KestrelV3Spout.java => KestrelThriftSpout.java} | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) rename src/jvm/backtype/storm/spout/{KestrelV3Spout.java => KestrelThriftSpout.java} (93%) diff --git a/src/jvm/backtype/storm/spout/KestrelV3Spout.java b/src/jvm/backtype/storm/spout/KestrelThriftSpout.java similarity index 93% rename from src/jvm/backtype/storm/spout/KestrelV3Spout.java rename to src/jvm/backtype/storm/spout/KestrelThriftSpout.java index 7548d42..125168d 100644 --- a/src/jvm/backtype/storm/spout/KestrelV3Spout.java +++ b/src/jvm/backtype/storm/spout/KestrelThriftSpout.java @@ -27,8 +27,8 @@ * multiple of the number of Kestrel servers, otherwise the read load will be * higher on some Kestrel servers than others. */ -public class KestrelV3Spout implements IRichSpout { - public static Logger LOG = Logger.getLogger(KestrelV3Spout.class); +public class KestrelThriftSpout implements IRichSpout { + public static Logger LOG = Logger.getLogger(KestrelThriftSpout.class); public static final long BLACKLIST_TIME_MS = 1000 * 60; public static final int BATCH_SIZE = 4000; @@ -95,7 +95,7 @@ public void closeClient() { } } - public KestrelV3Spout(List hosts, int port, String queueName, Scheme scheme) { + public KestrelThriftSpout(List hosts, int port, String queueName, Scheme scheme) { if(hosts.isEmpty()) { throw new IllegalArgumentException("Must configure at least one host"); } @@ -105,15 +105,15 @@ public KestrelV3Spout(List hosts, int port, String queueName, Scheme sch _scheme = scheme; } - public KestrelV3Spout(String hostname, int port, String queueName, Scheme scheme) { + public KestrelThriftSpout(String hostname, int port, String queueName, Scheme scheme) { this(Arrays.asList(hostname), port, queueName, scheme); } - public KestrelV3Spout(String hostname, int port, String queueName) { + public KestrelThriftSpout(String hostname, int port, String queueName) { this(hostname, port, queueName, new RawScheme()); } - public KestrelV3Spout(List hosts, int port, String queueName) { + public KestrelThriftSpout(List hosts, int port, String queueName) { this(hosts, port, queueName, new RawScheme()); } @@ -171,7 +171,7 @@ public boolean bufferKestrelGet(int index) { EmitItem emitItem = new EmitItem(_scheme.deserialize(item.get_data()), new KestrelSourceId(index, item.get_xid())); if(!_emitBuffer.offer(emitItem)) { - throw new RuntimeException("KestrelV3Spout's Internal Buffer Enqeueue Failed."); + throw new RuntimeException("KestrelThriftSpout's Internal Buffer Enqeueue Failed."); } }