# coding=utf-8
import PackageTool
from gs.UpdateFromTable import UpdateFromTable
from HeiLongJiang import HeiLongJiang


class HeiLongJiangUpdateJobDB(UpdateFromTable):

    def __init__(self):
        super(HeiLongJiangUpdateJobDB, self).__init__()

    def set_config(self):
        self.searcher = HeiLongJiang()
        # print u'*****'
        # self.init_kafka('GsSrc11')    #在searcher进行初始化，此处不再进行初始化

if __name__ == '__main__':
    job = HeiLongJiangUpdateJobDB()
    job.run()
d51fd14751eb4082f4e45171d616b5572a9430da
<mask token>


class HeiLongJiangUpdateJobDB(UpdateFromTable):

    def __init__(self):
        super(HeiLongJiangUpdateJobDB, self).__init__()
    <mask token>


<mask token>

<mask token>


class HeiLongJiangUpdateJobDB(UpdateFromTable):

    def __init__(self):
        super(HeiLongJiangUpdateJobDB, self).__init__()

    def set_config(self):
        self.searcher = HeiLongJiang()


<mask token>

<mask token>


class HeiLongJiangUpdateJobDB(UpdateFromTable):

    def __init__(self):
        super(HeiLongJiangUpdateJobDB, self).__init__()

    def set_config(self):
        self.searcher = HeiLongJiang()


if __name__ == '__main__':
    job = HeiLongJiangUpdateJobDB()
    job.run()

import PackageTool
from gs.UpdateFromTable import UpdateFromTable
from HeiLongJiang import HeiLongJiang


class HeiLongJiangUpdateJobDB(UpdateFromTable):

    def __init__(self):
        super(HeiLongJiangUpdateJobDB, self).__init__()

    def set_config(self):
        self.searcher = HeiLongJiang()


if __name__ == '__main__':
    job = HeiLongJiangUpdateJobDB()
    job.run()

# coding=utf-8
import PackageTool
from gs.UpdateFromTable import UpdateFromTable
from HeiLongJiang import HeiLongJiang


class HeiLongJiangUpdateJobDB(UpdateFromTable):

    def __init__(self):
        super(HeiLongJiangUpdateJobDB, self).__init__()

    def set_config(self):
        self.searcher = HeiLongJiang()
        # print u'*****'
        # self.init_kafka('GsSrc11')    #在searcher进行初始化，此处不再进行初始化

if __name__ == '__main__':
    job = HeiLongJiangUpdateJobDB()
    job.run()