[This is preliminary documentation and is subject to change.]
Overload List
Name | Description | |
---|---|---|
![]() ![]() | FromWebHdfs<TOutput, TTime>(Stream<Uri, TTime>, Func<Stream, IEnumerable<ArraySegment<TOutput>>>) |
Read a stream of path names (file or directory names) each of which corresponds to a collection of HDFS files
serialized in a custom binary format. Concatenate all the records to the output, in an unspecified order.
|
![]() ![]() | FromWebHdfs<TOutput, TTime>(Stream<Uri, TTime>, Func<Stream, IEnumerable<ArraySegment<TOutput>>>, String, Int32) |
Read a stream of path names (file or directory names) each of which corresponds to a collection of HDFS files
serialized in a custom binary format. Concatenate all the records to the output, in an unspecified order.
|
See Also