See: Description
Class | Description |
---|---|
CollectSink<IN> |
A specialized data sink to be used by DataStreamUtils.collect().
|
SocketStreamIterator<T> |
An iterator that returns the data from a socket stream.
|
They are NOT battle-tested code and may be changed or removed in future versions.
None of the classes should be @Public.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.