[ https://issues.apache.org/jira/browse/BAHIR-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15330676#comment-15330676 ]
Christian Kadner edited comment on BAHIR-8 at 6/14/16 9:42 PM: --------------------------------------------------------------- With my current approach, there is only one class per module which we need to keep in the o.a.s namespace in order to maintain back-ward compatibility: {noformat} streaming-akka/src/main/scala/org/apache/spark/streaming/akka/AkkaUtils.scala streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala streaming-zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala {noformat} But your suggestion requires less new code and avoids unnecessary complexity, so I am in favor of that. was (Author: ckadner): With my current approach, there is only one class per module which we need to keep in the o.a.s namespace in order to maintain back-ward compatibility: {noformat} streaming-akka/src/main/scala/org/apache/spark/streaming/akka/AkkaUtils.scala streaming-mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTUtils.scala streaming-twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterUtils.scala streaming-zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala {noformat} But there your suggestion requires less new code and avoids unnecessary complexity, so I am in favor of that. > Investigate weather we can use org.apache.bahir packages on Apache Spark > extensions > ----------------------------------------------------------------------------------- > > Key: BAHIR-8 > URL: https://issues.apache.org/jira/browse/BAHIR-8 > Project: Bahir > Issue Type: Task > Components: Spark Streaming Connectors > Affects Versions: 2.0.0 > Reporter: Luciano Resende > Assignee: Christian Kadner > > Experiment if we can move the current extensions to org.apache.bahir package. > We might see issues related to the private[spark], etc restriction that scala > imposes. -- This message was sent by Atlassian JIRA (v6.3.4#6332)