package Ġcom . example . k stream ers Ċ Ċ import Ġcom . es ot eric software . k ry o . K ry o ; Ċ import Ġcom . es ot eric software . k ry o . Serializer ; Ċ import Ġcom . es ot eric software . k ry o . io . Input ; Ċ import Ġcom . es ot eric software . k ry o . io . Output ; Ċ import Ġorg . apache . commons . lang . Serialization Exception ; Ċ import Ġorg . apache . ignite . Ign ite Checked Exception ; Ċ import Ġorg . apache . ignite . events . Cache Event ; Ċ import Ġorg . apache . ignite . marshaller . jdk . J dk Marshaller ; ĊĊ Ċ class ĠCache Event Serializer Ġ: ĠSerializer < Cache Event >() Ġ{ ĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠIf Ġtrue , Ġthe Ġtype Ġthis Ġserializer Ġwill Ġbe Ġused Ġfor Ġis Ġconsidered Ġimmutable . ĊĠĠĠĠ Ġ* ĠThis Ġcauses Ġ[. copy ] Ġto Ġreturn Ġthe Ġoriginal Ġobject . ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġinit Ġ{ ĊĠĠĠĠĠĠĠ Ġset Immutable ( true ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġwrite ( k ry o : ĠK ry o , Ġoutput : ĠOutput , Ġcache Event : ĠCache Event ) Ġ{ ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġoutput . write ( mar sh . marshal ( cache Event )) ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠIgn ite Checked Exception ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthrow ĠSerialization Exception (" Failed Ġto Ġserialize Ġcache Ġevent !", Ġe ) ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġread ( k ry o : ĠK ry o , Ġinput : ĠInput , Ġcache Event Class : ĠClass < Cache Event >): ĠCache Event Ġ{ ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġmar sh . un marshal ( input , ĠCache Event :: class . java . class Loader ) ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( e : ĠIgn ite Checked Exception ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthrow ĠSerialization Exception (" Failed Ġto Ġdeserialize Ġcache Ġevent !", Ġe ) ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠ Ġ} ĊĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĊĠĠĠĠĠĠĠ Ġ/** ĠMar shall er . Ġ Ġ*/ ĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġmar sh Ġ= ĠJ dk Marshaller () ĊĠĠĠ Ġ} Ċ }