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 >.