This project has retired. For details please refer to its Attic page.
Apache REEF: Org.Apache.REEF.Wake.Remote.IDataWriter Interface Reference
Apache REEF  0.15.0
Retainable Evaluator Execution Framework
Public Member Functions | List of all members
Org.Apache.REEF.Wake.Remote.IDataWriter Interface Reference

Interface for writing standard primitives More...

Inherited by Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Public Member Functions

void WriteDouble (double obj)
 write double More...
 
void WriteFloat (float obj)
 write float More...
 
void WriteLong (long obj)
 write long More...
 
void WriteBoolean (bool obj)
 write boolean More...
 
void WriteInt32 (int obj)
 write integer More...
 
void WriteInt16 (short obj)
 write short More...
 
void WriteString (string obj)
 write string More...
 
void Write (byte[] buffer, int index, int count)
 write bytes to the byte array More...
 
Task WriteDoubleAsync (double obj, CancellationToken token)
 write double asynchronously More...
 
Task WriteFloatAsync (float obj, CancellationToken token)
 write float asynchronously More...
 
Task WriteLongAsync (long obj, CancellationToken token)
 write long asynchronously More...
 
Task WriteBooleanAsync (bool obj, CancellationToken token)
 write bool asynchronously More...
 
Task WriteInt32Async (int obj, CancellationToken token)
 write integer asynchronously More...
 
Task WriteInt16Async (short obj, CancellationToken token)
 write short asynchronously More...
 
Task WriteStringAsync (string obj, CancellationToken token)
 write string asynchronously More...
 
Task WriteAsync (byte[] buffer, int index, int count, CancellationToken token)
 write bytes to the byte array asynchronously More...
 

Detailed Description

Interface for writing standard primitives

Member Function Documentation

void Org.Apache.REEF.Wake.Remote.IDataWriter.Write ( byte[]  buffer,
int  index,
int  count 
)

write bytes to the byte array

Parameters
bufferbyte array from which to read
indexstarting index in the array
countnumber of bytes to write

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Task Org.Apache.REEF.Wake.Remote.IDataWriter.WriteAsync ( byte[]  buffer,
int  index,
int  count,
CancellationToken  token 
)

write bytes to the byte array asynchronously

Parameters
bufferbyte array from which to read
indexstarting index in the array
countnumber of bytes to write
tokenCancellation token
Returns
the handler to the task

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteBoolean ( bool  obj)

write boolean

Parameters
objbool to be written

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Task Org.Apache.REEF.Wake.Remote.IDataWriter.WriteBooleanAsync ( bool  obj,
CancellationToken  token 
)

write bool asynchronously

Parameters
objbool to be written
tokenCancellation token
Returns
the handler to the task

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteDouble ( double  obj)

write double

Parameters
objdouble to be written

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Task Org.Apache.REEF.Wake.Remote.IDataWriter.WriteDoubleAsync ( double  obj,
CancellationToken  token 
)

write double asynchronously

Parameters
objdouble to be written
tokenCancellation token
Returns
the handler to the task

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteFloat ( float  obj)

write float

Parameters
objfloat to be written

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Task Org.Apache.REEF.Wake.Remote.IDataWriter.WriteFloatAsync ( float  obj,
CancellationToken  token 
)

write float asynchronously

Parameters
objfloat to be written
tokenCancellation token
Returns
the handler to the task

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteInt16 ( short  obj)

write short

Parameters
objshort to be written

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Task Org.Apache.REEF.Wake.Remote.IDataWriter.WriteInt16Async ( short  obj,
CancellationToken  token 
)

write short asynchronously

Parameters
objshort to be written
tokenCancellation token
Returns
the handler to the task

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteInt32 ( int  obj)

write integer

Parameters
objint to be written

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Task Org.Apache.REEF.Wake.Remote.IDataWriter.WriteInt32Async ( int  obj,
CancellationToken  token 
)

write integer asynchronously

Parameters
objinteger to be written
tokenCancellation token
Returns
the handler to the task

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteLong ( long  obj)

write long

Parameters
objlong to be written

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Task Org.Apache.REEF.Wake.Remote.IDataWriter.WriteLongAsync ( long  obj,
CancellationToken  token 
)

write long asynchronously

Parameters
objlong to be written
tokenCancellation token
Returns
the handler to the task

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteString ( string  obj)

write string

Parameters
objstring to be written

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.

Task Org.Apache.REEF.Wake.Remote.IDataWriter.WriteStringAsync ( string  obj,
CancellationToken  token 
)

write string asynchronously

Parameters
objstring to be written
tokenCancellation token
Returns
the handler to the task

Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.


The documentation for this interface was generated from the following file: