小编Blu*_*Dog的帖子

我正在将Spark Scala App Kafka API升级到v.0.10.我曾经创建自定义方法来反序列化以字节字符串格式出现的消息.

我已经意识到有一种方法可以将StringDeserializer或ByteArrayDeserializer作为参数传递给键或值.

但是,我找不到有关如何创建自定义Avro架构反序列化器的任何信息,因此我的kafkaStream可以在createDirectStream和使用Kafka的数据时使用它.

可能吗？

在Django中是否可以使用request.GET的模型方法？例如

    class Car(models.Model):
        owner = ForeignKey(Owner)
        car_model = ...
        def car_filter(self, request):
            query = request.GET.get("q")
            if query:
                Car.objects.filter(owner = self.id.order_by('id')
            else:
                Car.objects.filter(owner = me).order_by('id'

)

？