com._4paradigm.openmldb.synctool

Class SyncTask

java.lang.Object

com._4paradigm.openmldb.synctool.SyncTask

@ThreadSafe
public class SyncTask
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SyncTask.Status

Constructor Summary

Constructors

Constructor and Description
SyncTask(DataSync.AddSyncTaskRequest request, String dataCollector)

Method Summary

Modifier and Type	Method and Description
DataSync.Task	buildTaskPB()
void	close()
String	extraInfo()
String	getDataCollector()
DataSync.AddSyncTaskRequest	getProgress()
SyncTask.Status	getStatus()
void	persist()
void	preCheck(DataSync.SendDataRequest request)
static SyncTask	recover(String filePath)
void	setDataCollector(String dataCollector)
void	setStatus(SyncTask.Status status)
void	setTabletServer(String tabletServer)
void	setToken(String token)
void	updateProgress(DataSync.SendDataRequest request)

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncTask

public SyncTask(DataSync.AddSyncTaskRequest request,
                String dataCollector)

Method Detail

persist

public void persist()
             throws IOException

Throws:

IOException

recover

public static SyncTask recover(String filePath)
                        throws IOException

Throws:

IOException

getProgress

public DataSync.AddSyncTaskRequest getProgress()

preCheck

public void preCheck(DataSync.SendDataRequest request)
              throws IgnorableException

Throws:

IgnorableException

updateProgress

public void updateProgress(DataSync.SendDataRequest request)
                    throws IgnorableException

Throws:

IgnorableException

buildTaskPB

public DataSync.Task buildTaskPB()

setToken

public void setToken(String token)

extraInfo

public String extraInfo()

getDataCollector

public String getDataCollector()

setDataCollector

public void setDataCollector(String dataCollector)

setTabletServer

public void setTabletServer(String tabletServer)

getStatus

public SyncTask.Status getStatus()

setStatus

public void setStatus(SyncTask.Status status)

close

public void close()
           throws IOException

Throws:

IOException