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 Summary

Modifier and Type	Method and Description
HadoopFormatIO.Write<KeyT,ValueT>	withExternalSynchronization(ExternalSynchronization externalSynchronization) Specifies class which will provide external synchronization required for hadoop write operation.

Method Detail

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