org.apache.nifi.controller.repository

Class StandardProcessSession

java.lang.Object

org.apache.nifi.controller.repository.StandardProcessSession

All Implemented Interfaces:

ProvenanceEventEnricher, ProcessSession

public final class StandardProcessSession
extends java.lang.Object
implements ProcessSession, ProvenanceEventEnricher

Provides a ProcessSession that ensures all accesses, changes and transfers occur in an atomic manner for all FlowFiles including their contents and attributes

NOT THREAD SAFE

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_FLOWFILE_PATH
static int	VERBOSE_LOG_THRESHOLD

Constructor Summary

Constructors

Constructor and Description
StandardProcessSession(ProcessContext context)

Method Summary

Modifier and Type	Method and Description
void	adjustCounter(java.lang.String name, long delta, boolean immediate) Adjusts counter data for the given counter name and takes care of registering the counter if not already present.
FlowFile	append(FlowFile source, OutputStreamCallback writer) Executes the given callback against the content corresponding to the given FlowFile, such that any data written to the OutputStream of the content will be appended to the end of FlowFile.
void	checkpoint()
FlowFile	clone(FlowFile example) Creates a new FlowFile that is a clone of the given FlowFile as of the time this is called, both in content and attributes.
FlowFile	clone(FlowFile example, long offset, long size) Creates a new FlowFile whose parent is the given FlowFile.
void	commit() Commits the current session ensuring all operations against FlowFiles within this session are atomically persisted.
FlowFile	create() Creates a new FlowFile in the repository with no content and without any linkage to a parent FlowFile.
FlowFile	create(java.util.Collection<FlowFile> parents) Creates a new FlowFile in the repository with no content but with a parent linkage to the FlowFiles specified by the parents Collection.
FlowFile	create(FlowFile parent) Creates a new FlowFile in the repository with no content but with a parent linkage to parent.
StandardProvenanceEventRecord	enrich(ProvenanceEventRecord rawEvent, FlowFile flowFile) Returns a new Provenance event that has been updated to contain the original and updated FlowFile attributes and content claim information.
void	expireFlowFiles()
void	exportTo(FlowFile source, java.io.OutputStream destination) Writes the content of the given FlowFile to the given destination stream
void	exportTo(FlowFile source, java.nio.file.Path destination, boolean append) Writes the content of the given FlowFile to the given destination path.
protected void	finalize()
FlowFile	get()
java.util.List<FlowFile>	get(FlowFileFilter filter) Returns all FlowFiles from all of the incoming queues for which the given FlowFileFilter indicates should be accepted.
java.util.List<FlowFile>	get(int maxResults) Returns up to maxResults FlowFiles from the work queue.
ProvenanceReporter	getProvenanceReporter() Returns a ProvenanceReporter that is tied to this ProcessSession.
QueueSize	getQueueSize()
FlowFile	importFrom(java.io.InputStream source, FlowFile destination) Writes to the given FlowFile all content from the given content path.
FlowFile	importFrom(java.nio.file.Path source, boolean keepSourceFile, FlowFile destination) Writes to the given FlowFile all content from the given content path.
FlowFile	merge(java.util.Collection<FlowFile> sources, FlowFile destination) Combines the content of all given source FlowFiles into a single given destination FlowFile.
FlowFile	merge(java.util.Collection<FlowFile> sources, FlowFile destination, byte[] header, byte[] footer, byte[] demarcator) Combines the content of all given source FlowFiles into a single given destination FlowFile.
void	migrate(ProcessSession newOwner, java.util.Collection<FlowFile> flowFiles) Migrates ownership of the given FlowFiles from this to the given newOwner.
FlowFile	penalize(FlowFile flowFile) Sets a penalty for the given FlowFile which will make it unavailable to be operated on any further during the penalty period.
FlowFile	putAllAttributes(FlowFile flowFile, java.util.Map<java.lang.String,java.lang.String> attributes) Updates the given FlowFiles attributes with the given key/value pairs.
FlowFile	putAttribute(FlowFile flowFile, java.lang.String key, java.lang.String value) Updates the given FlowFiles attributes with the given key/value pair.
java.io.InputStream	read(FlowFile source) Provides an InputStream that can be used to read the contents of the given FlowFile.
void	read(FlowFile source, boolean allowSessionStreamManagement, InputStreamCallback reader) Executes the given callback against the contents corresponding to the given FlowFile.
void	read(FlowFile source, InputStreamCallback reader) Executes the given callback against the contents corresponding to the given FlowFile.
void	remove(java.util.Collection<FlowFile> flowFiles) Ends the managed persistence for the given FlowFiles.
void	remove(FlowFile flowFile) Ends the managed persistence for the given FlowFile.
FlowFile	removeAllAttributes(FlowFile flowFile, java.util.regex.Pattern keyPattern) Remove all attributes from the given FlowFile that have keys which match the given pattern.
FlowFile	removeAllAttributes(FlowFile flowFile, java.util.Set<java.lang.String> keys) Removes the attributes with the given keys from the given FlowFile.
FlowFile	removeAttribute(FlowFile flowFile, java.lang.String key) Removes the given FlowFile attribute with the given key.
void	rollback() Reverts any changes made during this session.
void	rollback(boolean penalize) Reverts any changes made during this session.
java.lang.String	toString()
void	transfer(java.util.Collection<FlowFile> flowFiles) Transfers the given FlowFiles back to the work queues from which the FlowFiles were pulled.
void	transfer(java.util.Collection<FlowFile> flowFiles, Relationship relationship) Transfers the given FlowFile to the appropriate destination processor work queue(s) based on the given relationship.
void	transfer(FlowFile flowFile) Transfers the given FlowFile back to the work queue from which it was pulled.
void	transfer(FlowFile flowFile, Relationship relationship) Transfers the given FlowFile to the appropriate destination processor work queue(s) based on the given relationship.
java.io.OutputStream	write(FlowFile source) Provides an OutputStream that can be used to write to the contents of the given FlowFile.
FlowFile	write(FlowFile source, OutputStreamCallback writer) Executes the given callback against the content corresponding to the given FlowFile.
FlowFile	write(FlowFile source, StreamCallback writer) Executes the given callback against the content corresponding to the given flow file.

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

