File tree Expand file tree Collapse file tree 1 file changed +4
-12
lines changed Expand file tree Collapse file tree 1 file changed +4
-12
lines changed Original file line number Diff line number Diff line change @@ -373,7 +373,10 @@ public class Config extends HashMap<String, Object> {
373
373
public static String TOPOLOGY_KRYO_REGISTER = "topology.kryo.register" ;
374
374
375
375
/**
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.
377
380
*/
378
381
public static String TOPOLOGY_KRYO_DECORATORS = "topology.kryo.decorators" ;
379
382
@@ -562,10 +565,6 @@ public void registerSerialization(Class klass, Class<? extends Serializer> seria
562
565
getRegisteredSerializations ().add (register );
563
566
}
564
567
565
- public void registerKryoDecorator (Class klass ) {
566
- getRegisteredKryoDecorators ().add (klass .getName ());
567
- }
568
-
569
568
public void setSkipMissingKryoRegistrations (boolean skip ) {
570
569
put (Config .TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS , skip );
571
570
}
@@ -592,11 +591,4 @@ private List getRegisteredSerializations() {
592
591
}
593
592
return (List ) get (Config .TOPOLOGY_KRYO_REGISTER );
594
593
}
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
- }
602
594
}
You can’t perform that action at this time.
0 commit comments