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

Interface Record.Builder

Enclosing interface:

Record

public static interface Record.Builder

Allows to create a record with a fluent API. This is the unique recommended way to create a record.

Method Summary

Modifier and Type	Method	Description
default Record.Builder	after(String entryName)	Mark that next entry created withXXXX() will be after entryName in schema order.
default Record.Builder	before(String entryName)	Mark that next entry created withXXXX() will be before entryName in schema order.
Record	build()
List<Schema.Entry>	getCurrentEntries()
default Schema.Entry	getEntry(String name)
Object	getValue(String name)
Record.Builder	removeEntry(Schema.Entry schemaEntry)
Record.Builder	updateEntryByName(String name, Schema.Entry schemaEntry)
default Record.Builder	updateEntryByName(String name, Schema.Entry schemaEntry, Function<Object,Object> valueCastFunction)
Record.Builder	with(Schema.Entry entry, Object value)
<T> Record.Builder	withArray(Schema.Entry entry, Collection<T> values)
Record.Builder	withBoolean(String name, boolean value)
Record.Builder	withBoolean(Schema.Entry entry, boolean value)
Record.Builder	withBytes(String name, byte[] value)
Record.Builder	withBytes(Schema.Entry entry, byte[] value)
Record.Builder	withDateTime(String name, ZonedDateTime value)
Record.Builder	withDateTime(String name, Date value)
Record.Builder	withDateTime(Schema.Entry entry, ZonedDateTime value)
Record.Builder	withDateTime(Schema.Entry entry, Date value)
default Record.Builder	withDecimal(String name, BigDecimal value)
default Record.Builder	withDecimal(Schema.Entry entry, BigDecimal value)
Record.Builder	withDouble(String name, double value)
Record.Builder	withDouble(Schema.Entry entry, double value)
Record.Builder	withFloat(String name, float value)
Record.Builder	withFloat(Schema.Entry entry, float value)
default Record.Builder	withInstant(String name, Instant value)
default Record.Builder	withInstant(Schema.Entry entry, Instant value)
Record.Builder	withInt(String name, int value)
Record.Builder	withInt(Schema.Entry entry, int value)
Record.Builder	withLong(String name, long value)
Record.Builder	withLong(Schema.Entry entry, long value)
Record.Builder	withRecord(String name, Record value)
Record.Builder	withRecord(Schema.Entry entry, Record value)
Record.Builder	withString(String name, String value)
Record.Builder	withString(Schema.Entry entry, String value)
Record.Builder	withTimestamp(String name, long value)
Record.Builder	withTimestamp(Schema.Entry entry, long value)

Method Details

build

Record build()

getValue

Object getValue(String name)

getCurrentEntries

List<Schema.Entry> getCurrentEntries()

getEntry

default Schema.Entry getEntry(String name)

before

default Record.Builder before(String entryName)

Mark that next entry created withXXXX() will be before entryName in schema order.

Parameters:

entryName - target entry name. This entry must exist!

Returns:

this Builder

See Also:

• • Schema#naturalOrder()
  • Schema#getEntriesOrdered()
  • Schema#getEntriesOrdered(Comparator)

after

default Record.Builder after(String entryName)

Mark that next entry created withXXXX() will be after entryName in schema order.

Parameters:

entryName - target entry name. This entry must exist!

Returns:

this Builder

See Also:

• • Schema#naturalOrder()
  • Schema#getEntriesOrdered()
  • Schema#getEntriesOrdered(Comparator)

removeEntry

Record.Builder removeEntry(Schema.Entry schemaEntry)

updateEntryByName

Record.Builder updateEntryByName(String name,
 Schema.Entry schemaEntry)

updateEntryByName

default Record.Builder updateEntryByName(String name,
 Schema.Entry schemaEntry,
 Function<Object,Object> valueCastFunction)

with

Record.Builder with(Schema.Entry entry,
 Object value)

withString

Record.Builder withString(String name,
 String value)

withString

Record.Builder withString(Schema.Entry entry,
 String value)

withBytes

Record.Builder withBytes(String name,
 byte[] value)

withBytes

Record.Builder withBytes(Schema.Entry entry,
 byte[] value)

withDateTime

Record.Builder withDateTime(String name,
 Date value)

withDateTime

Record.Builder withDateTime(Schema.Entry entry,
 Date value)

withDateTime

Record.Builder withDateTime(String name,
 ZonedDateTime value)

withDateTime

Record.Builder withDateTime(Schema.Entry entry,
 ZonedDateTime value)

withDecimal

default Record.Builder withDecimal(String name,
 BigDecimal value)

withDecimal

default Record.Builder withDecimal(Schema.Entry entry,
 BigDecimal value)

withTimestamp

Record.Builder withTimestamp(String name,
 long value)

withTimestamp

Record.Builder withTimestamp(Schema.Entry entry,
 long value)

withInstant

default Record.Builder withInstant(String name,
 Instant value)

withInstant

default Record.Builder withInstant(Schema.Entry entry,
 Instant value)

withInt

Record.Builder withInt(String name,
 int value)

withInt

Record.Builder withInt(Schema.Entry entry,
 int value)

withLong

Record.Builder withLong(String name,
 long value)

withLong

Record.Builder withLong(Schema.Entry entry,
 long value)

withFloat

Record.Builder withFloat(String name,
 float value)

withFloat

Record.Builder withFloat(Schema.Entry entry,
 float value)

withDouble

Record.Builder withDouble(String name,
 double value)

withDouble

Record.Builder withDouble(Schema.Entry entry,
 double value)

withBoolean

Record.Builder withBoolean(String name,
 boolean value)

withBoolean

Record.Builder withBoolean(Schema.Entry entry,
 boolean value)

withRecord

Record.Builder withRecord(Schema.Entry entry,
 Record value)

withRecord

Record.Builder withRecord(String name,
 Record value)

Parameters:

name - entry name.

value - record value.

Returns:

this builder.

Since:

1.1.6

withArray

<T> Record.Builder withArray(Schema.Entry entry,
 Collection<T> values)