[
https://issues.apache.org/jira/browse/NIFI-4105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067973#comment-16067973
]
ASF GitHub Bot commented on NIFI-4105:
--------------------------------------
Github user pvillard31 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/1937#discussion_r124735162
--- Diff:
nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/test/java/org/apache/nifi/processors/cassandra/QueryCassandraTest.java
---
@@ -361,6 +362,14 @@ public void testConvertToJSONStream() throws Exception
{
assertEquals(2, numberOfRows);
}
+ @Test
+ public void testConvertToCSVStream() throws Exception {
+ ResultSet rs = CassandraQueryTestUtil.createMockResultSet();
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
+ long numberOfRows = QueryCassandra.convertToCsvStream(rs, baos,
StandardCharsets.UTF_8, 0, null);
+ assertEquals(2, numberOfRows);
--- End diff --
Could you also check the output format and not only the number of rows?
> support the specified Maximum value column and CSV Stream for Cassandra
> -----------------------------------------------------------------------
>
> Key: NIFI-4105
> URL: https://issues.apache.org/jira/browse/NIFI-4105
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Extensions
> Affects Versions: 1.3.0
> Reporter: Yoonwon Ko
>
> I'm trying to find a CassandraProcessor to fetch rows whose values in the
> specified Maximum Value columns are larger than the previously-seen maximum
> like QueryDatabaseTable.
> But I found only QueryCassandra. It just executes same CQL everytime without
> keeping maximum value.
> and I think we also need convertToCsvStream option.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
