org.apache.nifi.processors.iceberg

Class AbstractIcebergProcessor

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processor.AbstractProcessor

org.apache.nifi.processors.iceberg.AbstractIcebergProcessor

All Implemented Interfaces:

ClassloaderIsolationKeyProvider, ConfigurableComponent, Processor

@RequiresInstanceClassLoading(cloneAncestorResources=true)
public abstract class AbstractIcebergProcessor
extends AbstractProcessor
implements ClassloaderIsolationKeyProvider

Base Iceberg processor class.

Field Summary

Fields

Modifier and Type	Field and Description
static PropertyDescriptor	CATALOG
static PropertyDescriptor	KERBEROS_USER_SERVICE
protected static AtomicReference<KerberosUser>	kerberosUserReference
static Relationship	REL_FAILURE
protected AtomicReference<org.apache.hadoop.security.UserGroupInformation>	ugiReference

Constructor Summary

Constructors

Constructor and Description
AbstractIcebergProcessor()

Method Summary

Modifier and Type	Method and Description
protected abstract void	doOnTrigger(ProcessContext context, ProcessSession session, FlowFile flowFile)
String	getClassloaderIsolationKey(PropertyContext context)
private org.apache.hadoop.security.UserGroupInformation	getUgi()
protected boolean	handleAuthErrors(Throwable t, ProcessSession session, ProcessContext context)
protected void	initKerberosCredentials(ProcessContext context)
void	onScheduled(ProcessContext context)
void	onTrigger(ProcessContext context, ProcessSession session)

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

onTrigger

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

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

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

customValidate, equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, getSupportedPropertyDescriptors, 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.processor.Processor

isStateful

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

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Field Detail

CATALOG

public static final PropertyDescriptor CATALOG

KERBEROS_USER_SERVICE

public static final PropertyDescriptor KERBEROS_USER_SERVICE

REL_FAILURE

public static final Relationship REL_FAILURE

kerberosUserReference

protected static final AtomicReference<KerberosUser> kerberosUserReference

ugiReference

protected final AtomicReference<org.apache.hadoop.security.UserGroupInformation> ugiReference

Constructor Detail

AbstractIcebergProcessor

public AbstractIcebergProcessor()

Method Detail

onScheduled

@OnScheduled
public void onScheduled(ProcessContext context)

initKerberosCredentials

protected void initKerberosCredentials(ProcessContext context)

onTrigger

public void onTrigger(ProcessContext context,
                      ProcessSession session)
               throws ProcessException

Specified by:

onTrigger in class AbstractProcessor

Throws:

ProcessException

getClassloaderIsolationKey

public String getClassloaderIsolationKey(PropertyContext context)

Specified by:

getClassloaderIsolationKey in interface ClassloaderIsolationKeyProvider

getUgi

private org.apache.hadoop.security.UserGroupInformation getUgi()

handleAuthErrors

protected boolean handleAuthErrors(Throwable t,
                                   ProcessSession session,
                                   ProcessContext context)

doOnTrigger

protected abstract void doOnTrigger(ProcessContext context,
                                    ProcessSession session,
                                    FlowFile flowFile)
                             throws ProcessException

Throws:

ProcessException