hollow/src/main/java/com/netflix/hollow/core/read/engine/HollowBlobReader.java
public void readSnapshot(InputStream is, HollowFilterConfig filter) throws IOException {
        HollowBlobHeader header = readHeader(is, false);

        notifyBeginUpdate();

        long startTime = System.currentTimeMillis();

        DataInputStream dis = new DataInputStream(is);

        int numStates = VarInt.readVInt(dis);

        Collection<String> typeNames = new TreeSet<String>();
        for(int i=0;i<numStates;i++) {
            String typeName = readTypeStateSnapshot(dis, header, filter);
            typeNames.add(typeName);
        }

        stateEngine.wireTypeStatesToSchemas();

        long endTime = System.currentTimeMillis();

        log.info("SNAPSHOT COMPLETED IN " + (endTime - startTime) + "ms");
        log.info("TYPES: " + typeNames);

        notifyEndUpdate();

        stateEngine.afterInitialization();
    }
public void readSnapshot(InputStream is, HollowFilterConfig filter) throws IOException {
        HollowBlobHeader header = readHeader(is, false);

        notifyBeginUpdate();

        long startTime = System.currentTimeMillis();

        DataInputStream dis = new DataInputStream(is);

        int numStates = VarInt.readVInt(dis);

        Collection<String> typeNames = new TreeSet<String>();
        for(int i=0;i<numStates;i++) {
            String typeName = readTypeStateSnapshot(dis, header, filter);
            typeNames.add(typeName);
        }

        stateEngine.wireTypeStatesToSchemas();

        long endTime = System.currentTimeMillis();

        log.info("SNAPSHOT COMPLETED IN " + (endTime - startTime) + "ms");
        log.info("TYPES: " + typeNames);

        notifyEndUpdate();

        stateEngine.afterInitialization();
    }
public void readSnapshot ( InputStream is , HollowFilterConfig filter ) throws IOException { HollowBlobHeader header = readHeader ( is , false ) ; notifyBeginUpdate ( ) ; long startTime = System . currentTimeMillis ( ) ; DataInputStream dis = new DataInputStream ( is ) ; int numStates = VarInt . readVInt ( dis ) ; Collection < String > typeNames = new TreeSet < String > ( ) ; for ( int i = 0 ; i < numStates ; i ++ ) { String typeName = readTypeStateSnapshot ( dis , header , filter ) ; typeNames . add ( typeName ) ; } stateEngine . wireTypeStatesToSchemas ( ) ; long endTime = System . currentTimeMillis ( ) ; log . info ( "SNAPSHOT COMPLETED IN " + ( endTime - startTime ) + "ms" ) ; log . info ( "TYPES: " + typeNames ) ; notifyEndUpdate ( ) ; stateEngine . afterInitialization ( ) ; }
Initialize the state engine using a snapshot blob from the provided InputStream.
<p>
Apply the provided {@link HollowFilterConfig} to the state.

@param is the input stream to read the snaptshot
@param filter the filtering configuration to filter the snapshot
@throws IOException if the snapshot could not be read
Initialize the state engine using a snapshot blob from the provided InputStream . <p > Apply the provided { @link HollowFilterConfig } to the state .