public static synchronized void initialize(int myHostId, CatalogContext catalogContext, HostMessenger messenger) throws BundleException, IOException {
        ImporterStatsCollector statsCollector = new ImporterStatsCollector(myHostId);
        ImportManager em = new ImportManager(myHostId, messenger, statsCollector);
        VoltDB.instance().getStatsAgent().registerStatsSource(
                StatsSelector.IMPORTER,
                myHostId,
                statsCollector);

        m_self = em;
        em.create(catalogContext);
    }
public static synchronized void initialize ( int myHostId , CatalogContext catalogContext , HostMessenger messenger ) throws BundleException , IOException { ImporterStatsCollector statsCollector = new ImporterStatsCollector ( myHostId ) ; ImportManager em = new ImportManager ( myHostId , messenger , statsCollector ) ; VoltDB . instance ( ) . getStatsAgent ( ) . registerStatsSource ( StatsSelector . IMPORTER , myHostId , statsCollector ) ; m_self = em ; em . create ( catalogContext ) ; }
Create the singleton ImportManager and initialize.
@param myHostId my host id in cluster
@param catalogContext current catalog context
@param messenger messenger to get to ZK
@throws org.osgi.framework.BundleException
@throws java.io.IOException