Package org.jumpmind.symmetric.file

Class FileSyncZipDataWriter

java.lang.Object

org.jumpmind.symmetric.file.FileSyncZipDataWriter

All Implemented Interfaces:

IDataResource, IDataWriter

public class FileSyncZipDataWriter
extends Object
implements IDataWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected Batch	batch
protected boolean	batchInError
protected long	byteCount
protected int	compressionLevel
protected IConfigurationService	configurationService
protected DataContext	context
protected IExtensionService	extensionService
protected IFileSyncService	fileSyncService
protected long	maxBytesToSync
protected INodeService	nodeService
protected List<FileSnapshot>	snapshotEvents
protected Table	snapshotTable
protected IStagedResource	stagedResource
protected Map<Batch,Statistics>	statistics
protected ZipOutputStream	zos

Constructor Summary

Constructors

Constructor	Description
FileSyncZipDataWriter(long maxBytesToSync, int compressionLevel, IFileSyncService fileSyncService, INodeService nodeService, IStagedResource stagedResource, IExtensionService extensionService, IConfigurationService configurationService)

Method Summary

Modifier and Type	Method	Description
void	close()
protected FileSyncZipScript	createFileSyncZipScript(String targetNodeId)
void	end(Table table)
void	end(Batch batch, boolean inError)
protected boolean	filterInitialLoad(CsvData data)
void	finish()
Map<Batch,Statistics>	getStatistics()
protected boolean	isCClient(String nodeId)
void	open(DataContext context)
boolean	readyToSend()
boolean	start(Table table)
void	start(Batch batch)
void	write(CsvData data)

Methods inherited from class java.lang.Object

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

Field Details

byteCount

protected long byteCount

maxBytesToSync

protected long maxBytesToSync

compressionLevel

protected int compressionLevel

fileSyncService

protected IFileSyncService fileSyncService

stagedResource

protected IStagedResource stagedResource

zos

protected ZipOutputStream zos

snapshotTable

protected Table snapshotTable

batch

protected Batch batch

statistics

protected Map<Batch,Statistics> statistics

snapshotEvents

protected List<FileSnapshot> snapshotEvents

context

protected DataContext context

nodeService

protected INodeService nodeService

extensionService

protected IExtensionService extensionService

configurationService

protected IConfigurationService configurationService

batchInError

protected boolean batchInError

Constructor Details

FileSyncZipDataWriter

public FileSyncZipDataWriter(long maxBytesToSync,
 int compressionLevel,
 IFileSyncService fileSyncService,
 INodeService nodeService,
 IStagedResource stagedResource,
 IExtensionService extensionService,
 IConfigurationService configurationService)

Method Details

open

public void open(DataContext context)

Specified by:

open in interface IDataResource

close

public void close()

Specified by:

close in interface IDataResource

getStatistics

public Map<Batch,Statistics> getStatistics()

Specified by:

getStatistics in interface IDataResource

start

public void start(Batch batch)

Specified by:

start in interface IDataWriter

start

public boolean start(Table table)

Specified by:

start in interface IDataWriter

write

public void write(CsvData data)

Specified by:

write in interface IDataWriter

end

public void end(Table table)

Specified by:

end in interface IDataWriter

end

public void end(Batch batch,
 boolean inError)

Specified by:

end in interface IDataWriter

finish

public void finish()

readyToSend

public boolean readyToSend()

createFileSyncZipScript

protected FileSyncZipScript createFileSyncZipScript(String targetNodeId)

isCClient

protected boolean isCClient(String nodeId)

filterInitialLoad

protected boolean filterInitialLoad(CsvData data)