Igniters, I have implemented timeout in DataStreamer by issue IGNITE-3055 <https://issues.apache.org/jira/browse/IGNITE-3055>(*IgniteDataStreamer can't be timed out*).
That lead the change public API: 1) Added set and get methods (IgniteDataStreamer.timeout(long) and IgniteDataStreamer.timeout()) for establish. Default value is -1, means unlimited time. 2) Added new TimeoutException (inherited IgniteException). The exception will thrown when timeout will be reached (may be take place in IgniteDataStreamer.addData, IgniteDataStreamer.close and IgniteDataStreamer.flash operations). Dmitry, colleagues, please comment or approve.