org.apache.beam.sdk.io.kinesis

Class KinesisTransformRegistrar.WriteBuilder.Configuration

java.lang.Object

org.apache.beam.sdk.io.kinesis.KinesisTransformRegistrar.WriteBuilder.Configuration

Enclosing class:

KinesisTransformRegistrar.WriteBuilder

public static class KinesisTransformRegistrar.WriteBuilder.Configuration
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Configuration()

Method Summary

Modifier and Type	Method and Description
void	setPartitionKey(java.lang.String partitionKey)
void	setProducerProperties(java.util.Map<java.lang.String,java.lang.String> producerProperties)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Configuration

public Configuration()

Method Detail

setProducerProperties

public void setProducerProperties(java.util.Map<java.lang.String,java.lang.String> producerProperties)

setPartitionKey

public void setPartitionKey(java.lang.String partitionKey)