Package com.streamconverter.controller

Class CsvProcessingController

java.lang.Object

com.streamconverter.controller.AbstractStreamController

com.streamconverter.controller.CsvProcessingController

All Implemented Interfaces:

IStreamController

public class CsvProcessingController
extends AbstractStreamController

Controller for CSV data processing operations.

This controller demonstrates how to configure command pipelines for CSV processing. It provides several processing modes:

• Column extraction - Extract specific columns by name or index
• Row filtering - Filter rows based on criteria
• Data transformation - Transform CSV data with additional processing
• Validation - Validate CSV structure and content

Usage examples:

 // Extract specific column
 CsvProcessingController controller = CsvProcessingController.forColumnExtraction("name");
 controller.process(inputStream, outputStream);

 // Complex processing pipeline
 CsvProcessingController controller = CsvProcessingController.forComplexProcessing("data", "processor-id");
 controller.process(inputStream, outputStream);
 

Since:

1.0

Version:

1.0

Author:

StreamConverter Team

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	CsvProcessingController.ProcessingMode	Processing mode enumeration

Method Summary

Modifier and Type	Method	Description
protected CommandConfig[]	configureCommands()	Configures the command pipeline based on the processing mode.
static CsvProcessingController	forColumnExtraction(String columnSelector)	Factory method for creating a column extraction controller.
static CsvProcessingController	forComplexProcessing(String columnSelector, String processorId)	Factory method for creating a complex processing controller.
static CsvProcessingController	forPassThrough()	Factory method for creating a pass-through controller.
String	getColumnSelector()	Gets the column selector if applicable.
String	getConfigurationDescription()	Gets a description of the controller's current configuration.
String	getInputDataType()	Gets the expected input data type that this controller can handle.
String	getOutputDataType()	Gets the output data type that this controller produces.
CsvProcessingController.ProcessingMode	getProcessingMode()	Gets the processing mode of this controller.
String	getProcessorId()	Gets the processor ID if applicable.

Methods inherited from class com.streamconverter.controller.AbstractStreamController

getCommandConfigs, getStreamConverter, isConfigured, process, validateConfiguration

Methods inherited from class java.lang.Object

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

Method Details

forColumnExtraction

public static CsvProcessingController forColumnExtraction(String columnSelector)

Factory method for creating a column extraction controller.

Parameters:

columnSelector - column name or index to extract

Returns:

configured controller

forComplexProcessing

public static CsvProcessingController forComplexProcessing(String columnSelector,
 String processorId)

Factory method for creating a complex processing controller.

Parameters:

columnSelector - column name or index to extract

processorId - processor ID for additional processing

Returns:

configured controller

forPassThrough

public static CsvProcessingController forPassThrough()

Factory method for creating a pass-through controller.

Returns:

configured controller that processes CSV without extraction

configureCommands

protected CommandConfig[] configureCommands()

Configures the command pipeline based on the processing mode.

Specified by:

configureCommands in class AbstractStreamController

Returns:

array of command configurations

getInputDataType

public String getInputDataType()

Description copied from interface: IStreamController

Gets the expected input data type that this controller can handle.

This information can be used by external systems to route data to appropriate controllers.

Returns:

the expected input data type (e.g., "CSV", "JSON", "XML", "BINARY")

getOutputDataType

public String getOutputDataType()

Description copied from interface: IStreamController

Gets the output data type that this controller produces.

This information helps external systems understand what type of data to expect from the processing.

Returns:

the output data type (e.g., "CSV", "JSON", "XML", "BINARY")

getProcessingMode

public CsvProcessingController.ProcessingMode getProcessingMode()

Gets the processing mode of this controller.

Returns:

the processing mode

getColumnSelector

public String getColumnSelector()

Gets the column selector if applicable.

Returns:

the column selector, or null if not applicable

getProcessorId

public String getProcessorId()

Gets the processor ID if applicable.

Returns:

the processor ID, or null if not applicable

getConfigurationDescription

public String getConfigurationDescription()

Description copied from class: AbstractStreamController

Gets a description of the controller's current configuration.

Specified by:

getConfigurationDescription in interface IStreamController

Overrides:

getConfigurationDescription in class AbstractStreamController

Returns:

configuration description