Mailing-List: contact user-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@ignite.apache.org
MIME-Version: 1.0
In-Reply-To: <CAK2_iMOYUhaCWppNMYQepLfS_6imY7+N-ArDRq93FjZgc9EBrg@mail.gmail.com>
References: <1466669175937-5819.post@n6.nabble.com> <CAK2_iMPyO7MqdiP30Fydh+kcJYFONwggU_NHveTd5cuu-HnO2Q@mail.gmail.com>
 <1466688290018-5838.post@n6.nabble.com> <CAK2_iMMiteZDsra-6yb2D=WRtSsf0-p+62O-GRGQnnkTC+jouA@mail.gmail.com>
 <1466766958856-5872.post@n6.nabble.com> <CAK2_iMOYUhaCWppNMYQepLfS_6imY7+N-ArDRq93FjZgc9EBrg@mail.gmail.com>
From: Pavel Tupitsyn <ptupitsyn@gridgain.com>
Date: Fri, 24 Jun 2016 15:26:34 +0300
Message-ID: <CAK2_iMN22Tp8nH4_cdytcy0guasCguhxCFG+0hOPwUyY8Emmkw@mail.gmail.com>
Subject: Re: Enable Binary Reflective Serializer in the app.config
To: user@ignite.apache.org
Content-Type: multipart/alternative; boundary=94eb2c0340a8c5e716053605495d
archived-at: Fri, 24 Jun 2016 12:27:18 -0000

--94eb2c0340a8c5e716053605495d
Content-Type: text/plain; charset=UTF-8

The workaround is to implement raw mode manually via IBinarizable interface.
It will look like this for the OrderEntity class (field order should be the
same in read and write methods):

public void WriteBinary(IBinaryWriter writer)
{
    var w = writer.GetRawWriter();

    w.WriteInt(OrderId);
    w.WriteString(OrderName);
    w.WriteObject(OrderDateTime);
    w.WriteDouble(OrderValue);
    w.WriteString(OrderAddress);
}
 public void ReadBinary(IBinaryReader reader)
{
    var r = reader.GetRawReader();

    OrderId = r.ReadInt();
    OrderName = r.ReadString();
    OrderDateTime = r.ReadObject<DateTime>();
    OrderValue = r.ReadDouble();
    OrderAddress = r.ReadString();
}


On Fri, Jun 24, 2016 at 3:22 PM, Pavel Tupitsyn <ptupitsyn@gridgain.com>
wrote:

> I've reproduced it.
> There is a bug with DateTime in raw mode. It works when I remove
> OrderEntity.OrderDateTime property.
>
> Bug is filed and will be fixed shortly:
> https://issues.apache.org/jira/browse/IGNITE-3364
>
> On Fri, Jun 24, 2016 at 2:15 PM, mrinalkamboj <mrinal.technology@gmail.com
> > wrote:
>
>> On enabling the rawMode="true", as suggested in the configuration file,
>> following piece of code leads to the exception:
>>
>>  using (var ldr = ignite.GetDataStreamer<int, OrderEntity>("OrderCache"))
>>             {
>>                 ldr.PerNodeBufferSize = 1024;
>>
>>                 //ldr.AllowOverwrite = true;
>>
>>                 var parallelOptions = new ParallelOptions {
>> MaxDegreeOfParallelism = Environment.ProcessorCount };
>>
>>                 // ReSharper disable once AccessToDisposedClosure
>>                 Parallel.Invoke(parallelOptions, orders.Select(order =>
>> (Action)(() => ldr.AddData(order.OrderId, order))).ToArray());
>>             }
>>
>> On the AddData call of the Data Streamer and the Exception is:
>>
>> {Apache.Ignite.Core.Binary.BinaryObjectException} - Cannot write named
>> fields after raw data is written.
>>
>> Logically this looks correct, but what shall I do now, can't use Data
>> Streamer with this setting, if I remove the rawMode setting then it works
>> fine
>>
>>
>>
>>
>> --
>> View this message in context:
>> http://apache-ignite-users.70518.x6.nabble.com/Enable-Binary-Reflective-Serializer-in-the-app-config-tp5819p5872.html
>> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>>
>
>

