import org.apache.cassandra.streaming.compress.CompressedStreamWriter; //导入依赖的package包/类
public synchronized void serialize(DataOutputStreamPlus out, int version, StreamSession session) throws IOException
{
    if (completed)
    {
        return;
    }

    CompressionInfo compressionInfo = FileMessageHeader.serializer.serialize(header, out, version);

    final SSTableReader reader = ref.get();
    StreamWriter writer = compressionInfo == null ?
                                  new StreamWriter(reader, header.sections, session) :
                                  new CompressedStreamWriter(reader, header.sections,
                                                             compressionInfo, session);
    writer.write(out);
}
 

import org.apache.cassandra.streaming.compress.CompressedStreamWriter; //导入依赖的package包/类
public void serialize(OutgoingFileMessage message, DataOutputStreamAndChannel out, int version, StreamSession session) throws IOException
{
    FileMessageHeader.serializer.serialize(message.header, out, version);

    final SSTableReader reader = message.sstable;
    StreamWriter writer = message.header.compressionInfo == null ?
            new StreamWriter(reader, message.header.sections, session) :
            new CompressedStreamWriter(reader,
                    message.header.sections,
                    message.header.compressionInfo, session);
    writer.write(out.getChannel());
    session.fileSent(message.header);
}
 

import org.apache.cassandra.streaming.compress.CompressedStreamWriter; //导入依赖的package包/类
public void serialize(FileMessage message, WritableByteChannel out, int version, StreamSession session) throws IOException
{
    DataOutput output = new DataOutputStream(Channels.newOutputStream(out));
    FileMessageHeader.serializer.serialize(message.header, output, version);
    StreamWriter writer = message.header.compressionInfo == null ?
                                  new StreamWriter(message.sstable, message.header.sections, session) :
                                  new CompressedStreamWriter(message.sstable,
                                                             message.header.sections,
                                                             message.header.compressionInfo, session);
    writer.write(out);
    session.fileSent(message.header);
}