org.thales.punch.pml.scan

Class ClassSerialization

java.lang.Object

org.thales.punch.pml.scan.ClassSerialization

Direct Known Subclasses:

SparkSerialization, StormSerialization

public abstract class ClassSerialization
extends Object

Common interface for both Spark and Storm runtime for serializing the publish-subscribe pojo

Author:

jonathan

Field Summary

Fields

Modifier and Type	Field and Description
protected Class<?>	clazz
protected List<Publication>	publications
protected List<Subscription>	subscriptions

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClassSerialization(Class<?> clazz)

Method Summary

Modifier and Type	Method and Description
protected abstract List<String>	executors()
protected List<Publication>	publications()
protected abstract void	serialize() Serialize will attempt to create an instance of the class given to this instance ctr.
protected List<Subscription>	subscriptions()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

clazz

protected final Class<?> clazz

subscriptions

protected List<Subscription> subscriptions

publications

protected List<Publication> publications

Constructor Detail

ClassSerialization

protected ClassSerialization(Class<?> clazz)

Method Detail

serialize

protected abstract void serialize()
                           throws InstantiationException,
                                  IllegalAccessException

Serialize will attempt to create an instance of the class given to this instance ctr.

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...

Throws:

InstantiationException

IllegalAccessException

subscriptions

protected List<Subscription> subscriptions()

publications

protected List<Publication> publications()

executors

protected abstract List<String> executors()

Returns:

the class passed in ctr compatible executors (pyspark, storm, spark, ...)