--94eb2c0340a8c5e716053605495d
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">The workaround is to implement raw mode manually via=C2=A0=
IBinarizable interface.<div>It will look like this for the OrderEntity clas=
s (field order should be the same in read and write methods):</div><div><pr=
e style=3D"font-family:Consolas;color:black;background-image:initial;backgr=
ound-repeat:initial"><span style=3D"color:blue">public</span>=C2=A0<span st=
yle=3D"color:blue">void</span>=C2=A0WriteBinary(<span style=3D"color:rgb(43=
,145,175)">IBinaryWriter</span>=C2=A0writer)
{
=C2=A0=C2=A0=C2=A0=C2=A0<span style=3D"color:blue">var</span>=C2=A0w=C2=A0=
=3D=C2=A0writer.GetRawWriter();
=20
=C2=A0=C2=A0=C2=A0=C2=A0w.WriteInt(OrderId);
=C2=A0=C2=A0=C2=A0=C2=A0w.WriteString(OrderName);
=C2=A0=C2=A0=C2=A0=C2=A0w.WriteObject(OrderDateTime);
=C2=A0=C2=A0=C2=A0=C2=A0w.WriteDouble(OrderValue);
=C2=A0=C2=A0=C2=A0=C2=A0w.WriteString(OrderAddress);
}
=20
<span style=3D"color:blue">public</span>=C2=A0<span style=3D"color:blue">vo=
id</span>=C2=A0ReadBinary(<span style=3D"color:rgb(43,145,175)">IBinaryRead=
er</span>=C2=A0reader)
{
=C2=A0=C2=A0=C2=A0=C2=A0<span style=3D"color:blue">var</span>=C2=A0r=C2=A0=
=3D=C2=A0reader.GetRawReader();
=20
=C2=A0=C2=A0=C2=A0=C2=A0OrderId=C2=A0=3D=C2=A0r.ReadInt();
=C2=A0=C2=A0=C2=A0=C2=A0OrderName=C2=A0=3D=C2=A0r.ReadString();
=C2=A0=C2=A0=C2=A0=C2=A0OrderDateTime=C2=A0=3D=C2=A0r.ReadObject&lt;<span s=
tyle=3D"color:rgb(43,145,175)">DateTime</span>&gt;();
=C2=A0=C2=A0=C2=A0=C2=A0OrderValue=C2=A0=3D=C2=A0r.ReadDouble();
=C2=A0=C2=A0=C2=A0=C2=A0OrderAddress=C2=A0=3D=C2=A0r.ReadString();
}
</pre></div></div><div class=3D"gmail_extra"><br><div class=3D"gmail_quote"=
>On Fri, Jun 24, 2016 at 3:22 PM, Pavel Tupitsyn <span dir=3D"ltr">&lt;<a h=
ref=3D"mailto:ptupitsyn@gridgain.com" target=3D"_blank">ptupitsyn@gridgain.=
com</a>&gt;</span> wrote:<br><blockquote class=3D"gmail_quote" style=3D"mar=
gin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><div dir=3D"ltr=
"><div>I&#39;ve reproduced it.=C2=A0</div><div>There is a bug with DateTime=
 in raw mode. It works when I remove OrderEntity.OrderDateTime property.</d=
iv><div><br></div><div>Bug is filed and will be fixed shortly:=C2=A0<a href=
=3D"https://issues.apache.org/jira/browse/IGNITE-3364" target=3D"_blank">ht=
tps://issues.apache.org/jira/browse/IGNITE-3364</a></div></div><div class=
=3D"HOEnZb"><div class=3D"h5"><div class=3D"gmail_extra"><br><div class=3D"=
gmail_quote">On Fri, Jun 24, 2016 at 2:15 PM, mrinalkamboj <span dir=3D"ltr=
">&lt;<a href=3D"mailto:mrinal.technology@gmail.com" target=3D"_blank">mrin=
al.technology@gmail.com</a>&gt;</span> wrote:<br><blockquote class=3D"gmail=
_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:=
1ex">On enabling the rawMode=3D&quot;true&quot;, as suggested in the config=
uration file,<br>
following piece of code leads to the exception:<br>
<br>
=C2=A0using (var ldr =3D ignite.GetDataStreamer&lt;int, OrderEntity&gt;(&qu=
ot;OrderCache&quot;))<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 ldr.PerNodeBufferSi=
ze =3D 1024;<br>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 //ldr.AllowOverwrit=
e =3D true;<br>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 var parallelOptions=
 =3D new ParallelOptions {<br>
MaxDegreeOfParallelism =3D Environment.ProcessorCount };<br>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 // ReSharper disabl=
e once AccessToDisposedClosure<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 Parallel.Invoke(par=
allelOptions, orders.Select(order =3D&gt;<br>
(Action)(() =3D&gt; ldr.AddData(order.OrderId, order))).ToArray());<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 }<br>
<br>
On the AddData call of the Data Streamer and the Exception is:<br>
<br>
{Apache.Ignite.Core.Binary.BinaryObjectException} - Cannot write named<br>
fields after raw data is written.<br>
<br>
Logically this looks correct, but what shall I do now, can&#39;t use Data<b=
r>
Streamer with this setting, if I remove the rawMode setting then it works<b=
r>
fine<br>
<br>
<br>
<br>
<br>
--<br>
View this message in context: <a href=3D"http://apache-ignite-users.70518.x=
6.nabble.com/Enable-Binary-Reflective-Serializer-in-the-app-config-tp5819p5=
872.html" rel=3D"noreferrer" target=3D"_blank">http://apache-ignite-users.7=
0518.x6.nabble.com/Enable-Binary-Reflective-Serializer-in-the-app-config-tp=
5819p5872.html</a><br>
<div><div>Sent from the Apache Ignite Users mailing list archive at Nabble.=
com.<br>
</div></div></blockquote></div><br></div>
</div></div></blockquote></div><br></div>

--94eb2c0340a8c5e716053605495d--