public class FileSyncZipDataWriter
extends java.lang.Object
implements org.jumpmind.symmetric.io.data.IDataWriter
| 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 and Description |
|---|
FileSyncZipDataWriter(long maxBytesToSync,
IFileSyncService fileSyncService,
INodeService nodeService,
org.jumpmind.symmetric.io.stage.IStagedResource stagedResource,
IExtensionService extensionService,
IConfigurationService configurationService) |
| 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) |
protected long byteCount
protected long maxBytesToSync
protected IFileSyncService fileSyncService
protected org.jumpmind.symmetric.io.stage.IStagedResource stagedResource
protected java.util.zip.ZipOutputStream zos
protected org.jumpmind.db.model.Table snapshotTable
protected org.jumpmind.symmetric.io.data.Batch batch
protected java.util.Map<org.jumpmind.symmetric.io.data.Batch,org.jumpmind.util.Statistics> statistics
protected java.util.List<FileSnapshot> snapshotEvents
protected org.jumpmind.symmetric.io.data.DataContext context
protected INodeService nodeService
protected IExtensionService extensionService
protected IConfigurationService configurationService
public FileSyncZipDataWriter(long maxBytesToSync,
IFileSyncService fileSyncService,
INodeService nodeService,
org.jumpmind.symmetric.io.stage.IStagedResource stagedResource,
IExtensionService extensionService,
IConfigurationService configurationService)
public void open(org.jumpmind.symmetric.io.data.DataContext context)
open in interface org.jumpmind.symmetric.io.data.IDataResourcepublic void close()
close in interface org.jumpmind.symmetric.io.data.IDataResourcepublic java.util.Map<org.jumpmind.symmetric.io.data.Batch,org.jumpmind.util.Statistics> getStatistics()
getStatistics in interface org.jumpmind.symmetric.io.data.IDataResourcepublic void start(org.jumpmind.symmetric.io.data.Batch batch)
start in interface org.jumpmind.symmetric.io.data.IDataWriterpublic boolean start(org.jumpmind.db.model.Table table)
start in interface org.jumpmind.symmetric.io.data.IDataWriterpublic void write(org.jumpmind.symmetric.io.data.CsvData data)
write in interface org.jumpmind.symmetric.io.data.IDataWriterpublic void end(org.jumpmind.db.model.Table table)
end in interface org.jumpmind.symmetric.io.data.IDataWriterpublic void end(org.jumpmind.symmetric.io.data.Batch batch,
boolean inError)
end in interface org.jumpmind.symmetric.io.data.IDataWriterpublic void finish()
public boolean readyToSend()
protected FileSyncZipScript createFileSyncZipScript(java.lang.String targetNodeId)
protected boolean isCClient(java.lang.String nodeId)
protected boolean filterInitialLoad(org.jumpmind.symmetric.io.data.CsvData data)