Package org.apache.beam.sdk.io.hadoop.format

Interface HadoopFormatIO.Write.ExternalSynchronizationBuilder<KeyT,ValueT>

Type Parameters:
KeyT - Key type to write
ValueT - Value type to write
Enclosing class:
HadoopFormatIO.Write<KeyT,ValueT>
public static interface HadoopFormatIO.Write.ExternalSynchronizationBuilder<KeyT,ValueT>
Builder for External Synchronization defining.

  • Method Details

    • withExternalSynchronization

      HadoopFormatIO.Write<KeyT,ValueT> withExternalSynchronization(ExternalSynchronization externalSynchronization)
      Specifies class which will provide external synchronization required for hadoop write operation.
      Parameters:
      externalSynchronization - provider of external synchronization
      Returns:
      Write transformation