Hello,
I would like to hive directions to make my code work again (thanks in advance).
My code used to work on versions equal or less than 9.1 but when i included 10
or 10.1 i got the following exception.
This type
(ObjectArrayTypeInfo<GenericType<it.polimi.genomics.core.DataTypes.GValue>>)
cannot be used as key
I understood that it is related to the serialisation of objects. I tried to
follow the POJO building directions in
https://cwiki.apache.org/confluence/display/FLINK/Type+System,+Type+Extraction,+Serializationwith
no luck to make it work.
my dataset contains a set of tuples as key and one array of GValues, this is a
snapshot of the GValue class.
sealed trait GValue extends Serializable with Ordered[GValue]{
def compare(o : GValue) : Int = {
o match {
case GDouble(v) => this.asInstanceOf[GDouble].v compare v
case GString(v) => this.asInstanceOf[GString].v compare v
case GInt(v) => this.asInstanceOf[GInt].v compare v
case GNull() => 0
}
}
def equal(o : GValue) : Boolean = {
o match {
case GInt(value) => try{value.equals(o.asInstanceOf[GInt].v)} catch {
case e : Throwable => false }
case GDouble(value) => try{value.equals(o.asInstanceOf[GDouble].v)} catch
{ case e : Throwable => false }
case GString(value) => try{value.equals(o.asInstanceOf[GString].v)} catch
{ case e : Throwable => false }
case GNull() => o.isInstanceOf[GNull]
case _ => false
}
}
}
/**
* Represents a @GValue that contains an integer
* @deprecated
* @param v
*/
case class GInt(v: Int) extends GValue{
def this() = this(0)
override def toString() : String = {
v.toString
}
override def equals(other : Any) : Boolean = {
other match {
case GInt(value) => value.equals(v)
case _ => false
}
}
}
/**
* Represents a @GValue that contains a number as a @Double
* @param v number
*/
case class GDouble(v: Double) extends GValue {//with Ordered[GDouble]{
def this() = this(0.0)
override def equals(other : Any) : Boolean = {
other match {
case GDouble(value) => value.equals(v)
case _ => false
}
}
}
/**
* Represents a @GValue that contains a @String
* @param v string
*/
case class GString(v: String) extends GValue{
def this() = this(".")
override def toString() : String = {
v.toString
}
override def equals(other : Any) : Boolean = {
other match {
case GString(value) => value.equals(v)
case _ => false
}
}
}
Regards,
-----------------------------------------------------------------
Abdulrahman Kaitoua
-----------------------------------------------------------------
Ph.D. Candidate at Politecnico Di Milano
