diff options
author | Herman van Hovell <hvanhovell@questtec.nl> | 2015-11-05 09:23:09 +0000 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2015-11-05 09:23:09 +0000 |
commit | 7bdc92197cce0edc0110dc9c2158e6e3f42c72ee (patch) | |
tree | a4820fa8f08f2de88860fea539abb09d122be3f9 /mllib/src/main/scala/org | |
parent | 859dff56eb0f8c63c86e7e900a12340c199e6247 (diff) | |
download | spark-7bdc92197cce0edc0110dc9c2158e6e3f42c72ee.tar.gz spark-7bdc92197cce0edc0110dc9c2158e6e3f42c72ee.tar.bz2 spark-7bdc92197cce0edc0110dc9c2158e6e3f42c72ee.zip |
[SPARK-11449][CORE] PortableDataStream should be a factory
```PortableDataStream``` maintains some internal state. This makes it tricky to reuse a stream (one needs to call ```close``` on both the ```PortableDataStream``` and the ```InputStream``` it produces).
This PR removes all state from ```PortableDataStream``` and effectively turns it into an ```InputStream```/```Array[Byte]``` factory. This makes the user responsible for managing the ```InputStream``` it returns.
cc srowen
Author: Herman van Hovell <hvanhovell@questtec.nl>
Closes #9417 from hvanhovell/SPARK-11449.
Diffstat (limited to 'mllib/src/main/scala/org')
0 files changed, 0 insertions, 0 deletions