@@ -0,0 +1,2155 @@
+package org.apache.cassandra.streaming;%0D%0A%0D%0Aimport java.io.DataInputStream;%0D%0Aimport java.io.DataOutputStream;%0D%0Aimport java.io.IOException;%0D%0A%0D%0Aimport org.apache.cassandra.io.ICompactSerializer;%0D%0A%0D%0Aclass PendingFile%0D%0A%7B%0D%0A    private static ICompactSerializer%3CPendingFile%3E serializer_;%0D%0A%0D%0A    static%0D%0A    %7B%0D%0A        serializer_ = new InitiatedFileSerializer();%0D%0A    %7D%0D%0A%0D%0A    public static ICompactSerializer%3CPendingFile%3E serializer()%0D%0A    %7B%0D%0A        return serializer_;%0D%0A    %7D%0D%0A%0D%0A    private String targetFile_;%0D%0A    private long expectedBytes_;%0D%0A    private String table_;%0D%0A%0D%0A    public PendingFile(String targetFile, long expectedBytes, String table)%0D%0A    %7B%0D%0A        targetFile_ = targetFile;%0D%0A        expectedBytes_ = expectedBytes;%0D%0A        table_ = table;%0D%0A    %7D%0D%0A%0D%0A    public String getTable()%0D%0A    %7B%0D%0A        return table_;%0D%0A    %7D%0D%0A%0D%0A    public String getTargetFile()%0D%0A    %7B%0D%0A        return targetFile_;%0D%0A    %7D%0D%0A%0D%0A    public void setTargetFile(String file)%0D%0A    %7B%0D%0A        targetFile_ = file;%0D%0A    %7D%0D%0A%0D%0A    public long getExpectedBytes()%0D%0A    %7B%0D%0A        return expectedBytes_;%0D%0A    %7D%0D%0A%0D%0A    public boolean equals(Object o)%0D%0A    %7B%0D%0A        if ( !(o instanceof PendingFile) )%0D%0A            return false;%0D%0A%0D%0A        PendingFile rhs = (PendingFile)o;%0D%0A        return targetFile_.equals(rhs.targetFile_);%0D%0A    %7D%0D%0A%0D%0A    public int hashCode()%0D%0A    %7B%0D%0A        return toString().hashCode();%0D%0A    %7D%0D%0A%0D%0A    public String toString()%0D%0A    %7B%0D%0A        return targetFile_ + %22:%22 + expectedBytes_;%0D%0A    %7D%0D%0A%0D%0A    private static class InitiatedFileSerializer implements ICompactSerializer%3CPendingFile%3E%0D%0A    %7B%0D%0A        public void serialize(PendingFile sc, DataOutputStream dos) throws IOException%0D%0A        %7B%0D%0A            dos.writeUTF(sc.targetFile_);%0D%0A            dos.writeLong(sc.expectedBytes_);%0D%0A            dos.writeUTF(sc.table_);%0D%0A        %7D%0D%0A%0D%0A        public PendingFile deserialize(DataInputStream dis) throws IOException%0D%0A        %7B%0D%0A            String targetFile = dis.readUTF();%0D%0A            long expectedBytes = dis.readLong();%0D%0A            String table = dis.readUTF();%0D%0A            return new PendingFile(targetFile, expectedBytes, table);%0D%0A        %7D%0D%0A    %7D%0D%0A%7D%0D%0A

add missing PendingFile.java