Package org.apache.beam.sdk.io.cdap

package org.apache.beam.sdk.io.cdap

Transforms for reading and writing from CDAP.

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.
org.apache.beam.sdk.io.cdap.context	Context for CDAP classes.

Class	Description
CdapIO	A CdapIO is a Transform for reading data from source or writing data to sink of a Cdap Plugin.
CdapIO.Read<K,V>	A PTransform to read from CDAP source.
CdapIO.Write<K,V>	A PTransform to write to CDAP sink.
ConfigWrapper<T extends PluginConfig>	Class for building PluginConfig object of the specific class .
MappingUtils	Util class for mapping plugins.
Plugin<K,V>	Class wrapper for a CDAP plugin.
Plugin.Builder<K,V>	Builder class for a Plugin.
PluginConfigInstantiationUtils	Class for getting any filled PluginConfig configuration object.
PluginConstants	Class for CDAP plugin constants.
PluginConstants.Format	Format types.
PluginConstants.FormatProvider	Format provider types.
PluginConstants.Hadoop	Hadoop types.
PluginConstants.PluginType	Plugin types.