VERBOSE_LOG_THRESHOLD

public static final int VERBOSE_LOG_THRESHOLD

See Also:

Constant Field Values

DEFAULT_FLOWFILE_PATH

public static final java.lang.String DEFAULT_FLOWFILE_PATH

See Also:

Constant Field Values

Constructor Detail

StandardProcessSession

public StandardProcessSession(ProcessContext context)

Method Detail

checkpoint

public void checkpoint()

commit

public void commit()

Description copied from interface: ProcessSession

Commits the current session ensuring all operations against FlowFiles within this session are atomically persisted. All FlowFiles operated on within this session must be accounted for by transfer or removal or the commit will fail.

As soon as the commit completes the session is again ready to be used

Specified by:

commit in interface ProcessSession

enrich

public StandardProvenanceEventRecord enrich(ProvenanceEventRecord rawEvent,
                                            FlowFile flowFile)

Description copied from interface: ProvenanceEventEnricher

Returns a new Provenance event that has been updated to contain the original and updated FlowFile attributes and content claim information.

Specified by:

enrich in interface ProvenanceEventEnricher

Parameters:

rawEvent - record

flowFile - flowfile

Returns:

new event record

rollback

public void rollback()

Description copied from interface: ProcessSession

Reverts any changes made during this session. All FlowFiles are restored back to their initial session state and back to their original queues. If this session is already committed or rolled back then no changes will occur. This method can be called any number of times. Calling this method is identical to calling ProcessSession.rollback(boolean) passing false as the parameter.

Specified by:

rollback in interface ProcessSession

rollback

public void rollback(boolean penalize)

Description copied from interface: ProcessSession

Reverts any changes made during this session. All FlowFiles are restored back to their initial session state and back to their original queues, after optionally being penalized. If this session is already committed or rolled back then no changes will occur. This method can be called any number of times.

Specified by:

rollback in interface ProcessSession

Parameters:

penalize - whether or not the FlowFiles that are being restored back to their queues should be penalized

migrate

public void migrate(ProcessSession newOwner,
                    java.util.Collection<FlowFile> flowFiles)

Description copied from interface: ProcessSession

Migrates ownership of the given FlowFiles from this to the given newOwner.

When calling this method, all of the following pre-conditions must be met:

