org.apache.nifi.controller.serialization

Class StandardFlowSerializer

java.lang.Object

org.apache.nifi.controller.serialization.StandardFlowSerializer

All Implemented Interfaces:

FlowSerializer

public class StandardFlowSerializer
extends java.lang.Object
implements FlowSerializer

Serializes a Flow Controller as XML to an output stream. NOT THREAD-SAFE.

Field Summary

Fields inherited from interface org.apache.nifi.controller.serialization.FlowSerializer

ENC_PREFIX, ENC_SUFFIX

Constructor Summary

Constructors

Constructor and Description
StandardFlowSerializer(StringEncryptor encryptor)

Method Summary

Modifier and Type	Method and Description
void	addControllerService(org.w3c.dom.Element element, ControllerServiceNode serviceNode)
static void	addReportingTask(org.w3c.dom.Element element, ReportingTaskNode taskNode, StringEncryptor encryptor)
static void	addTemplate(org.w3c.dom.Element element, Template template)
void	serialize(FlowController controller, java.io.OutputStream os, ScheduledStateLookup scheduledStateLookup) Serializes the flow configuration of a controller instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardFlowSerializer

public StandardFlowSerializer(StringEncryptor encryptor)

Method Detail

serialize

public void serialize(FlowController controller,
                      java.io.OutputStream os,
                      ScheduledStateLookup scheduledStateLookup)
               throws FlowSerializationException

Description copied from interface: FlowSerializer

Serializes the flow configuration of a controller instance.

Specified by:

serialize in interface FlowSerializer

Parameters:

controller - a controller

os - an output stream to write the configuration to

scheduledStateLookup - a lookup that can be used to determine the ScheduledState of a Processor

Throws:

FlowSerializationException - if serialization failed

addControllerService

public void addControllerService(org.w3c.dom.Element element,
                                 ControllerServiceNode serviceNode)

addReportingTask

public static void addReportingTask(org.w3c.dom.Element element,
                                    ReportingTaskNode taskNode,
                                    StringEncryptor encryptor)

addTemplate

public static void addTemplate(org.w3c.dom.Element element,
                               Template template)