def infer(self, dataTable, dictTable, modelTable, outputTable, numTopics, numIter=30, alpha=0.5, eta=0.5): 
            self.model = {}
            self.model['dictTable']=dictTable
            self.model['modelTable']=modelTable
            self.model['alpha']=alpha
            self.model['eta']=eta
            self.model['numTopics']=numTopics
                       
            stmt = '''
                      select {madlib_schema}.plda_run('{dataTable}', '{dictTable}', '{modelTable}', '{outputTable}', 
                             {numIter}, {numTopics}, {alpha}, {eta});  
                   '''.format(
                              dataTable=dataTable,
                              dictTable=dictTable,
                              modelTable=modelTable,
                              outputTable=outputTable,
                              numIter=numIter,
                              numTopics=numTopics,
                              alpha=alpha,
                              eta=eta,
                              madlib_schema=self.dbconn.madlib_schema
                             ) 
               
            self.dbconn.executeQuery(stmt)
            stmt = ''' select id, (topics).topics, (topics).topic_d
                       from {outputTable};
                   '''.format (
                                outputTable=outputTable
                              )     
            cursor = self.dbconn.getCursor()
            cursor.execute(stmt)
            result_set = [row for row in cursor]   
            cursor.close()
            return result_set
Access the current state of this job.
dataset/ETHPy150Open pivotalsoftware/pymadlib/pymadlib/pymadlib.py/PLDA.infer--crossover with--dataset/ETHPy150Open openstack/taskflow/taskflow/jobs/base.py/Job.state