Package org.apache.nifi.schema.inference

Class SchemaInferenceUtil

java.lang.Object

org.apache.nifi.schema.inference.SchemaInferenceUtil

public class SchemaInferenceUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.nifi.components.AllowableValue	INFER_SCHEMA
static final org.apache.nifi.components.PropertyDescriptor	SCHEMA_CACHE

Constructor Summary

Constructors

Constructor	Description
SchemaInferenceUtil()

Method Summary

Modifier and Type	Method	Description
static <T> SchemaAccessStrategy	getSchemaAccessStrategy(String strategy, org.apache.nifi.context.PropertyContext context, org.apache.nifi.logging.ComponentLog logger, RecordSourceFactory<T> recordSourceFactory, Supplier<SchemaInferenceEngine<T>> inferenceSupplier, Supplier<SchemaAccessStrategy> defaultSupplier)

Methods inherited from class java.lang.Object

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

Field Details

INFER_SCHEMA

public static final org.apache.nifi.components.AllowableValue INFER_SCHEMA

SCHEMA_CACHE

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

Constructor Details

SchemaInferenceUtil

public SchemaInferenceUtil()

Method Details

getSchemaAccessStrategy

public static <T> SchemaAccessStrategy getSchemaAccessStrategy(String strategy,
 org.apache.nifi.context.PropertyContext context,
 org.apache.nifi.logging.ComponentLog logger,
 RecordSourceFactory<T> recordSourceFactory,
 Supplier<SchemaInferenceEngine<T>> inferenceSupplier,
 Supplier<SchemaAccessStrategy> defaultSupplier)