ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vladislav Pyatkov <vldpyat...@gmail.com>
Subject Re: Ignite : IgniteDataStreamer question about units/valid ranges for perNodeBufferSize, autoFlushFrequency
Date Mon, 06 Jun 2016 14:34:33 GMT
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 <mans2singh@yahoo.com> wrote:

> Is there any valid range for these attributes ?
>
>
> On Monday, June 6, 2016 1:31 AM, M Singh <mans2singh@yahoo.com> wrote:
>
>
> Thanks Vladislav for the clarification.
>
>
> On Monday, June 6, 2016 12:45 AM, Vladislav Pyatkov <vldpyatkov@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 <mans2singh@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

Mime
View raw message