def __init__(<EOL>self,<EOL>session,<EOL>candidate_classes,<EOL>throttlers=None,<EOL>self_relations=False,<EOL>nested_relations=False,<EOL>symmetric_relations=True,<EOL>parallelism=<NUM_LIT:1>,<EOL>):
if throttlers is None:<EOL><INDENT>throttlers = [None] * len(candidate_classes)<EOL><DEDENT>"""<STR_LIT>"""<EOL>super(CandidateExtractor, self).__init__(<EOL>session,<EOL>CandidateExtractorUDF,<EOL>parallelism=parallelism,<EOL>candidate_classes=candidate_classes,<EOL>throttlers=throttlers,<EOL>self_relations=self_relations,<EOL>nested_relations=nested_relations,<EOL>symmetric_relations=symmetric_relations,<EOL>)<EOL>if len(candidate_classes) != len(throttlers):<EOL><INDENT>raise ValueError(<EOL>"<STR_LIT>"<EOL>)<EOL><DEDENT>self.candidate_classes = candidate_classes<EOL>
Set throttlers match candidate_classes if not provide.