(self, shard_id)
Called once by a KCLProcess before any calls to process_records

        :type shard_id: str
        :param shard_id: The shard id that this processor is going to be working on.
Called once by a KCLProcess before any calls to process_records
Called once by a KCLProcess before any calls to process_records
def initialize(self, shard_id):
        """
        Called once by a KCLProcess before any calls to process_records

        :type shard_id: str
        :param shard_id: The shard id that this processor is going to be working on.
        """
        raise NotImplementedError
def initialize ( self , shard_id ) : raise NotImplementedError