Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Codec Interface that external users should implement to directly write to the stream More...
Inherited by Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< 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... | |
Task< T > | ReadAsync (IDataReader reader, CancellationToken token) |
Instantiate the class from the reader. More... | |
Task | WriteAsync (T obj, IDataWriter writer, CancellationToken token) |
Writes the class fields to the writer. More... | |
Codec Interface that external users should implement to directly write to the stream
T Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.Read | ( | IDataReader | reader | ) |
Instantiate the class from the reader.
reader | The reader from which to read |
Implemented in Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T >.
Task<T> Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.ReadAsync | ( | IDataReader | reader, |
CancellationToken | token | ||
) |
Instantiate the class from the reader.
reader | The reader from which to read |
token | Cancellation token |
Implemented in Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T >.
void Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.Write | ( | T | obj, |
IDataWriter | writer | ||
) |
Writes the class fields to the writer.
obj | The object of type T to be encoded |
writer | The writer to which to write |
Implemented in Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T >.
Task Org.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T >.WriteAsync | ( | T | obj, |
IDataWriter | writer, | ||
CancellationToken | token | ||
) |
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 |
Implemented in Org.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T >.