com.splout.db.dnode.beans
Class BalanceFileReceivingProgress

java.lang.Object
  com.splout.db.dnode.beans.BalanceFileReceivingProgress

public class BalanceFileReceivingProgress
extends java.lang.Object

This bean describes the state of a file transaction (tablespace/partition/version) between DNodes in progress. These transactions have two files: the .meta and the .db so we need to know when both have been received to transfer the partition data to the appropriated folder.

Constructor Summary

BalanceFileReceivingProgress()

BalanceFileReceivingProgress(java.lang.String tablespace, int partition, long version)

Method Summary

void	binaryFileReceived(java.io.File binaryFile)
java.lang.String	getBinaryFile()
long	getBinaryFileSize()
java.lang.String	getMetaFile()
int	getPartition()
long	getReceivedSizeSoFar()
java.lang.String	getTablespace()
long	getVersion()
boolean	isReceivedBinaryFile()
boolean	isReceivedMetaFile()
void	metaFileReceived(java.io.File metaFile)
void	progressBinaryFile(long finalSize, long sizeSoFar)
void	setBinaryFile(java.lang.String binaryFile)
void	setBinaryFileSize(long binaryFileSize)
void	setMetaFile(java.lang.String metaFile)
void	setPartition(int partition)
void	setReceivedBinaryFile(boolean receivedBinaryFile)
void	setReceivedMetaFile(boolean receivedMetaFile)
void	setReceivedSizeSoFar(long receivedSizeSoFar)
void	setTablespace(java.lang.String tablespace)
void	setVersion(long version)

Methods inherited from class java.lang.Object

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

Constructor Detail

BalanceFileReceivingProgress

public BalanceFileReceivingProgress()

BalanceFileReceivingProgress

public BalanceFileReceivingProgress(java.lang.String tablespace,
                                    int partition,
                                    long version)

Method Detail

metaFileReceived

public void metaFileReceived(java.io.File metaFile)

binaryFileReceived

public void binaryFileReceived(java.io.File binaryFile)

progressBinaryFile

public void progressBinaryFile(long finalSize,
                               long sizeSoFar)

setReceivedMetaFile

public void setReceivedMetaFile(boolean receivedMetaFile)

setReceivedBinaryFile

public void setReceivedBinaryFile(boolean receivedBinaryFile)

setMetaFile

public void setMetaFile(java.lang.String metaFile)

setBinaryFile

public void setBinaryFile(java.lang.String binaryFile)

setBinaryFileSize

public void setBinaryFileSize(long binaryFileSize)

setReceivedSizeSoFar

public void setReceivedSizeSoFar(long receivedSizeSoFar)

setTablespace

public void setTablespace(java.lang.String tablespace)

setPartition

public void setPartition(int partition)

setVersion

public void setVersion(long version)

isReceivedMetaFile

public boolean isReceivedMetaFile()

isReceivedBinaryFile

public boolean isReceivedBinaryFile()

getBinaryFileSize

public long getBinaryFileSize()

getReceivedSizeSoFar

public long getReceivedSizeSoFar()

getTablespace

public java.lang.String getTablespace()

getPartition

public int getPartition()

getVersion

public long getVersion()

getMetaFile

public java.lang.String getMetaFile()

getBinaryFile

public java.lang.String getBinaryFile()