Package org.apache.nifi.util

Class MockProcessSession.Builder

java.lang.Object

org.apache.nifi.util.MockProcessSession.Builder

Enclosing class:

MockProcessSession

public static final class MockProcessSession.Builder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	allowRecursiveReads
private boolean	allowSynchronousCommits
private boolean	enforceStreamsClosed
private boolean	failCommit
private final org.apache.nifi.processor.Processor	processor
private final SharedSessionState	sharedState
private org.apache.nifi.components.state.StateManager	stateManager

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Builder(SharedSessionState sharedState, org.apache.nifi.processor.Processor processor)

Method Summary

Modifier and Type	Method	Description
MockProcessSession.Builder	allowRecursiveReads(boolean allowRecursiveReads)
MockProcessSession.Builder	allowSynchronousCommits()
MockProcessSession.Builder	allowSynchronousCommits(boolean allowSynchronousCommits)
MockProcessSession	build()
MockProcessSession.Builder	enforceStreamsClosed(boolean enforceStreamsClosed)
MockProcessSession.Builder	failCommit()
MockProcessSession.Builder	failCommit(boolean failCommit)
MockProcessSession.Builder	stateManager(org.apache.nifi.components.state.StateManager stateManager)

Methods inherited from class java.lang.Object

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

Field Details

sharedState

private final SharedSessionState sharedState

processor

private final org.apache.nifi.processor.Processor processor

stateManager

private org.apache.nifi.components.state.StateManager stateManager

enforceStreamsClosed

private boolean enforceStreamsClosed

allowRecursiveReads

private boolean allowRecursiveReads

allowSynchronousCommits

private boolean allowSynchronousCommits

failCommit

private boolean failCommit

Constructor Details

Builder

private Builder(SharedSessionState sharedState,
 org.apache.nifi.processor.Processor processor)

Method Details

stateManager

public MockProcessSession.Builder stateManager(org.apache.nifi.components.state.StateManager stateManager)

enforceStreamsClosed

public MockProcessSession.Builder enforceStreamsClosed(boolean enforceStreamsClosed)

allowSynchronousCommits

public MockProcessSession.Builder allowSynchronousCommits()

allowSynchronousCommits

public MockProcessSession.Builder allowSynchronousCommits(boolean allowSynchronousCommits)

allowRecursiveReads

public MockProcessSession.Builder allowRecursiveReads(boolean allowRecursiveReads)

failCommit

public MockProcessSession.Builder failCommit()

failCommit

public MockProcessSession.Builder failCommit(boolean failCommit)

build

public MockProcessSession build()