KeyT
- Key type to writeValueT
- Value type to writepublic static interface HadoopFormatIO.Write.WriteBuilder<KeyT,ValueT>
Modifier and Type | Method and Description |
---|---|
HadoopFormatIO.Write.PartitionedWriterBuilder<KeyT,ValueT> |
withConfiguration(org.apache.hadoop.conf.Configuration config)
Writes to the sink using the options provided by the given hadoop configuration.
|
HadoopFormatIO.Write.ExternalSynchronizationBuilder<KeyT,ValueT> |
withConfigurationTransform(PTransform<PCollection<? extends KV<KeyT,ValueT>>,PCollectionView<org.apache.hadoop.conf.Configuration>> configTransform)
Writes to the sink using configuration created by provided
configurationTransformation . |
HadoopFormatIO.Write.PartitionedWriterBuilder<KeyT,ValueT> withConfiguration(org.apache.hadoop.conf.Configuration config)
Note: Works only for PCollection.IsBounded.BOUNDED
PCollection
with global
WindowingStrategy
.
config
- hadoop configuration.java.lang.NullPointerException
- when the configuration is nullfor required hadoop {@link Configuration} properties
HadoopFormatIO.Write.ExternalSynchronizationBuilder<KeyT,ValueT> withConfigurationTransform(PTransform<PCollection<? extends KV<KeyT,ValueT>>,PCollectionView<org.apache.hadoop.conf.Configuration>> configTransform)
configurationTransformation
.
This type is useful especially for processing unbounded windowed data but can be used also for batch processing.
Supports only PCollection
with DefaultTrigger
ing and without allowed
lateness
configTransform
- configuration transformation interfacejava.lang.NullPointerException
- when configurationTransformation
is null
for required hadoop {@link Configuration} properties