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

Class CdapIO.Write<K,V>

java.lang.Object
org.apache.beam.sdk.transforms.PTransform<PCollection<KV<K,V>>,PDone>
org.apache.beam.sdk.io.cdap.CdapIO.Write<K,V>
All Implemented Interfaces:
Serializable, HasDisplayData
Enclosing class:
CdapIO
public abstract static class CdapIO.Write<K,V> extends PTransform<PCollection<KV<K,V>>,PDone>
A PTransform to write to CDAP sink.
See Also:

  • Constructor Details

    • Write

      public Write()

  • Method Details

    • withCdapPlugin

      public CdapIO.Write<K,V> withCdapPlugin(Plugin<K,V> plugin)
      Sets a CDAP Plugin.

    • withCdapPluginClass

      public CdapIO.Write<K,V> withCdapPluginClass(Class<?> cdapPluginClass)
      Sets a CDAP Plugin class.

    • withPluginConfig

      public CdapIO.Write<K,V> withPluginConfig(PluginConfig pluginConfig)
      Sets a PluginConfig.

    • withKeyClass

      public CdapIO.Write<K,V> withKeyClass(Class<K> keyClass)
      Sets a key class.

    • withLocksDirPath

      public CdapIO.Write<K,V> withLocksDirPath(String locksDirPath)
      Sets path to directory where locks will be stored.

    • withValueClass

      public CdapIO.Write<K,V> withValueClass(Class<V> valueClass)
      Sets a value class.

    • expand

      public PDone expand(PCollection<KV<K,V>> input)
      Description copied from class: PTransform
      Override this method to specify how this PTransform should be expanded on the given InputT.

      NOTE: This method should not be called directly. Instead apply the PTransform should be applied to the InputT using the apply method.

      Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).

      Specified by:
      expand in class PTransform<PCollection<KV<K,V>>,PDone>