org.talend.sdk.component.api.service.record

Interface RecordService

public interface RecordService

Helping class to build records.

Method Summary

Modifier and Type	Method and Description
Record	create(Schema schema, Record fallbackRecord, BiFunction<Schema.Entry,Record.Builder,Boolean> customHandler, BiConsumer<Record.Builder,Boolean> beforeFinish) Shortcut to build a record using toRecord(Schema, Record, BiFunction, BiConsumer).
boolean	forwardEntry(Record source, Record.Builder builder, String sourceColumn, Schema.Entry entry) Forward an entry from the source record if it exists.
Collector<Schema.Entry,Record.Builder,Record>	toRecord(Schema schema, Record fallbackRecord, BiFunction<Schema.Entry,Record.Builder,Boolean> customHandler, BiConsumer<Record.Builder,Boolean> beforeFinish) Method providing a collector enabling to create a record from another one in a custom fashion.
<T> T	visit(RecordVisitor<T> visitor, Record record) Visit a record with a custom visitor.

Method Detail

forwardEntry

boolean forwardEntry(Record source,
                     Record.Builder builder,
                     String sourceColumn,
                     Schema.Entry entry)

Forward an entry from the source record if it exists.

Parameters:

source - the source record to read data from.

builder - the current builder to fill.

sourceColumn - the column name.

entry - the entry to use for the output column.

Returns:

true if the entry was forwarded.

toRecord

Collector<Schema.Entry,Record.Builder,Record> toRecord(Schema schema,
                                                       Record fallbackRecord,
                                                       BiFunction<Schema.Entry,Record.Builder,Boolean> customHandler,
                                                       BiConsumer<Record.Builder,Boolean> beforeFinish)

Method providing a collector enabling to create a record from another one in a custom fashion.

Parameters:

schema - the schema of the record being built.

fallbackRecord - the source record used when the custom handler does not handle current entry.

customHandler - a processor of entry enabling to inject custom data in the record being built.

beforeFinish - a callback before the record is actually built, it enables to add data if not already there.

Returns:

a collector enabling to build a record.

create

Record create(Schema schema,
              Record fallbackRecord,
              BiFunction<Schema.Entry,Record.Builder,Boolean> customHandler,
              BiConsumer<Record.Builder,Boolean> beforeFinish)

Shortcut to build a record using toRecord(Schema, Record, BiFunction, BiConsumer).

Parameters:

schema - the schema of the record being built.

fallbackRecord - the source record used when the custom handler does not handle current entry.

customHandler - a processor of entry enabling to inject custom data in the record being built.

beforeFinish - a callback before the record is actually built, it enables to add data if not already there.

Returns:

a collector enabling to build a record.

visit

<T> T visit(RecordVisitor<T> visitor,
            Record record)

Visit a record with a custom visitor.

Type Parameters:

T - the visitor returned type.

Parameters:

visitor - the visitor to use to browse the record.

Returns:

the visitor value.