You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by M Singh <ma...@yahoo.com> on 2016/06/05 17:14:33 UTC
Ignite : IgniteDataStreamer question about units/valid ranges for
perNodeBufferSize, autoFlushFrequency
Hi:
I was looking at the javadoc for some of the methods in this interface and am not sure of units as well as the ranges for these allowed values. The impl class just checks for positive argument.
If anyone has any pointers, please let me know. Thanks
/** * Gets size of per node key-value pairs buffer. * * @return Per node buffer size. */ public int perNodeBufferSize();
Is buffer size in bytes or count of items ?
/** * Sets automatic flush frequency. Essentially, this is the time after which the * streamer will make an attempt to submit all data added so far to remote nodes. * Note that there is no guarantee that data will be delivered after this concrete * attempt (e.g., it can fail when topology is changing), but it won't be lost anyway. * <p> * If set to {@code 0}, automatic flush is disabled. * <p> * Automatic flush is disabled by default (default value is {@code 0}). * * @param autoFlushFreq Flush frequency or {@code 0} to disable automatic flush. * @see #flush() */ public void autoFlushFrequency(long autoFlushFreq);
Is the freq in times/sec or every millis etc ?
Re: Ignite : IgniteDataStreamer question about units/valid ranges for
perNodeBufferSize, autoFlushFrequency
Posted by Vladislav Pyatkov <vl...@gmail.com>.
Hello,
I do not see any restrictions other than reasonable.
perNodeBufferSize only positive value
autoFlushFrequency only positive value and if auto flush disabled then 0
On Mon, Jun 6, 2016 at 11:33 AM, M Singh <ma...@yahoo.com> wrote:
> Is there any valid range for these attributes ?
>
>
> On Monday, June 6, 2016 1:31 AM, M Singh <ma...@yahoo.com> wrote:
>
>
> Thanks Vladislav for the clarification.
>
>
> On Monday, June 6, 2016 12:45 AM, Vladislav Pyatkov <vl...@gmail.com>
> wrote:
>
>
> Hello,
>
> 1) perNodeBufferSize - is the number of entries in the buffer.
> 2) autoFlushFrequency - in milliseconds
>
> On Sun, Jun 5, 2016 at 8:14 PM, M Singh <ma...@yahoo.com> wrote:
>
> Hi:
>
> I was looking at the javadoc for some of the methods in this interface and
> am not sure of units as well as the ranges for these allowed values. The
> impl class just checks for positive argument.
>
> If anyone has any pointers, please let me know. Thanks
>
>
> /**
> * Gets size of per node key-value pairs buffer.
> *
> * @return Per node buffer size.
> */
> public int perNodeBufferSize();
>
> Is buffer size in bytes or count of items ?
>
> /**
> * Sets automatic flush frequency. Essentially, this is the time after
> which the
> * streamer will make an attempt to submit all data added so far to
> remote nodes.
> * Note that there is no guarantee that data will be delivered after
> this concrete
> * attempt (e.g., it can fail when topology is changing), but it won't
> be lost anyway.
> * <p>
> * If set to {@code 0}, automatic flush is disabled.
> * <p>
> * Automatic flush is disabled by default (default value is {@code 0}).
> *
> * @param autoFlushFreq Flush frequency or {@code 0} to disable
> automatic flush.
> * @see #flush()
> */
> public void autoFlushFrequency(long autoFlushFreq);
>
> Is the freq in times/sec or every millis etc ?
>
>
>
>
>
> --
> Vladislav Pyatkov
>
>
>
>
>
--
Vladislav Pyatkov
Re: Ignite : IgniteDataStreamer question about units/valid ranges
for perNodeBufferSize, autoFlushFrequency
Posted by M Singh <ma...@yahoo.com>.
Is there any valid range for these attributes ?
On Monday, June 6, 2016 1:31 AM, M Singh <ma...@yahoo.com> wrote:
Thanks Vladislav for the clarification.
On Monday, June 6, 2016 12:45 AM, Vladislav Pyatkov <vl...@gmail.com> wrote:
Hello,
1) perNodeBufferSize - is the number of entries in the buffer.2) autoFlushFrequency - in milliseconds
On Sun, Jun 5, 2016 at 8:14 PM, M Singh <ma...@yahoo.com> wrote:
Hi:
I was looking at the javadoc for some of the methods in this interface and am not sure of units as well as the ranges for these allowed values. The impl class just checks for positive argument.
If anyone has any pointers, please let me know. Thanks
/** * Gets size of per node key-value pairs buffer. * * @return Per node buffer size. */ public int perNodeBufferSize();
Is buffer size in bytes or count of items ?
/** * Sets automatic flush frequency. Essentially, this is the time after which the * streamer will make an attempt to submit all data added so far to remote nodes. * Note that there is no guarantee that data will be delivered after this concrete * attempt (e.g., it can fail when topology is changing), but it won't be lost anyway. * <p> * If set to {@code 0}, automatic flush is disabled. * <p> * Automatic flush is disabled by default (default value is {@code 0}). * * @param autoFlushFreq Flush frequency or {@code 0} to disable automatic flush. * @see #flush() */ public void autoFlushFrequency(long autoFlushFreq);
Is the freq in times/sec or every millis etc ?
--
Vladislav Pyatkov
Re: Ignite : IgniteDataStreamer question about units/valid ranges
for perNodeBufferSize, autoFlushFrequency
Posted by M Singh <ma...@yahoo.com>.
Thanks Vladislav for the clarification.
On Monday, June 6, 2016 12:45 AM, Vladislav Pyatkov <vl...@gmail.com> wrote:
Hello,
1) perNodeBufferSize - is the number of entries in the buffer.2) autoFlushFrequency - in milliseconds
On Sun, Jun 5, 2016 at 8:14 PM, M Singh <ma...@yahoo.com> wrote:
Hi:
I was looking at the javadoc for some of the methods in this interface and am not sure of units as well as the ranges for these allowed values. The impl class just checks for positive argument.
If anyone has any pointers, please let me know. Thanks
/** * Gets size of per node key-value pairs buffer. * * @return Per node buffer size. */ public int perNodeBufferSize();
Is buffer size in bytes or count of items ?
/** * Sets automatic flush frequency. Essentially, this is the time after which the * streamer will make an attempt to submit all data added so far to remote nodes. * Note that there is no guarantee that data will be delivered after this concrete * attempt (e.g., it can fail when topology is changing), but it won't be lost anyway. * <p> * If set to {@code 0}, automatic flush is disabled. * <p> * Automatic flush is disabled by default (default value is {@code 0}). * * @param autoFlushFreq Flush frequency or {@code 0} to disable automatic flush. * @see #flush() */ public void autoFlushFrequency(long autoFlushFreq);
Is the freq in times/sec or every millis etc ?
--
Vladislav Pyatkov
Re: Ignite : IgniteDataStreamer question about units/valid ranges for
perNodeBufferSize, autoFlushFrequency
Posted by Vladislav Pyatkov <vl...@gmail.com>.
Hello,
1) perNodeBufferSize - is the number of entries in the buffer.
2) autoFlushFrequency - in milliseconds
On Sun, Jun 5, 2016 at 8:14 PM, M Singh <ma...@yahoo.com> wrote:
> Hi:
>
> I was looking at the javadoc for some of the methods in this interface and
> am not sure of units as well as the ranges for these allowed values. The
> impl class just checks for positive argument.
>
> If anyone has any pointers, please let me know. Thanks
>
>
> /**
> * Gets size of per node key-value pairs buffer.
> *
> * @return Per node buffer size.
> */
> public int perNodeBufferSize();
>
> Is buffer size in bytes or count of items ?
>
> /**
> * Sets automatic flush frequency. Essentially, this is the time after
> which the
> * streamer will make an attempt to submit all data added so far to
> remote nodes.
> * Note that there is no guarantee that data will be delivered after
> this concrete
> * attempt (e.g., it can fail when topology is changing), but it won't
> be lost anyway.
> * <p>
> * If set to {@code 0}, automatic flush is disabled.
> * <p>
> * Automatic flush is disabled by default (default value is {@code 0}).
> *
> * @param autoFlushFreq Flush frequency or {@code 0} to disable
> automatic flush.
> * @see #flush()
> */
> public void autoFlushFrequency(long autoFlushFreq);
>
> Is the freq in times/sec or every millis etc ?
>
>
>
--
Vladislav Pyatkov