import org.apache.cassandra.streaming.messages.FileMessageHeader; //导入依赖的package包/类
public StreamReader(FileMessageHeader header, StreamSession session)
{
    this.session = session;
    this.cfId = header.cfId;
    this.estimatedKeys = header.estimatedKeys;
    this.sections = header.sections;
    this.inputVersion = new Descriptor.Version(header.version);
    this.repairedAt = header.repairedAt;
}
 

import org.apache.cassandra.streaming.messages.FileMessageHeader; //导入依赖的package包/类
public StreamReader(FileMessageHeader header, StreamSession session)
{
    this.session = session;
    this.cfId = header.cfId;
    this.estimatedKeys = header.estimatedKeys;
    this.sections = header.sections;
    this.inputVersion = new Descriptor.Version(header.version);
}
 

import org.apache.cassandra.streaming.messages.FileMessageHeader; //导入依赖的package包/类
public StreamReader(FileMessageHeader header, StreamSession session)
{
    this.session = session;
    this.cfId = header.cfId;
    this.estimatedKeys = header.estimatedKeys;
    this.sections = header.sections;
    this.inputVersion = header.version;
    this.repairedAt = header.repairedAt;
    this.format = header.format;
    this.sstableLevel = header.sstableLevel;
    this.header = header.header;
    this.fileSeqNum = header.sequenceNumber;
}
 

import org.apache.cassandra.streaming.messages.FileMessageHeader; //导入依赖的package包/类
public CompressedStreamReader(FileMessageHeader header, StreamSession session)
{
    super(header, session);
    this.compressionInfo = header.compressionInfo;
}