flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java
/**
	 * Auxiliary method to write the length of an upcoming data chunk to an
	 * output stream.
	 *
	 * @param length
	 *        the length of the upcoming data chunk in bytes
	 * @param outputStream
	 *        the output stream to write the length to
	 * @throws IOException
	 *         thrown if an I/O error occurs while writing to the output
	 *         stream
	 */
Auxiliary method to write the length of an upcoming data chunk to an
output stream.

@param length
the length of the upcoming data chunk in bytes
@param outputStream
the output stream to write the length to
@throws IOException
thrown if an I/O error occurs while writing to the output
stream
Auxiliary method to write the length of an upcoming data chunk to an output stream . @param length the length of the upcoming data chunk in bytes @param outputStream the output stream to write the length to @throws IOException thrown if an I / O error occurs while writing to the output stream
static void writeLength(int length, OutputStream outputStream) throws IOException {
		byte[] buf = new byte[4];
		buf[0] = (byte) (length & 0xff);
		buf[1] = (byte) ((length >> 8) & 0xff);
		buf[2] = (byte) ((length >> 16) & 0xff);
		buf[3] = (byte) ((length >> 24) & 0xff);
		outputStream.write(buf, 0, 4);
	}
static void writeLength ( int length , OutputStream outputStream ) throws IOException { byte [ ] buf = new byte [ 4 ] ; buf [ 0 ] = ( byte ) ( length & 0xff ) ; buf [ 1 ] = ( byte ) ( ( length >> 8 ) & 0xff ) ; buf [ 2 ] = ( byte ) ( ( length >> 16 ) & 0xff ) ; buf [ 3 ] = ( byte ) ( ( length >> 24 ) & 0xff ) ; outputStream . write ( buf , 0 , 4 ) ; }
Auxiliary method to write the length of an upcoming data chunk to an
 output stream.
Auxiliary method to write the length of an upcoming data chunk to an output stream .