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

package org.apache.beam.sdk.io.kudu

Transforms for reading and writing from/to Apache Kudu.

See Also:

• KuduIO

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

Class	Description
KuduIO	A bounded source and sink for Kudu.
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.
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 TableAndRecord representing a typed record.