org.apache.lucene.replicator.nrt

Class CopyOneFile

java.lang.Object

org.apache.lucene.replicator.nrt.CopyOneFile

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class CopyOneFile
extends java.lang.Object
implements java.io.Closeable

Copies one file from an incoming DataInput to a dest filename in a local Directory

Field Summary

Fields

Modifier and Type	Field and Description
long	bytesToCopy
FileMetaData	metaData
java.lang.String	name
java.lang.String	tmpName

Constructor Summary

Constructors

Constructor and Description
CopyOneFile(CopyOneFile other, DataInput in) Transfers this file copy to another input, continuing where the first one left off
CopyOneFile(DataInput in, ReplicaNode dest, java.lang.String name, FileMetaData metaData, byte[] buffer)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getBytesCopied()
boolean	visit() Copy another chunk of bytes, returning true once the copy is done

Methods inherited from class java.lang.Object

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

Field Detail

name

public final java.lang.String name

tmpName

public final java.lang.String tmpName

metaData

public final FileMetaData metaData

bytesToCopy

public final long bytesToCopy

Constructor Detail

CopyOneFile

public CopyOneFile(DataInput in,
                   ReplicaNode dest,
                   java.lang.String name,
                   FileMetaData metaData,
                   byte[] buffer)
            throws java.io.IOException

Throws:

java.io.IOException

CopyOneFile

public CopyOneFile(CopyOneFile other,
                   DataInput in)

Transfers this file copy to another input, continuing where the first one left off

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

visit

public boolean visit()
              throws java.io.IOException

Copy another chunk of bytes, returning true once the copy is done

Throws:

java.io.IOException

getBytesCopied

public long getBytesCopied()