com.hazelcast.jet.strategy

Interface DataTransferringStrategy<T>

Type Parameters:

T - type if input source objects to be written into the ringBuffer

All Superinterfaces:

Serializable

public interface DataTransferringStrategy<T>
extends Serializable

Represents strategy of data transferring Jet uses ringBuffers to pass data from one vertex to another RingBuffers can work by reference or by value By references means that all input objects will be copied into the ringBuffer by reference (without internal copy) By value means ringBuffer has pre-allocated objects Data will be copied from input objects into pre-allocated objects Used depends on the flow to avoid copy or in opposite to avoid garbage creation

Method Summary

Modifier and Type	Method and Description
boolean	byReference()
void	clean(T object) Clean object's internals
void	copy(T sourceObject, T targetObject) Copy data from one object to another
T	newInstance() Creates new instance of object

Method Detail

byReference

boolean byReference()

Returns:

true in case of "by reference" strategy, false in case if "by value" strategy

newInstance

T newInstance()

Creates new instance of object

Returns:

the new instance

copy

void copy(T sourceObject,
          T targetObject)

Copy data from one object to another

Parameters:

sourceObject - object with source data

targetObject - target object

clean

void clean(T object)

Clean object's internals

Parameters:

object - object to clean