org.apache.drill.metastore.iceberg.transform

Class OutputDataTransformer<T>

java.lang.Object

org.apache.drill.metastore.iceberg.transform.OutputDataTransformer<T>

Type Parameters:

T - Metastore component unit type

Direct Known Subclasses:

TablesOutputDataTransformer

public abstract class OutputDataTransformer<T>
extends Object

Base class to convert list of Record into Metastore component units for the given list of column names.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OutputDataTransformer(Map<String,MethodHandle> unitSetters)

Method Summary

Modifier and Type	Method and Description
OutputDataTransformer<T>	columns(List<String> columns)
OutputDataTransformer<T>	columns(String... columns)
abstract List<T>	execute() Converts given list of Record into Metastore component units.
OutputDataTransformer<T>	records(List<org.apache.iceberg.data.Record> records)
protected List<Map<MethodHandle,Object>>	valuesToSet() For each given record prepares specific methods handler and its value to be set into Metastore specific component unit.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputDataTransformer

protected OutputDataTransformer(Map<String,MethodHandle> unitSetters)

Method Detail

columns

public OutputDataTransformer<T> columns(List<String> columns)

columns

public OutputDataTransformer<T> columns(String... columns)

records

public OutputDataTransformer<T> records(List<org.apache.iceberg.data.Record> records)

execute

public abstract List<T> execute()

Converts given list of Record into Metastore component units. Specific for each Metastore component.

Returns:

list of Metastore component units

valuesToSet

protected List<Map<MethodHandle,Object>> valuesToSet()

For each given record prepares specific methods handler and its value to be set into Metastore specific component unit. Ignores absent setters for columns and null values.

Returns:

list of methods handlers and values to set