GitHub user upio opened a pull request:
https://github.com/apache/incubator-storm/pull/208
Introduce Trident SerializerFactory and Kryo serializers
Some topologies use Trident-State to store intermediate data as POJOs which
are then transferred downstream to other functions or aggregators. It doesn't
matter how these POJOs are stored as long as it is efficient.
Storm uses a Kryo serializer to serialize the POJO when it is part of a
Tuple and requires #registerSerialization be called on the topology
configuration. This change enables the same Kryo serializer configuration to be
used in a Trident Serializer.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/upio/incubator-storm master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-storm/pull/208.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #208
----
commit a0ac90f999ed3f64730af7e9a19c5e460aa99d42
Author: Sam Goodwin <[email protected]>
Date: 2014-07-28T01:54:21Z
Introduce SerializerFactory so that Trident States can construct
Serialziers using the Storm config. Implement non, transactional and opaque
serialziers which use an internally configured Kryo instance.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
