Uses of Class
org.apache.nifi.util.MockFlowFile

Packages that use MockFlowFile

Package	Description
org.apache.nifi.util

Uses of MockFlowFile in org.apache.nifi.util

Fields in org.apache.nifi.util with type parameters of type MockFlowFile

Modifier and Type	Field	Description
private final Map<Long,MockFlowFile>	MockProcessSession.currentVersions
private final Map<Long,MockFlowFile>	MockProcessSession.originalVersions
private final List<MockFlowFile>	MockProcessSession.penalized
private final BlockingQueue<MockFlowFile>	MockFlowFileQueue.queue
private final Map<org.apache.nifi.processor.Relationship,List<MockFlowFile>>	MockProcessSession.transferMap

Methods in org.apache.nifi.util that return MockFlowFile

Modifier and Type	Method	Description
MockFlowFile	MockProcessSession.clone(org.apache.nifi.flowfile.FlowFile flowFile)
MockFlowFile	MockProcessSession.clone(org.apache.nifi.flowfile.FlowFile flowFile, long offset, long size)
MockFlowFile	MockProcessSession.create()
MockFlowFile	MockProcessSession.create(Collection<org.apache.nifi.flowfile.FlowFile> flowFiles)
MockFlowFile	MockProcessSession.create(org.apache.nifi.flowfile.FlowFile flowFile)
MockFlowFile	MockProcessSession.createFlowFile(byte[] data)
MockFlowFile	MockProcessSession.createFlowFile(byte[] data, Map<String,String> attrs)
MockFlowFile	MockProcessSession.createFlowFile(File file)
MockFlowFile	StandardProcessorTestRunner.enqueue(byte[] data)
MockFlowFile	StandardProcessorTestRunner.enqueue(byte[] data, Map<String,String> attributes)
MockFlowFile	StandardProcessorTestRunner.enqueue(InputStream data)
MockFlowFile	StandardProcessorTestRunner.enqueue(InputStream data, Map<String,String> attributes)
MockFlowFile	StandardProcessorTestRunner.enqueue(String data)
MockFlowFile	StandardProcessorTestRunner.enqueue(String data, Map<String,String> attributes)
MockFlowFile	StandardProcessorTestRunner.enqueue(Path path)
MockFlowFile	StandardProcessorTestRunner.enqueue(Path path, Map<String,String> attributes)
MockFlowFile	TestRunner.enqueue(byte[] data)	Copies the content from the given byte array into memory and creates a FlowFile from this content with no attributes and adds this FlowFile to the Processor's Input Queue
MockFlowFile	TestRunner.enqueue(byte[] data, Map<String,String> attributes)	Copies the content from the given byte array into memory and creates a FlowFile from this content with the given attributes and adds this FlowFile to the Processor's Input Queue
MockFlowFile	TestRunner.enqueue(InputStream data)	Reads the content from the given InputStream into memory and creates a FlowFile from this content with no attributes and adds this FlowFile to the Processor's Input Queue
MockFlowFile	TestRunner.enqueue(InputStream data, Map<String,String> attributes)	Reads the content from the given InputStream into memory and creates a FlowFile from this content with the given attributes and adds this FlowFile to the Processor's Input Queue
MockFlowFile	TestRunner.enqueue(String data)	Creates a FlowFile with the content set to the given string (in UTF-8 format), with no attributes, and adds this FlowFile to the Processor's Input Queue
MockFlowFile	TestRunner.enqueue(String data, Map<String,String> attributes)	Creates a FlowFile with the content set to the given string (in UTF-8 format), with the given attributes, and adds this FlowFile to the Processor's Input Queue
MockFlowFile	TestRunner.enqueue(Path path)	Reads the content from the given Path into memory and creates a FlowFile from this content with no attributes and adds this FlowFile to the Processor's Input Queue
MockFlowFile	TestRunner.enqueue(Path path, Map<String,String> attributes)	Reads the content from the given Path into memory and creates a FlowFile from this content with the given attributes and adds this FlowFile to the Processor's Input Queue
MockFlowFile	MockProcessSession.get()
MockFlowFile	MockProcessSession.importFrom(InputStream in, org.apache.nifi.flowfile.FlowFile flowFile)
MockFlowFile	MockProcessSession.importFrom(Path path, boolean keepSourceFile, org.apache.nifi.flowfile.FlowFile flowFile)
MockFlowFile	MockProcessSession.merge(Collection<org.apache.nifi.flowfile.FlowFile> sources, org.apache.nifi.flowfile.FlowFile destination)
MockFlowFile	MockProcessSession.merge(Collection<org.apache.nifi.flowfile.FlowFile> sources, org.apache.nifi.flowfile.FlowFile destination, byte[] header, byte[] footer, byte[] demarcator)
MockFlowFile	MockProcessSession.penalize(org.apache.nifi.flowfile.FlowFile flowFile)
MockFlowFile	MockFlowFileQueue.poll()
MockFlowFile	MockProcessSession.putAllAttributes(org.apache.nifi.flowfile.FlowFile flowFile, Map<String,String> attrs)
MockFlowFile	MockProcessSession.putAttribute(org.apache.nifi.flowfile.FlowFile flowFile, String attrName, String attrValue)
MockFlowFile	MockProcessSession.removeAllAttributes(org.apache.nifi.flowfile.FlowFile flowFile, Pattern keyPattern)
MockFlowFile	MockProcessSession.removeAllAttributes(org.apache.nifi.flowfile.FlowFile flowFile, Set<String> attrNames)
MockFlowFile	MockProcessSession.removeAttribute(org.apache.nifi.flowfile.FlowFile flowFile, String attrName)
MockFlowFile	MockProcessSession.unpenalize(org.apache.nifi.flowfile.FlowFile flowFile)
private MockFlowFile	MockProcessSession.validateState(org.apache.nifi.flowfile.FlowFile flowFile)
MockFlowFile	MockProcessSession.write(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.io.OutputStreamCallback callback)
MockFlowFile	MockProcessSession.write(org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.io.StreamCallback callback)

