public static void writeToCheckpoint ( OutputStream output , List < ? extends Checkpointed > components ) throws IOException , InterruptedException { OutputChunked chunked = new OutputChunked ( new CheckpointOutputStream ( output , CheckpointType . COMPOUND ) , 64 * Constants . KB ) ; for ( Checkpointed component : components ) { chunked . writeString ( component . getCheckpointName ( ) . toString ( ) ) ; component . writeToCheckpoint ( chunked ) ; chunked . endChunks ( ) ; } chunked . flush ( ) ; }
Writes a composite checkpoint for the given checkpointed components .