Мы новичок в скале и апаче флинк.Когда мы пытаемся преобразовать scala.collection.mutable.Map в класс Scala POJO, используя ObjectMapper [com.fasterxml.jackson.databind.ObjectMapper], получая нераспознанное поле «sizeMapDefined», исключение.
com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: нераспознанное поле «sizeMapDefined» (класс com.test.model.Data), не помеченное как игнорируемое
Попытка подписать данныеот AMPS (crankuptheamps) как DataStream с помощью apache flink.
import com.fasterxml.jackson.annotation.JsonIgnoreProperties
import scala.beans.BeanProperty
@JsonIgnoreProperties(ignoreUnknown = true)
@SerialVersionUID(123L)
class Data() extends Serializable {
@BeanProperty var name: String = _
@BeanProperty var address: String = _
override def toString = s"Data($name, $address)"
}
@transient lazy val mapper = new ObjectMapper() with Serializable with ScalaObjectMapper
mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
mapper.registerModule(DefaultScalaModule)
var map = scala.collection.mutable.Map("name" -> "Thiru",
"address" -> "Mayiladuthurai")
val testClass = mapper.convertValue(map, classOf[Data])