Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
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... | |
Interface for writing standard primitives
void Org.Apache.REEF.Wake.Remote.IDataWriter.Write | ( | byte[] | buffer, |
int | index, | ||
int | count | ||
) |
write bytes to the byte array
buffer | byte array from which to read |
index | starting index in the array |
count | number 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
buffer | byte array from which to read |
index | starting index in the array |
count | number of bytes to write |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.
void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteBoolean | ( | bool | obj | ) |
write boolean
obj | bool 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
obj | bool to be written |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.
void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteDouble | ( | double | obj | ) |
write double
obj | double 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
obj | double to be written |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.
void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteFloat | ( | float | obj | ) |
write float
obj | float 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
obj | float to be written |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.
void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteInt16 | ( | short | obj | ) |
write short
obj | short 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
obj | short to be written |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.
void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteInt32 | ( | int | obj | ) |
write integer
obj | int 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
obj | integer to be written |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.
void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteLong | ( | long | obj | ) |
write long
obj | long 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
obj | long to be written |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.
void Org.Apache.REEF.Wake.Remote.IDataWriter.WriteString | ( | string | obj | ) |
write string
obj | string 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
obj | string to be written |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.Remote.Impl.StreamDataWriter.