edu.iu.dsc.tws.api.compute.executor

Interface ISync

All Known Implementing Classes:

SourceBatchInstance, TaskBatchInstance, TaskStreamingInstance

public interface ISync

Sync interface, this method is called when barriers come and tasks sync

Method Summary

Modifier and Type	Method and Description
boolean	sync(java.lang.String edge, byte[] value) Callback for sync

Method Detail

sync

boolean sync(java.lang.String edge,
             byte[] value)

Callback for sync

Parameters:

edge - edge name

value - value, can be null

Returns:

if we handled the sync, return true