[
https://issues.apache.org/jira/browse/CASSANDRA-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13437753#comment-13437753
]
Piotr Kołaczkowski edited comment on CASSANDRA-4558 at 8/20/12 8:12 PM:
------------------------------------------------------------------------
I attach a patch enabling to set transport factory class in hadoop job
configuration. Added new properties "cassandra.input.transport.factory.class"
and "cassandra.output.transport.factory.class". TFramedTransportFactory is used
by default if properties are not set, so old behaviour is preserved. The
modified code has been tested using PIG demo in DSE.
Patch generated against 1.1 branch (1.1.4), intended for 1.1.
was (Author: pkolaczk):
I attach a patch enabling to set transport factory class in hadoop job
configuration. Added new properties "cassandra.input.transport.factory.class"
and "cassandra.output.transport.factory.class". TFramedTransportFactory is used
by default if properties are not set, so old behaviour is preserved. The
modified code has been tested using PIG demo in DSE.
> Configurable transport in CF RecordReader / RecordWriter
> --------------------------------------------------------
>
> Key: CASSANDRA-4558
> URL: https://issues.apache.org/jira/browse/CASSANDRA-4558
> Project: Cassandra
> Issue Type: New Feature
> Components: Hadoop
> Reporter: Piotr Kołaczkowski
> Attachments: configurable_transport.patch
>
>
> Currently RecordReaders and RecordWriters use hardcoded TFramedTransport. In
> order to use other transports, e.g. SSL transport, allow for setting custom
> transport class.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
