org.thales.punch.pml.scan

Class SparkSerialization

java.lang.Object

org.thales.punch.pml.scan.ClassSerialization

org.thales.punch.pml.scan.SparkSerialization

public class SparkSerialization
extends ClassSerialization

Field Summary

Fields inherited from class org.thales.punch.pml.scan.ClassSerialization

clazz, publications, subscriptions

Constructor Summary

Constructors

Constructor and Description
SparkSerialization(Class<?> clazz)

Method Summary

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.

Methods inherited from class org.thales.punch.pml.scan.ClassSerialization

publications, subscriptions

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkSerialization

public SparkSerialization(Class<?> clazz)

Method Detail

serialize

public void serialize()
               throws InstantiationException,
                      IllegalAccessException

Description copied from class: ClassSerialization

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

Specified by:

serialize in class ClassSerialization

Throws:

InstantiationException

IllegalAccessException

executors

protected List<String> executors()

Specified by:

executors in class ClassSerialization

Returns:

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