• This method cannot be called from within a callback (see ProcessSession.write(FlowFile, OutputStreamCallback), ProcessSession.write(FlowFile, StreamCallback), ProcessSession.read(FlowFile, InputStreamCallback), ProcessSession.read(FlowFile, boolean, InputStreamCallback) for any of the given FlowFiles.
• No InputStream can be open for the content of any of the given FlowFiles (see ProcessSession.read(FlowFile)).
• No OutputStream can be open for the content of any of the given FlowFiles (see ProcessSession.write(FlowFile).
• For any provided FlowFile, if the FlowFile has any child (e.g., by calling ProcessSession.create(FlowFile) and passing the FlowFile as the argument), then all children that were created must also be in the Collection of provided FlowFiles.

Also note, that if any FlowFile given is not the most up-to-date version of that FlowFile, then the most up-to-date version of the FlowFile will be migrated to the new owner. For example, if a call to ProcessSession.putAttribute(FlowFile, String, String) is made, passing flowFile1 as the FlowFile, and then flowFile1 is passed to this method, then the newest version (including the newly added attribute) will be migrated, not the outdated version of the FlowFile that flowFile1 points to.

Specified by:

migrate in interface ProcessSession

Parameters:

newOwner - the ProcessSession that is to become the new owner of all FlowFiles that currently belong to this.

flowFiles - the FlowFiles to migrate

adjustCounter

public void adjustCounter(java.lang.String name,
                          long delta,
                          boolean immediate)

Description copied from interface: ProcessSession

Adjusts counter data for the given counter name and takes care of registering the counter if not already present. The adjustment occurs only if and when the ProcessSession is committed.

Specified by:

adjustCounter in interface ProcessSession

Parameters:

name - the name of the counter

delta - the delta by which to modify the counter (+ or -)

immediate - if true, the counter will be updated immediately, without regard to whether the ProcessSession is commit or rolled back; otherwise, the counter will be incremented only if and when the ProcessSession is committed.

get

public FlowFile get()

Specified by:

get in interface ProcessSession

Returns:

FlowFile that is next highest priority FlowFile to process. Otherwise returns null.

get

public java.util.List<FlowFile> get(int maxResults)

Description copied from interface: ProcessSession

Returns up to maxResults FlowFiles from the work queue. If no FlowFiles are available, returns an empty list. Will not return null. If multiple incoming queues are present, the behavior is unspecified in terms of whether all queues or only a single queue will be polled in a single call.

Specified by:

get in interface ProcessSession

Parameters:

maxResults - the maximum number of FlowFiles to return

Returns:

up to maxResults FlowFiles from the work queue. If no FlowFiles are available, returns an empty list. Will not return null.

get

public java.util.List<FlowFile> get(FlowFileFilter filter)

Description copied from interface: ProcessSession

Returns all FlowFiles from all of the incoming queues for which the given FlowFileFilter indicates should be accepted. Calls to this method provide exclusive access to the underlying queues. I.e., no other thread will be permitted to pull FlowFiles from this Processor's queues or add FlowFiles to this Processor's incoming queues until this method call has returned.

Specified by:

get in interface ProcessSession

Parameters:

filter - to limit which flow files are returned

Returns:

all FlowFiles from all of the incoming queues for which the given FlowFileFilter indicates should be accepted.

getQueueSize

public QueueSize getQueueSize()

Specified by:

getQueueSize in interface ProcessSession

Returns:

the QueueSize that represents the number of FlowFiles and their combined data size for all FlowFiles waiting to be processed by the Processor that owns this ProcessSession, regardless of which Connection the FlowFiles live on

create

public FlowFile create()

Description copied from interface: ProcessSession

Creates a new FlowFile in the repository with no content and without any linkage to a parent FlowFile. This method is appropriate only when data is received or created from an external system. Otherwise, this method should be avoided and should instead use ProcessSession.create(FlowFile) or ProcessSession.create(Collection). When this method is used, a Provenance CREATE or RECEIVE Event should be generated. See the ProcessSession.getProvenanceReporter() method and ProvenanceReporter class for more information

Specified by:

create in interface ProcessSession

Returns:

newly created FlowFile

clone

public FlowFile clone(FlowFile example)

Description copied from interface: ProcessSession

Creates a new FlowFile that is a clone of the given FlowFile as of the time this is called, both in content and attributes. This method automatically emits a Provenance CLONE Event.

Specified by:

clone in interface ProcessSession

Parameters:

example - FlowFile to be the source of cloning - given FlowFile must be a part of the given session

Returns:

FlowFile that is a clone of the given example

clone

public FlowFile clone(FlowFile example,
                      long offset,
                      long size)

Description copied from interface: ProcessSession

Creates a new FlowFile whose parent is the given FlowFile. The content of the new FlowFile will be a subset of the byte sequence of the given FlowFile starting at the specified offset and with the length specified. The new FlowFile will contain all of the attributes of the original. This method automatically emits a Provenance FORK Event (or a Provenance CLONE Event, if the offset is 0 and the size is exactly equal to the size of the example FlowFile).

Specified by:

clone in interface ProcessSession

Parameters:

example - to base the new flowfile attributes on

offset - of the parent flowfile to base the child flowfile content on

size - of the new flowfile from the offset

Returns:

a FlowFile with the specified size whose parent is first argument to this function

penalize

public FlowFile penalize(FlowFile flowFile)

Description copied from interface: ProcessSession

Sets a penalty for the given FlowFile which will make it unavailable to be operated on any further during the penalty period.

Specified by:

penalize in interface ProcessSession

Parameters:

flowFile - to penalize

Returns:

FlowFile the new FlowFile reference to use

putAttribute

public FlowFile putAttribute(FlowFile flowFile,
                             java.lang.String key,
                             java.lang.String value)

Description copied from interface: ProcessSession

Updates the given FlowFiles attributes with the given key/value pair. If the key is named uuid, this attribute will be ignored.

Specified by:

putAttribute in interface ProcessSession

Parameters:

flowFile - to update

key - of attribute

value - of attribute

Returns:

FlowFile the updated FlowFile

putAllAttributes

public FlowFile putAllAttributes(FlowFile flowFile,
                                 java.util.Map<java.lang.String,java.lang.String> attributes)

Description copied from interface: ProcessSession

Updates the given FlowFiles attributes with the given key/value pairs. If the map contains a key named uuid, this attribute will be ignored.

Specified by:

putAllAttributes in interface ProcessSession

Parameters:

flowFile - to update

attributes - the attributes to add to the given FlowFile

Returns:

FlowFile the updated FlowFile

removeAttribute

public FlowFile removeAttribute(FlowFile flowFile,
                                java.lang.String key)

Description copied from interface: ProcessSession

Removes the given FlowFile attribute with the given key. If the key is named uuid, this method will return the same FlowFile without removing any attribute.

Specified by:

removeAttribute in interface ProcessSession

Parameters:

flowFile - to update

key - of attribute

Returns:

FlowFile the updated FlowFile

removeAllAttributes

public FlowFile removeAllAttributes(FlowFile flowFile,
                                    java.util.Set<java.lang.String> keys)

Description copied from interface: ProcessSession

Removes the attributes with the given keys from the given FlowFile. If the set of keys contains the value uuid, this key will be ignored

Specified by:

removeAllAttributes in interface ProcessSession

Parameters:

flowFile - to update

keys - of attribute

Returns:

FlowFile the updated FlowFile

removeAllAttributes

public FlowFile removeAllAttributes(FlowFile flowFile,
                                    java.util.regex.Pattern keyPattern)

Description copied from interface: ProcessSession

Remove all attributes from the given FlowFile that have keys which match the given pattern. If the pattern matches the key uuid, this key will not be removed.

Specified by:

removeAllAttributes in interface ProcessSession

Parameters:

flowFile - to update

keyPattern - may be null; if supplied is matched against each of the FlowFile attribute keys

Returns:

FlowFile containing only attributes which did not meet the key pattern

transfer

public void transfer(FlowFile flowFile,
                     Relationship relationship)

Description copied from interface: ProcessSession

Transfers the given FlowFile to the appropriate destination processor work queue(s) based on the given relationship. If the relationship leads to more than one destination the state of the FlowFile is replicated such that each destination receives an exact copy of the FlowFile though each will have its own unique identity. The destination processors will not be able to operate on the given FlowFile until this session is committed or until the ownership of the session is migrated to another processor. If ownership of the session is passed to a destination processor then that destination processor will have immediate visibility of the transferred FlowFiles within the session.

Specified by:

transfer in interface ProcessSession

Parameters:

flowFile - to transfer

relationship - to transfer to

transfer

public void transfer(FlowFile flowFile)

Description copied from interface: ProcessSession

Transfers the given FlowFile back to the work queue from which it was pulled. The processor will not be able to operate on the given FlowFile until this session is committed. Any modifications that have been made to the FlowFile will be maintained. FlowFiles that are created by the processor cannot be transferred back to themselves via this method.

Specified by:

transfer in interface ProcessSession

Parameters:

flowFile - to transfer

transfer

public void transfer(java.util.Collection<FlowFile> flowFiles)

Description copied from interface: ProcessSession

Transfers the given FlowFiles back to the work queues from which the FlowFiles were pulled. The processor will not be able to operate on the given FlowFile until this session is committed. Any modifications that have been made to the FlowFile will be maintained. FlowFiles that are created by the processor cannot be transferred back to themselves via this method.

Specified by:

transfer in interface ProcessSession

Parameters:

flowFiles - to transfer

transfer

public void transfer(java.util.Collection<FlowFile> flowFiles,
                     Relationship relationship)

Description copied from interface: ProcessSession

Transfers the given FlowFile to the appropriate destination processor work queue(s) based on the given relationship. If the relationship leads to more than one destination the state of the FlowFile is replicated such that each destination receives an exact copy of the FlowFile though each will have its own unique identity. The destination processors will not be able to operate on the given FlowFile until this session is committed or until the ownership of the session is migrated to another processor. If ownership of the session is passed to a destination processor then that destination processor will have immediate visibility of the transferred FlowFiles within the session.

Specified by:

transfer in interface ProcessSession

Parameters:

flowFiles - to transfer

relationship - to transfer to

remove

public void remove(FlowFile flowFile)

Description copied from interface: ProcessSession

Ends the managed persistence for the given FlowFile. The persistent attributes for the FlowFile are deleted and so is the content assuming nothing else references it and this FlowFile will no longer be available for further operation.

Specified by:

remove in interface ProcessSession

Parameters:

flowFile - to remove

remove

public void remove(java.util.Collection<FlowFile> flowFiles)

Description copied from interface: ProcessSession

Ends the managed persistence for the given FlowFiles. The persistent attributes for the FlowFile are deleted and so is the content assuming nothing else references it and this FlowFile will no longer be available for further operation.

Specified by:

remove in interface ProcessSession

Parameters:

flowFiles - to remove

expireFlowFiles

public void expireFlowFiles()

read

public void read(FlowFile source,
                 InputStreamCallback reader)

Description copied from interface: ProcessSession

Executes the given callback against the contents corresponding to the given FlowFile.

Specified by:

read in interface ProcessSession

Parameters:

source - flowfile to retrieve content of

reader - that will be called to read the flowfile content

read

public void read(FlowFile source,
                 boolean allowSessionStreamManagement,
                 InputStreamCallback reader)

Description copied from interface: ProcessSession

Executes the given callback against the contents corresponding to the given FlowFile. Note: The OutputStream provided to the given OutputStreamCallback will not be accessible once this method has completed its execution.

Specified by:

read in interface ProcessSession

Parameters:

source - flowfile to retrieve content of

allowSessionStreamManagement - allow session to hold the stream open for performance reasons

reader - that will be called to read the flowfile content

read

public java.io.InputStream read(FlowFile source)

Description copied from interface: ProcessSession

Provides an InputStream that can be used to read the contents of the given FlowFile. This method differs from those that make use of callbacks in that this method returns an InputStream and expects the caller to properly handle the lifecycle of the InputStream (i.e., the caller is responsible for ensuring that the InputStream is closed appropriately). The Process Session may or may not handle closing the stream when ProcessSession.commit() or ProcessSession.rollback() is called, but the responsibility of doing so belongs to the caller. The InputStream will throw an IOException if an attempt is made to read from the stream after the session is committed or rolled back.

Specified by:

read in interface ProcessSession

Parameters:

source - the FlowFile to read

Returns:

an InputStream that can be used to read the contents of the FlowFile

merge

public FlowFile merge(java.util.Collection<FlowFile> sources,
                      FlowFile destination)

Description copied from interface: ProcessSession

Combines the content of all given source FlowFiles into a single given destination FlowFile.

Specified by:

merge in interface ProcessSession

Parameters:

sources - the flowfiles to merge

destination - the flowfile to use as the merged result

Returns:

updated destination FlowFile (new size, etc...)

merge

public FlowFile merge(java.util.Collection<FlowFile> sources,
                      FlowFile destination,
                      byte[] header,
                      byte[] footer,
                      byte[] demarcator)

Description copied from interface: ProcessSession

Combines the content of all given source FlowFiles into a single given destination FlowFile.

Specified by:

merge in interface ProcessSession

Parameters:

sources - to merge together

destination - to merge to

header - bytes that will be added to the beginning of the merged output. May be null or empty.

footer - bytes that will be added to the end of the merged output. May be null or empty.

demarcator - bytes that will be placed in between each object merged together. May be null or empty.

Returns:

updated destination FlowFile (new size, etc...)

write

public java.io.OutputStream write(FlowFile source)

Description copied from interface: ProcessSession

Provides an OutputStream that can be used to write to the contents of the given FlowFile.

Specified by:

write in interface ProcessSession

Parameters:

source - to write to

Returns:

an OutputStream that can be used to write to the contents of the FlowFile

write

public FlowFile write(FlowFile source,
                      OutputStreamCallback writer)

Description copied from interface: ProcessSession

Executes the given callback against the content corresponding to the given FlowFile. Note: The OutputStream provided to the given OutputStreamCallback will not be accessible once this method has completed its execution.

Specified by:

write in interface ProcessSession

Parameters:

source - to write to

writer - used to write new content

Returns:

updated FlowFile

append

public FlowFile append(FlowFile source,
                       OutputStreamCallback writer)

Description copied from interface: ProcessSession

Executes the given callback against the content corresponding to the given FlowFile, such that any data written to the OutputStream of the content will be appended to the end of FlowFile. Note: The OutputStream provided to the given OutputStreamCallback will not be accessible once this method has completed its execution.

Specified by:

append in interface ProcessSession

Parameters:

source - the flowfile for which content should be appended

writer - used to write new bytes to the flowfile content

Returns:

the updated flowfile reference for the new content

write

public FlowFile write(FlowFile source,
                      StreamCallback writer)

Description copied from interface: ProcessSession

Executes the given callback against the content corresponding to the given flow file. Note: The InputStream & OutputStream provided to the given StreamCallback will not be accessible once this method has completed its execution.

Specified by:

write in interface ProcessSession

Parameters:

source - to read from and write to

writer - used to read the old content and write new content

Returns:

updated FlowFile

importFrom

public FlowFile importFrom(java.nio.file.Path source,
                           boolean keepSourceFile,
                           FlowFile destination)

Description copied from interface: ProcessSession

Writes to the given FlowFile all content from the given content path.

Specified by:

importFrom in interface ProcessSession

Parameters:

source - the file from which content will be obtained

keepSourceFile - if true the content is simply copied; if false the original content might be used in a destructive way for efficiency such that the repository will have the data but the original data will be gone. If false the source object will be removed or gone once imported. It will not be restored if the session is rolled back so this must be used with caution. In some cases it can result in tremendous efficiency gains but is also dangerous.

destination - the FlowFile whose content will be updated

Returns:

the updated destination FlowFile (new size)

importFrom

public FlowFile importFrom(java.io.InputStream source,
                           FlowFile destination)

Description copied from interface: ProcessSession

Writes to the given FlowFile all content from the given content path.

Specified by:

importFrom in interface ProcessSession

Parameters:

source - the file from which content will be obtained

destination - the FlowFile whose content will be updated

Returns:

the updated destination FlowFile (new size)

exportTo

public void exportTo(FlowFile source,
                     java.nio.file.Path destination,
                     boolean append)

Description copied from interface: ProcessSession

Writes the content of the given FlowFile to the given destination path.

Specified by:

exportTo in interface ProcessSession

Parameters:

source - to export the content of

destination - to export the content to

append - if true will append to the current content at the given path; if false will replace any current content

exportTo

public void exportTo(FlowFile source,
                     java.io.OutputStream destination)

Description copied from interface: ProcessSession

Writes the content of the given FlowFile to the given destination stream

Specified by:

exportTo in interface ProcessSession

Parameters:

source - to export the content of

destination - to export the content to

create

public FlowFile create(FlowFile parent)

Description copied from interface: ProcessSession

Creates a new FlowFile in the repository with no content but with a parent linkage to parent. The newly created FlowFile will inherit all of the parent's attributes except for the UUID. This method will automatically generate a Provenance FORK event or a Provenance JOIN event, depending on whether or not other FlowFiles are generated from the same parent before the ProcessSession is committed.

Specified by:

create in interface ProcessSession

Parameters:

parent - to base the new flowfile on

Returns:

newly created flowfile

create

public FlowFile create(java.util.Collection<FlowFile> parents)

Description copied from interface: ProcessSession

Creates a new FlowFile in the repository with no content but with a parent linkage to the FlowFiles specified by the parents Collection. The newly created FlowFile will inherit all of the attributes that are in common to all parents (except for the UUID, which will be in common if only a single parent exists). This method will automatically generate a Provenance JOIN event.

Specified by:

create in interface ProcessSession

Parameters:

parents - which the new flowfile should inherit shared attributes from

Returns:

new flowfile

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

getProvenanceReporter

public ProvenanceReporter getProvenanceReporter()

Description copied from interface: ProcessSession

Returns a ProvenanceReporter that is tied to this ProcessSession.

Specified by:

getProvenanceReporter in interface ProcessSession

Returns:

the provenance reporter

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object