K
- consumed record key typeT
- cell typepublic static interface UpdateOperation.CellUpdateOperation<K extends java.lang.Comparable<K>,T> extends UpdateOperation<K>
UpdateOperation.BoolWriteOperationBuilder, UpdateOperation.CellUpdateOperation<K extends java.lang.Comparable<K>,T>, UpdateOperation.DoubleWriteOperationBuilder, UpdateOperation.IntWriteOperationBuilder, UpdateOperation.LongWriteOperationBuilder, UpdateOperation.WriteOperationBuilder<T>
Modifier and Type | Method and Description |
---|---|
default java.lang.Iterable<Cell<?>> |
apply(Record<K> t)
Applies this transform to the given record.
|
java.util.function.Function<Record<?>,java.util.Optional<Cell<T>>> |
cell()
Returns the cell to be written or an empty optional to remove.
|
CellDefinition<T> |
definition()
Returns the cell definition modified by this transform.
|
CellDefinition<T> definition()
java.util.function.Function<Record<?>,java.util.Optional<Cell<T>>> cell()
default java.lang.Iterable<Cell<?>> apply(Record<K> t)
UpdateOperation
apply
in interface UpdateOperation<K extends java.lang.Comparable<K>>
t
- the incoming record