com.graphdbapi.task.message

Interface IMessageHandler

public interface IMessageHandler

图计算框架消息处理接口

Method Summary

Modifier and Type	Method and Description
ArrayMessage	getInstance(java.lang.Object sendValues, java.lang.Object receiveValues) 获取消息对象.
void	getInstance(java.util.function.Supplier<java.lang.String> algorithm, long taskId, GraphLogger graphLogger, int sourceAffinity) 获取消息实例.
void	setStop() 设置停止.

Method Detail

setStop

void setStop()

设置停止.

getInstance

void getInstance(java.util.function.Supplier<java.lang.String> algorithm,
                 long taskId,
                 GraphLogger graphLogger,
                 int sourceAffinity)

获取消息实例.

Parameters:

algorithm - 传入算法

taskId - 任务Id

graphLogger - 日志

sourceAffinity - 源主机

getInstance

ArrayMessage getInstance(java.lang.Object sendValues,
                         java.lang.Object receiveValues)

获取消息对象.

Parameters:

sendValues - 发送消息对象

receiveValues - 发送消息对象

Returns:

消息处理对象