Methods in org.apache.nifi.util that return types with arguments of type MockFlowFile

Modifier and Type	Method	Description
List<MockFlowFile>	MockProcessSession.getFlowFilesForRelationship(String relationship)
List<MockFlowFile>	MockProcessSession.getFlowFilesForRelationship(org.apache.nifi.processor.Relationship relationship)
List<MockFlowFile>	StandardProcessorTestRunner.getFlowFilesForRelationship(String relationship)
List<MockFlowFile>	StandardProcessorTestRunner.getFlowFilesForRelationship(org.apache.nifi.processor.Relationship relationship)
List<MockFlowFile>	TestRunner.getFlowFilesForRelationship(String relationship)	Returns a List of FlowFiles in the order in which they were transferred to the given relationship
List<MockFlowFile>	TestRunner.getFlowFilesForRelationship(org.apache.nifi.processor.Relationship relationship)	Returns a List of FlowFiles in the order in which they were transferred to the given relationship
List<MockFlowFile>	MockProcessSession.getPenalizedFlowFiles()
List<MockFlowFile>	StandardProcessorTestRunner.getPenalizedFlowFiles()
List<MockFlowFile>	TestRunner.getPenalizedFlowFiles()	Returns a List of FlowFiles in the order in which they were transferred that were penalized

Methods in org.apache.nifi.util with parameters of type MockFlowFile

Modifier and Type	Method	Description
byte[]	MockProcessSession.getContentAsByteArray(MockFlowFile flowFile)
byte[]	StandardProcessorTestRunner.getContentAsByteArray(MockFlowFile flowFile)
byte[]	TestRunner.getContentAsByteArray(MockFlowFile flowFile)	Copies the contents of the given MockFlowFile into a byte array and returns that byte array.
void	MockFlowFileQueue.offer(MockFlowFile flowFile)
private void	MockProcessSession.updateLastQueuedDate(MockFlowFile mockFlowFile)
private void	MockProcessSession.updateStateWithNewFlowFile(MockFlowFile newFlowFile)

Method parameters in org.apache.nifi.util with type arguments of type MockFlowFile

Modifier and Type	Method	Description
void	MockFlowFileQueue.addAll(Collection<MockFlowFile> flowFiles)
void	StandardProcessorTestRunner.assertAllConditionsMet(String relationshipName, Predicate<MockFlowFile> predicate)	Asserts that all FlowFiles meet all conditions.
void	StandardProcessorTestRunner.assertAllConditionsMet(org.apache.nifi.processor.Relationship relationship, Predicate<MockFlowFile> predicate)	Asserts that all FlowFiles meet all conditions.
void	TestRunner.assertAllConditionsMet(String relationshipName, Predicate<MockFlowFile> predicate)	Asserts that all FlowFiles meet all conditions.
void	TestRunner.assertAllConditionsMet(org.apache.nifi.processor.Relationship relationship, Predicate<MockFlowFile> predicate)	Asserts that all FlowFiles meet all conditions.
private void	MockProcessSession.migrate(MockProcessSession newOwner, Collection<MockFlowFile> flowFiles)