Skip to content

Commit d4f6114

Browse files
author
Jason Jackson
committed
added better comment, removed code that is never called
1 parent 205722d commit d4f6114

File tree

1 file changed

+4
-12
lines changed

1 file changed

+4
-12
lines changed

src/jvm/backtype/storm/Config.java

+4-12
Original file line numberDiff line numberDiff line change
@@ -373,7 +373,10 @@ public class Config extends HashMap<String, Object> {
373373
public static String TOPOLOGY_KRYO_REGISTER = "topology.kryo.register";
374374

375375
/**
376-
* JTODO
376+
* A list of classes that customize storm's kryo instance during start-up.
377+
* Each listed class name must implement IKryoDecorator. During start-up the
378+
* listed class is instantiated with 0 arguments, then its 'decorate' method
379+
* is called with storm's kryo instance as the only argument.
377380
*/
378381
public static String TOPOLOGY_KRYO_DECORATORS = "topology.kryo.decorators";
379382

@@ -562,10 +565,6 @@ public void registerSerialization(Class klass, Class<? extends Serializer> seria
562565
getRegisteredSerializations().add(register);
563566
}
564567

565-
public void registerKryoDecorator(Class klass) {
566-
getRegisteredKryoDecorators().add(klass.getName());
567-
}
568-
569568
public void setSkipMissingKryoRegistrations(boolean skip) {
570569
put(Config.TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS, skip);
571570
}
@@ -592,11 +591,4 @@ private List getRegisteredSerializations() {
592591
}
593592
return (List) get(Config.TOPOLOGY_KRYO_REGISTER);
594593
}
595-
596-
private List getRegisteredKryoDecorators() {
597-
if(!containsKey(Config.TOPOLOGY_KRYO_DECORATORS)) {
598-
put(Config.TOPOLOGY_KRYO_DECORATORS, new ArrayList());
599-
}
600-
return (List) get(Config.TOPOLOGY_KRYO_DECORATORS);
601-
}
602594
}

0 commit comments

Comments
 (0)