Hi Vlad, Can you please list the API changes in the ticket, so others can review without digging in code?
Thanks, D. On Mon, Jul 11, 2016 at 1:14 PM, Vladislav Pyatkov <vpyat...@gridgain.com> wrote: > 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. > >
