package com.yahoo.hadoop_bsp;

import java.io.IOException;

import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.ipc.VersionedProtocol;
import org.apache.hadoop.security.token.TokenInfo;

/**
 * Basic interface for communication between workers.
 *
 *
 * @param <I extends Writable> vertex id
 * @param <M extends Writable> message data
 *
 **/
@TokenInfo(BspTokenSelector.class)
@SuppressWarnings("rawtypes")
public interface CommunicationsInterface<
        I extends WritableComparable,
        V extends Writable,
        E extends Writable,
        M extends Writable>
        extends VersionedProtocol {

	/**
	 * Interface Version History
	 *
	 * 0 - First Version
	 */
	static final long versionID = 0L;

    /**
     * Adds incoming message.
     *
     * @param vertexIndex
     * @param msg
     * @throws IOException
     */
    void putMsg(I vertexIndex, M msg) throws IOException;

    /**
     * Adds incoming message list.
     *
     * @param vertexIndex
     * @param msgList messages added
     * @throws IOException
     */
    void putMsgList(I vertexIndex, MsgList<M> msgList) throws IOException;

    /**
     * Adds vertex list (index, value, edges, etc.) to the appropriate worker.
     *
     * @param vertexRangeIndex
     */
    void putVertexList(I vertexIndexMax,
                       HadoopVertexList<I, V, E, M> vertexList)
        throws IOException;

    /**
     * @return The name of this worker in the format "hostname:port".
     */
    String getName();

}

package com.yahoo.hadoop_bsp;

import java.io.IOException;

import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.ipc.VersionedProtocol;
import org.apache.hadoop.security.token.TokenInfo;

/**
 * Basic interface for communication between workers.
 *
 *
 * @param <I extends Writable> vertex id
 * @param <M extends Writable> message data
 *
 **/
@TokenInfo(BspTokenSelector.class)
@SuppressWarnings("rawtypes")
public interface CommunicationsInterface<
        I extends WritableComparable,
        V extends Writable,
        E extends Writable,
        M extends Writable>
        extends VersionedProtocol {

    /**
     * Interface Version History
     *
     * 0 - First Version
     */
    static final long versionID = 0L;

    /**
     * Adds incoming message.
     *
     * @param vertexIndex
     * @param msg
     * @throws IOException
     */
    void putMsg(I vertexIndex, M msg) throws IOException;

    /**
     * Adds incoming message list.
     *
     * @param vertexIndex
     * @param msgList messages added
     * @throws IOException
     */
    void putMsgList(I vertexIndex, MsgList<M> msgList) throws IOException;

    /**
     * Adds vertex list (index, value, edges, etc.) to the appropriate worker.
     *
     * @param vertexRangeIndex
     */
    void putVertexList(I vertexIndexMax,
                       HadoopVertexList<I, V, E, M> vertexList)
        throws IOException;

    /**
     * @return The name of this worker in the format "hostname:port".
     */
    String getName();
}

Fix indentation and removed extra last line.