Package org.apache.beam.sdk.io.kudu
Interface KuduIO.FormatFunction<T>
- All Superinterfaces:
ProcessFunction<TableAndRecord<T>,
,org.apache.kudu.client.Operation> Serializable
,SerializableFunction<TableAndRecord<T>,
org.apache.kudu.client.Operation>
- Enclosing class:
KuduIO
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface
public static interface KuduIO.FormatFunction<T>
extends SerializableFunction<TableAndRecord<T>,org.apache.kudu.client.Operation>
An interface used by the KuduIO Write to convert an input record into an Operation to apply as
a mutation in Kudu.
-
Method Summary
Methods inherited from interface org.apache.beam.sdk.transforms.SerializableFunction
apply