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

Interface RecordService

public interface RecordService
Helping class to build records.

  • Method Details

    • toObject

      <T> T toObject(Record data, Class<T> expected)
      Simple mapper of record to pojo.
      Type Parameters:
      T - the pojo type (optional).
      Parameters:
      data - record to map to pojo.
      expected - : class expected.
      Returns:
      a pojo representing the data record.

    • toRecord

      <T> Record toRecord(T data)
      Simple mapper of data to record.
      Type Parameters:
      T - the pojo type (optional).
      Parameters:
      data - pojo to map to record.
      Returns:
      a record representing the pojo.

    • 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.
      record - record to visit.
      Returns:
      the visitor value.