|
Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Converts codec to streaming codec More...
Inherits Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.
Public Member Functions | |
| T | Read (IDataReader reader) |
| Instantiate the class from the reader. More... | |
| void | Write (T obj, IDataWriter writer) |
| Writes the class fields to the writer. More... | |
| async Task< T > | ReadAsync (IDataReader reader, CancellationToken token) |
| Instantiate the class from the reader. More... | |
| async Task | WriteAsync (T obj, IDataWriter writer, CancellationToken token) |
| Writes the class fields to the writer. More... | |
Converts codec to streaming codec
| T | Message type |
|
inline |
Instantiate the class from the reader.
| reader | The reader from which to read |
Implements Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.
|
inline |
Instantiate the class from the reader.
| reader | The reader from which to read |
| token | Cancellation token |
Implements Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.
|
inline |
Writes the class fields to the writer.
| obj | The object of type T to be encoded |
| writer | The writer to which to write |
Implements Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.
|
inline |
Writes the class fields to the writer.
| obj | The object of type T to be encoded |
| writer | The writer to which to write |
| token | Cancellation token |
Implements Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.
1.8.11