Package org.apache.nifi.processors.standard

Class LogMessage

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processor.AbstractProcessor

org.apache.nifi.processors.standard.LogMessage

All Implemented Interfaces:

org.apache.nifi.components.ConfigurableComponent, org.apache.nifi.processor.Processor

@SideEffectFree
@SupportsBatching(defaultDuration=TWENTY_FIVE_MILLIS)
@Tags({"attributes","logging"})
@InputRequirement(INPUT_REQUIRED)
@CapabilityDescription("Emits a log message at the specified log level")
public class LogMessage
extends org.apache.nifi.processor.AbstractProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	LogMessage.MessageLogLevel

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.nifi.components.PropertyDescriptor	LOG_LEVEL
static final org.apache.nifi.components.PropertyDescriptor	LOG_MESSAGE
static final org.apache.nifi.components.PropertyDescriptor	LOG_PREFIX
private static final List<org.apache.nifi.components.PropertyDescriptor>	PROPERTY_DESCRIPTORS
static final org.apache.nifi.processor.Relationship	REL_SUCCESS
private static final Set<org.apache.nifi.processor.Relationship>	RELATIONSHIPS

Constructor Summary

Constructors

Constructor	Description
LogMessage()

Method Summary

Modifier and Type	Method	Description
Set<org.apache.nifi.processor.Relationship>	getRelationships()
protected List<org.apache.nifi.components.PropertyDescriptor>	getSupportedPropertyDescriptors()
void	onTrigger(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session)
private void	processFlowFile(org.apache.nifi.logging.ComponentLog logger, LogMessage.MessageLogLevel logLevel, org.apache.nifi.flowfile.FlowFile flowFile, org.apache.nifi.processor.ProcessContext context)

Methods inherited from class org.apache.nifi.processor.AbstractProcessor

onTrigger

Methods inherited from class org.apache.nifi.processor.AbstractSessionFactoryProcessor

getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, init, initialize, isConfigurationRestored, isScheduled, toString, updateConfiguredRestoredTrue, updateScheduledFalse, updateScheduledTrue

Methods inherited from class org.apache.nifi.components.AbstractConfigurableComponent

customValidate, equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, hashCode, onPropertyModified, validate

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Methods inherited from interface org.apache.nifi.processor.Processor

isStateful, migrateProperties, migrateRelationships

Field Details

LOG_LEVEL

public static final org.apache.nifi.components.PropertyDescriptor LOG_LEVEL

LOG_PREFIX

public static final org.apache.nifi.components.PropertyDescriptor LOG_PREFIX

LOG_MESSAGE

public static final org.apache.nifi.components.PropertyDescriptor LOG_MESSAGE

PROPERTY_DESCRIPTORS

private static final List<org.apache.nifi.components.PropertyDescriptor> PROPERTY_DESCRIPTORS

REL_SUCCESS

public static final org.apache.nifi.processor.Relationship REL_SUCCESS

RELATIONSHIPS

private static final Set<org.apache.nifi.processor.Relationship> RELATIONSHIPS

Constructor Details

LogMessage

public LogMessage()

Method Details

getRelationships

public Set<org.apache.nifi.processor.Relationship> getRelationships()

Specified by:

getRelationships in interface org.apache.nifi.processor.Processor

Overrides:

getRelationships in class org.apache.nifi.processor.AbstractSessionFactoryProcessor

getSupportedPropertyDescriptors

protected List<org.apache.nifi.components.PropertyDescriptor> getSupportedPropertyDescriptors()

Overrides:

getSupportedPropertyDescriptors in class org.apache.nifi.components.AbstractConfigurableComponent

onTrigger

public void onTrigger(org.apache.nifi.processor.ProcessContext context,
 org.apache.nifi.processor.ProcessSession session)

Specified by:

onTrigger in class org.apache.nifi.processor.AbstractProcessor

processFlowFile

private void processFlowFile(org.apache.nifi.logging.ComponentLog logger,
 LogMessage.MessageLogLevel logLevel,
 org.apache.nifi.flowfile.FlowFile flowFile,
 org.apache.nifi.processor.ProcessContext context)