tensorflowonspark.marker module

class EndPartition[source]

Bases: tensorflowonspark.marker.Marker

Marks the end of an RDD Partition during data feeding

class Marker[source]

Bases: object

Base class for special marker objects in the data queue