Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-17 23:47:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-1272: Added unit test to verify behavior

Browse Source
This commit is contained in:
Mark Payne 2015-12-18 11:51:42 -05:00
parent fa4c5314ca
commit 9ca0f95d06
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/repository/TestStandardProcessSession.java
View File

@ -1105,6 +1105,20 @@ public class TestStandardProcessSession {
assertEquals(ProvenanceEventType.CONTENT_MODIFIED, event.getEventType()); assertEquals(ProvenanceEventType.CONTENT_MODIFIED, event.getEventType());
} }
@Test
public void testGetWithCount() {
for (int i = 0; i < 8; i++) {
final FlowFileRecord flowFile = new StandardFlowFileRecord.Builder()
.id(i)
.addAttribute("uuid", "000000000000-0000-0000-0000-0000000" + i)
.build();
this.flowFileQueue.put(flowFile);
}
final List<FlowFile> flowFiles = session.get(7);
assertEquals(7, flowFiles.size());
}
@Test @Test
public void testAttributesModifiedEmitted() throws IOException { public void testAttributesModifiedEmitted() throws IOException {
final FlowFileRecord flowFile = new StandardFlowFileRecord.Builder() final FlowFileRecord flowFile = new StandardFlowFileRecord.Builder()