@classmethod
def _java_loader_class(cls):
    """
        Returns the full class name of the Java loader. The default
        implementation replaces "pyspark" by "org.apache.spark" in
        the Python full class name.
        """
    java_package = cls.__module__.replace('pyspark', 'org.apache.spark')
    return '.'.join([java_package, cls.__name__])
