@Experimental(value=SOURCE_SINK)

Package org.apache.beam.sdk.io.kudu

Transforms for reading and writing from/to Apache Kudu.

See: Description

Interface Summary

Interface	Description
KuduIO.FormatFunction<T>	An interface used by the KuduIO Write to convert an input record into an Operation to apply as a mutation in Kudu.

Class Summary

Class	Description
KuduIO	A bounded source and sink for Kudu.
KuduIO.Read<T>	Implementation of KuduIO.read().
KuduIO.Write<T>	A PTransform that writes to Kudu.
TableAndRecord<T>	A wrapper for a KuduTable and the T representing a typed record.

Package org.apache.beam.sdk.io.kudu Description

Transforms for reading and writing from/to Apache Kudu.

See Also:

KuduIO