com._4paradigm.openmldb.synctool

Class SyncToolImpl

java.lang.Object

com._4paradigm.openmldb.synctool.SyncToolImpl

All Implemented Interfaces:

SyncToolInterface

public class SyncToolImpl
extends Object
implements SyncToolInterface

Constructor Summary

Constructors

Constructor and Description
SyncToolImpl(String endpoint)

Method Summary

Modifier and Type	Method and Description
DataSync.GeneralResponse	CreateSyncTask(DataSync.CreateSyncTaskRequest request)
DataSync.GeneralResponse	DeleteSyncTask(DataSync.DeleteSyncTaskRequest request)
static String	genCacheDir(int tid)
void	init()
void	saveToCache(String cacheDir, io.netty.buffer.ByteBuf data, long count, List<Common.ColumnDesc> schema)
DataSync.SendDataResponse	SendData(DataSync.SendDataRequest request)
DataSync.TaskStatusResponse	TaskStatus(DataSync.TaskStatusRequest request)
static String	uniqueFileName()

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncToolImpl

public SyncToolImpl(String endpoint)
             throws SqlException,
                    InterruptedException

Throws:

SqlException

InterruptedException

Method Detail

init

public void init()

CreateSyncTask

public DataSync.GeneralResponse CreateSyncTask(DataSync.CreateSyncTaskRequest request)

Specified by:

CreateSyncTask in interface SyncToolInterface

genCacheDir

public static String genCacheDir(int tid)

DeleteSyncTask

public DataSync.GeneralResponse DeleteSyncTask(DataSync.DeleteSyncTaskRequest request)

Specified by:

DeleteSyncTask in interface SyncToolInterface

SendData

public DataSync.SendDataResponse SendData(DataSync.SendDataRequest request)

Specified by:

SendData in interface SyncToolInterface

saveToCache

public void saveToCache(String cacheDir,
                        io.netty.buffer.ByteBuf data,
                        long count,
                        List<Common.ColumnDesc> schema)

uniqueFileName

public static String uniqueFileName()

TaskStatus

public DataSync.TaskStatusResponse TaskStatus(DataSync.TaskStatusRequest request)

Specified by:

TaskStatus in interface SyncToolInterface