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 .