[ https://issues.apache.org/jira/browse/APEXMALHAR-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300206#comment-15300206 ]
ASF GitHub Bot commented on APEXMALHAR-2087: -------------------------------------------- Github user tweise commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/289#discussion_r64593672 --- Diff: contrib/src/main/java/com/datatorrent/contrib/hive/FSPojoToHiveOperator.java --- @@ -40,14 +43,14 @@ * @tags fs, hive, database * @since 3.0.0 */ -public class FSPojoToHiveOperator extends AbstractFSRollingOutputOperator<Object> +public class FSPojoToHiveOperator<T> extends AbstractFSRollingOutputOperator<T> --- End diff -- What's the purpose of the type parameter? > Hive output module > ------------------ > > Key: APEXMALHAR-2087 > URL: https://issues.apache.org/jira/browse/APEXMALHAR-2087 > Project: Apache Apex Malhar > Issue Type: Improvement > Reporter: Yogi Devendra > Assignee: Yogi Devendra > > Currently, applications which needs to write to Hive have to include 2 > operators FSPojoToHiveOperator, HiveOperator from malhar-contrib in the > application DAG. [First operator writes to HDFS; second operator loads files > from HDFS to hive]. > Proposal: to wrap these two operators into a Module/CompositeOperator. So > that, end user can directly include this module into application. -- This message was sent by Atlassian JIRA (v6.3.4#6332)