DataImportProcessorFactory

Functional Interface:: This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface DataImportProcessorFactory

A factory used to create an appropriate DataImportProcessor given a wire value of DataImportFormat and context.

Field Summary

Fields

Modifier and Type Field Description

static DataImportProcessorFactory DEFAULT
The default factory, which supports binary and csv formats.

Method Summary

Modifier and Type	Method	Description
`DataImportProcessor`	`create(byte streamFormat, int rowBatchCapacity, int parallelism, DataImportStreamContext context, com.fishlib.io.logger.Logger log)`	Create a `DataImportProcessor` given the inputs.

Field Details
- DEFAULT
  
  static final DataImportProcessorFactory DEFAULT
  
  The default factory, which supports binary and csv formats.
Method Details
- create
  
  DataImportProcessor create(byte streamFormat, int rowBatchCapacity, int parallelism, DataImportStreamContext context, com.fishlib.io.logger.Logger log)
  
  Create a DataImportProcessor given the inputs.
  
  Parameters:
  
  streamFormat - The wire format of the stream.
  
  rowBatchCapacity - The row batch capacity, for batch-capable import processors
  
  parallelism - The parallelism, for batch-capable parallel import processors
  
  context - The context to pass down.
  
  log - A logger to pass down.
  
  Returns:
  
  A DataImportProcessor that will handle the stream format.