Package org.apache.nifi.util

Class MockProcessorInitializationContext

java.lang.Object

org.apache.nifi.util.MockProcessorInitializationContext

All Implemented Interfaces:

org.apache.nifi.controller.ControllerServiceLookup, org.apache.nifi.kerberos.KerberosContext, org.apache.nifi.processor.ProcessorInitializationContext

public class MockProcessorInitializationContext
extends Object
implements org.apache.nifi.processor.ProcessorInitializationContext, org.apache.nifi.controller.ControllerServiceLookup

Field Summary

Fields

Modifier and Type	Field	Description
private final MockProcessContext	context
private final org.apache.nifi.kerberos.KerberosContext	kerberosContext
private final MockComponentLog	logger
private final String	processorId

Constructor Summary

Constructors

Constructor	Description
MockProcessorInitializationContext(org.apache.nifi.processor.Processor processor, MockProcessContext context)
MockProcessorInitializationContext(org.apache.nifi.processor.Processor processor, MockProcessContext context, MockComponentLog logger)
MockProcessorInitializationContext(org.apache.nifi.processor.Processor processor, MockProcessContext context, MockComponentLog logger, org.apache.nifi.kerberos.KerberosContext kerberosContext)

Method Summary

Modifier and Type	Method	Description
org.apache.nifi.controller.ControllerService	getControllerService(String identifier)
Set<String>	getControllerServiceIdentifiers(Class<? extends org.apache.nifi.controller.ControllerService> serviceType)
org.apache.nifi.controller.ControllerServiceLookup	getControllerServiceLookup()
String	getControllerServiceName(String serviceIdentifier)
String	getIdentifier()
File	getKerberosConfigurationFile()
File	getKerberosServiceKeytab()
String	getKerberosServicePrincipal()
MockComponentLog	getLogger()
org.apache.nifi.controller.NodeTypeProvider	getNodeTypeProvider()
boolean	isControllerServiceEnabled(String serviceIdentifier)
boolean	isControllerServiceEnabled(org.apache.nifi.controller.ControllerService service)
boolean	isControllerServiceEnabling(String serviceIdentifier)

Methods inherited from class java.lang.Object

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

Field Details

logger

private final MockComponentLog logger

processorId

private final String processorId

context

private final MockProcessContext context

kerberosContext

private final org.apache.nifi.kerberos.KerberosContext kerberosContext

Constructor Details

MockProcessorInitializationContext

public MockProcessorInitializationContext(org.apache.nifi.processor.Processor processor,
 MockProcessContext context)

MockProcessorInitializationContext

public MockProcessorInitializationContext(org.apache.nifi.processor.Processor processor,
 MockProcessContext context,
 MockComponentLog logger)

MockProcessorInitializationContext

public MockProcessorInitializationContext(org.apache.nifi.processor.Processor processor,
 MockProcessContext context,
 MockComponentLog logger,
 org.apache.nifi.kerberos.KerberosContext kerberosContext)

Method Details

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in interface org.apache.nifi.processor.ProcessorInitializationContext

getLogger

public MockComponentLog getLogger()

Specified by:

getLogger in interface org.apache.nifi.processor.ProcessorInitializationContext

getControllerServiceIdentifiers

public Set<String> getControllerServiceIdentifiers(Class<? extends org.apache.nifi.controller.ControllerService> serviceType)

Specified by:

getControllerServiceIdentifiers in interface org.apache.nifi.controller.ControllerServiceLookup

getControllerService

public org.apache.nifi.controller.ControllerService getControllerService(String identifier)

Specified by:

getControllerService in interface org.apache.nifi.controller.ControllerServiceLookup

getControllerServiceLookup

public org.apache.nifi.controller.ControllerServiceLookup getControllerServiceLookup()

Specified by:

getControllerServiceLookup in interface org.apache.nifi.processor.ProcessorInitializationContext

getControllerServiceName

public String getControllerServiceName(String serviceIdentifier)

Specified by:

getControllerServiceName in interface org.apache.nifi.controller.ControllerServiceLookup

isControllerServiceEnabled

public boolean isControllerServiceEnabled(String serviceIdentifier)

Specified by:

isControllerServiceEnabled in interface org.apache.nifi.controller.ControllerServiceLookup

isControllerServiceEnabled

public boolean isControllerServiceEnabled(org.apache.nifi.controller.ControllerService service)

Specified by:

isControllerServiceEnabled in interface org.apache.nifi.controller.ControllerServiceLookup

isControllerServiceEnabling

public boolean isControllerServiceEnabling(String serviceIdentifier)

Specified by:

isControllerServiceEnabling in interface org.apache.nifi.controller.ControllerServiceLookup

getNodeTypeProvider

public org.apache.nifi.controller.NodeTypeProvider getNodeTypeProvider()

Specified by:

getNodeTypeProvider in interface org.apache.nifi.processor.ProcessorInitializationContext

getKerberosServicePrincipal

public String getKerberosServicePrincipal()

Specified by:

getKerberosServicePrincipal in interface org.apache.nifi.kerberos.KerberosContext

getKerberosServiceKeytab

public File getKerberosServiceKeytab()

Specified by:

getKerberosServiceKeytab in interface org.apache.nifi.kerberos.KerberosContext

getKerberosConfigurationFile

public File getKerberosConfigurationFile()

Specified by:

getKerberosConfigurationFile in interface org.apache.nifi.kerberos.KerberosContext