org.apache.nifi.cluster.protocol

Class StandardDataFlow

java.lang.Object

org.apache.nifi.cluster.protocol.StandardDataFlow

All Implemented Interfaces:

java.io.Serializable, DataFlow

public class StandardDataFlow
extends java.lang.Object
implements java.io.Serializable, DataFlow

Represents a dataflow, which includes the raw bytes of the flow.xml and whether processors should be started automatically at application startup.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StandardDataFlow(byte[] flow, byte[] snippetBytes, byte[] authorizerFingerprint, java.util.Set<java.lang.String> missingComponentIds) Constructs an instance.
StandardDataFlow(DataFlow toCopy)

Method Summary

Modifier and Type	Method and Description
byte[]	getAuthorizerFingerprint()
byte[]	getFlow()
java.util.Set<java.lang.String>	getMissingComponents()
byte[]	getSnippets()

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardDataFlow

public StandardDataFlow(byte[] flow,
                        byte[] snippetBytes,
                        byte[] authorizerFingerprint,
                        java.util.Set<java.lang.String> missingComponentIds)

Constructs an instance.

Parameters:

flow - a valid flow as bytes, which cannot be null

snippetBytes - an XML representation of snippets. May be null.

authorizerFingerprint - the bytes of the Authorizer's fingerprint. May be null when using an external Authorizer.

missingComponentIds - the ids of components that were created as missing ghost components

Throws:

java.lang.NullPointerException - if flow is null

StandardDataFlow

public StandardDataFlow(DataFlow toCopy)

Method Detail

getFlow

public byte[] getFlow()

Specified by:

getFlow in interface DataFlow

Returns:

the raw byte array of the flow

getSnippets

public byte[] getSnippets()

Specified by:

getSnippets in interface DataFlow

Returns:

the raw byte array of the snippets

getAuthorizerFingerprint

public byte[] getAuthorizerFingerprint()

Specified by:

getAuthorizerFingerprint in interface DataFlow

Returns:

the raw byte array of the Authorizer's fingerprint, null when not using a ManagedAuthorizer

getMissingComponents

public java.util.Set<java.lang.String> getMissingComponents()

Specified by:

getMissingComponents in interface DataFlow

Returns:

the component ids of components that were created as a missing ghost component