public class StormSerialization extends ClassSerialization
clazz, publications, subscriptions
Constructor and Description |
---|
StormSerialization(Class<?> clazz) |
Modifier and Type | Method and Description |
---|---|
protected List<String> |
executors() |
void |
serialize()
Serialize will attempt to create an instance of the class given to this instance ctr.
|
publications, subscriptions
public StormSerialization(Class<?> clazz)
public void serialize() throws InstantiationException, IllegalAccessException
ClassSerialization
Afterwards, subscription/publication pojo will be generated.
Note: Storm pub-sub is richer than it's spark counterpart. i.e. in storm we can define not only stream but also fields...
serialize
in class ClassSerialization
InstantiationException
IllegalAccessException
protected List<String> executors()
executors
in class ClassSerialization
Copyright © 2023. All rights reserved.