Package | Description |
---|---|
org.talend.sdk.component.api.record | |
org.talend.sdk.component.api.service.record | |
org.talend.sdk.component.api.service.schema |
Modifier and Type | Method and Description |
---|---|
Schema.Entry |
Schema.Entry.Builder.build() |
Modifier and Type | Method and Description |
---|---|
List<Schema.Entry> |
Schema.getEntries() |
Modifier and Type | Method and Description |
---|---|
Collector<Schema.Entry,Record.Builder,Record> |
RecordService.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.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RecordService.forwardEntry(Record source,
Record.Builder builder,
String sourceColumn,
Schema.Entry entry)
Forward an entry from the source record if it exists.
|
default void |
RecordVisitor.onBoolean(Schema.Entry entry,
Optional<Boolean> optionalBoolean) |
default void |
RecordVisitor.onBooleanArray(Schema.Entry entry,
Optional<Collection<Boolean>> array) |
default void |
RecordVisitor.onBytes(Schema.Entry entry,
Optional<byte[]> bytes) |
default void |
RecordVisitor.onBytesArray(Schema.Entry entry,
Optional<Collection<byte[]>> array) |
default void |
RecordVisitor.onDatetime(Schema.Entry entry,
Optional<ZonedDateTime> dateTime) |
default void |
RecordVisitor.onDatetimeArray(Schema.Entry entry,
Optional<Collection<ZonedDateTime>> array) |
default void |
RecordVisitor.onDouble(Schema.Entry entry,
OptionalDouble optionalDouble) |
default void |
RecordVisitor.onDoubleArray(Schema.Entry entry,
Optional<Collection<Double>> array) |
default void |
RecordVisitor.onFloat(Schema.Entry entry,
OptionalDouble optionalFloat) |
default void |
RecordVisitor.onFloatArray(Schema.Entry entry,
Optional<Collection<Float>> array) |
default void |
RecordVisitor.onInt(Schema.Entry entry,
OptionalInt optionalInt) |
default void |
RecordVisitor.onIntArray(Schema.Entry entry,
Optional<Collection<Integer>> array) |
default void |
RecordVisitor.onLong(Schema.Entry entry,
OptionalLong optionalLong) |
default void |
RecordVisitor.onLongArray(Schema.Entry entry,
Optional<Collection<Long>> array) |
default RecordVisitor<T> |
RecordVisitor.onRecord(Schema.Entry entry,
Optional<Record> record) |
default RecordVisitor<T> |
RecordVisitor.onRecordArray(Schema.Entry entry,
Optional<Collection<Record>> array) |
default void |
RecordVisitor.onString(Schema.Entry entry,
Optional<String> string) |
default void |
RecordVisitor.onStringArray(Schema.Entry entry,
Optional<Collection<String>> array) |
Modifier and Type | Method and Description |
---|---|
Record |
RecordService.create(Schema schema,
Record fallbackRecord,
BiFunction<Schema.Entry,Record.Builder,Boolean> customHandler,
BiConsumer<Record.Builder,Boolean> beforeFinish)
Shortcut to build a record using
RecordService.toRecord(Schema, Record, BiFunction, BiConsumer) . |
Collector<Schema.Entry,Record.Builder,Record> |
RecordService.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.
|
Modifier and Type | Class and Description |
---|---|
static class |
Schema.Entry
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
Schema.setEntries(Collection<Schema.Entry> entries)
Deprecated.
|
Constructor and Description |
---|
Schema(Collection<Schema.Entry> entries)
Deprecated.
|
1.1.14-SNAPSHOT - Copyright © 2019 Talend Component Kit Documentation