org.jumpmind.symmetric.file

Class FileSyncZipDataWriter

java.lang.Object

org.jumpmind.symmetric.file.FileSyncZipDataWriter

All Implemented Interfaces:

org.jumpmind.symmetric.io.data.IDataResource, org.jumpmind.symmetric.io.data.IDataWriter

public class FileSyncZipDataWriter
extends java.lang.Object
implements org.jumpmind.symmetric.io.data.IDataWriter

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jumpmind.symmetric.io.data.Batch	batch
protected long	byteCount
protected IConfigurationService	configurationService
protected org.jumpmind.symmetric.io.data.DataContext	context
protected IExtensionService	extensionService
protected IFileSyncService	fileSyncService
protected long	maxBytesToSync
protected INodeService	nodeService
protected java.util.List<FileSnapshot>	snapshotEvents
protected org.jumpmind.db.model.Table	snapshotTable
protected org.jumpmind.symmetric.io.stage.IStagedResource	stagedResource
protected java.util.Map<org.jumpmind.symmetric.io.data.Batch,org.jumpmind.util.Statistics>	statistics
protected java.util.zip.ZipOutputStream	zos

Constructor Summary

Constructors

Constructor and Description
FileSyncZipDataWriter(long maxBytesToSync, IFileSyncService fileSyncService, INodeService nodeService, org.jumpmind.symmetric.io.stage.IStagedResource stagedResource, IExtensionService extensionService, IConfigurationService configurationService)

Method Summary

Modifier and Type	Method and Description
void	close()
protected FileSyncZipScript	createFileSyncZipScript(java.lang.String targetNodeId)
void	end(org.jumpmind.symmetric.io.data.Batch batch, boolean inError)
void	end(org.jumpmind.db.model.Table table)
protected boolean	filterInitialLoad(org.jumpmind.symmetric.io.data.CsvData data)
void	finish()
java.util.Map<org.jumpmind.symmetric.io.data.Batch,org.jumpmind.util.Statistics>	getStatistics()
protected boolean	isCClient(java.lang.String nodeId)
void	open(org.jumpmind.symmetric.io.data.DataContext context)
boolean	readyToSend()
void	start(org.jumpmind.symmetric.io.data.Batch batch)
boolean	start(org.jumpmind.db.model.Table table)
void	write(org.jumpmind.symmetric.io.data.CsvData data)

Methods inherited from class java.lang.Object

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

Field Detail

byteCount

protected long byteCount

maxBytesToSync

protected long maxBytesToSync

fileSyncService

protected IFileSyncService fileSyncService

stagedResource

protected org.jumpmind.symmetric.io.stage.IStagedResource stagedResource

zos

protected java.util.zip.ZipOutputStream zos

snapshotTable

protected org.jumpmind.db.model.Table snapshotTable

batch

protected org.jumpmind.symmetric.io.data.Batch batch

statistics

protected java.util.Map<org.jumpmind.symmetric.io.data.Batch,org.jumpmind.util.Statistics> statistics

snapshotEvents

protected java.util.List<FileSnapshot> snapshotEvents

context

protected org.jumpmind.symmetric.io.data.DataContext context

nodeService

protected INodeService nodeService

extensionService

protected IExtensionService extensionService

configurationService

protected IConfigurationService configurationService

Constructor Detail

FileSyncZipDataWriter

public FileSyncZipDataWriter(long maxBytesToSync,
                             IFileSyncService fileSyncService,
                             INodeService nodeService,
                             org.jumpmind.symmetric.io.stage.IStagedResource stagedResource,
                             IExtensionService extensionService,
                             IConfigurationService configurationService)

Method Detail

open

public void open(org.jumpmind.symmetric.io.data.DataContext context)

Specified by:

open in interface org.jumpmind.symmetric.io.data.IDataResource

close

public void close()

Specified by:

close in interface org.jumpmind.symmetric.io.data.IDataResource

getStatistics

public java.util.Map<org.jumpmind.symmetric.io.data.Batch,org.jumpmind.util.Statistics> getStatistics()

Specified by:

getStatistics in interface org.jumpmind.symmetric.io.data.IDataResource

start

public void start(org.jumpmind.symmetric.io.data.Batch batch)

Specified by:

start in interface org.jumpmind.symmetric.io.data.IDataWriter

start

public boolean start(org.jumpmind.db.model.Table table)

Specified by:

start in interface org.jumpmind.symmetric.io.data.IDataWriter

write

public void write(org.jumpmind.symmetric.io.data.CsvData data)

Specified by:

write in interface org.jumpmind.symmetric.io.data.IDataWriter

end

public void end(org.jumpmind.db.model.Table table)

Specified by:

end in interface org.jumpmind.symmetric.io.data.IDataWriter

end

public void end(org.jumpmind.symmetric.io.data.Batch batch,
                boolean inError)

Specified by:

end in interface org.jumpmind.symmetric.io.data.IDataWriter

finish

public void finish()

readyToSend

public boolean readyToSend()

createFileSyncZipScript

protected FileSyncZipScript createFileSyncZipScript(java.lang.String targetNodeId)

isCClient

protected boolean isCClient(java.lang.String nodeId)

filterInitialLoad

protected boolean filterInitialLoad(org.jumpmind.symmetric.io.data.CsvData data)