Package org.apache.solr.handler.admin.api

Class ReplicationAPIBase.DirectoryFileStream

java.lang.Object

org.apache.solr.handler.admin.api.ReplicationAPIBase.DirectoryFileStream

All Implemented Interfaces:

jakarta.ws.rs.core.StreamingOutput, SolrCore.RawWriter

Direct Known Subclasses:

ReplicationAPIBase.LocalFsFileStream

Enclosing class:

ReplicationAPIBase

protected class ReplicationAPIBase.DirectoryFileStream
extends Object
implements SolrCore.RawWriter, jakarta.ws.rs.core.StreamingOutput

This class is used to read and send files in the lucene index

Field Summary

Fields

Modifier and Type	Field	Description
protected String	cfileName
protected Checksum	checksum
protected boolean	compress
protected IndexDeletionPolicyWrapper	delPolicy
protected String	fileName
protected org.apache.solr.common.util.FastOutputStream	fos
protected Long	indexGen
protected int	len
protected long	offset
protected String	sLen
protected String	sOffset
protected String	tlogFileName
protected boolean	useChecksum

Constructor Summary

Constructors

Constructor	Description
DirectoryFileStream(String file, String dirType, String offset, String len, boolean compression, boolean useChecksum, double maxWriteMBPerSec, Long gen)

Method Summary

Modifier and Type	Method	Description
protected void	createOutputStream(OutputStream out)
protected void	extendReserveAndReleaseCommitPoint()
protected void	initWrite()
protected String	validateFilenameOrError(String fileName)
void	write(OutputStream out)
protected void	writeNothingAndFlush()	Used to write a marker for EOF

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.solr.core.SolrCore.RawWriter

getContentType

Field Detail

fos

protected org.apache.solr.common.util.FastOutputStream fos

indexGen

protected Long indexGen

delPolicy

protected IndexDeletionPolicyWrapper delPolicy

fileName

protected String fileName

cfileName

protected String cfileName

tlogFileName

protected String tlogFileName

sOffset

protected String sOffset

sLen

protected String sLen

compress

protected final boolean compress

useChecksum

protected boolean useChecksum

offset

protected long offset

len

protected int len

checksum

protected Checksum checksum

Constructor Detail

DirectoryFileStream

public DirectoryFileStream(String file,
                           String dirType,
                           String offset,
                           String len,
                           boolean compression,
                           boolean useChecksum,
                           double maxWriteMBPerSec,
                           Long gen)

Method Detail

validateFilenameOrError

protected String validateFilenameOrError(String fileName)

initWrite

protected void initWrite()
                  throws IOException

Throws:

IOException

createOutputStream

protected void createOutputStream(OutputStream out)

extendReserveAndReleaseCommitPoint

protected void extendReserveAndReleaseCommitPoint()

write

public void write(OutputStream out)
           throws IOException

Specified by:

write in interface SolrCore.RawWriter

Specified by:

write in interface jakarta.ws.rs.core.StreamingOutput

Throws:

IOException

writeNothingAndFlush

protected void writeNothingAndFlush()
                             throws IOException

Used to write a marker for EOF

Throws:

IOException