public class EventHubSpoutConfig extends Object implements Serializable
| Modifier and Type | Field and Description |
|---|---|
static String |
EH_SERVICE_FQDN_SUFFIX |
| Constructor and Description |
|---|
EventHubSpoutConfig(String username,
String password,
String namespace,
String entityPath,
int partitionCount) |
EventHubSpoutConfig(String username,
String password,
String namespace,
String entityPath,
int partitionCount,
String zkConnectionString) |
EventHubSpoutConfig(String username,
String password,
String namespace,
String entityPath,
int partitionCount,
String zkConnectionString,
int checkpointIntervalInSeconds,
int receiverCredits) |
EventHubSpoutConfig(String username,
String password,
String namespace,
String entityPath,
int partitionCount,
String zkConnectionString,
int checkpointIntervalInSeconds,
int receiverCredits,
int maxPendingMsgsPerPartition,
long enqueueTimeFilter) |
EventHubSpoutConfig(String username,
String password,
String namespace,
String entityPath,
int partitionCount,
String zkConnectionString,
int checkpointIntervalInSeconds,
int receiverCredits,
long enqueueTimeFilter) |
public static final String EH_SERVICE_FQDN_SUFFIX
public EventHubSpoutConfig(String username, String password, String namespace, String entityPath, int partitionCount)
public EventHubSpoutConfig(String username, String password, String namespace, String entityPath, int partitionCount, String zkConnectionString)
public EventHubSpoutConfig(String username, String password, String namespace, String entityPath, int partitionCount, String zkConnectionString, int checkpointIntervalInSeconds, int receiverCredits)
public EventHubSpoutConfig(String username, String password, String namespace, String entityPath, int partitionCount, String zkConnectionString, int checkpointIntervalInSeconds, int receiverCredits, long enqueueTimeFilter)
public String getNamespace()
public String getEntityPath()
public int getPartitionCount()
public String getZkConnectionString()
public void setZkConnectionString(String value)
public EventHubSpoutConfig withZkConnectionString(String value)
public int getCheckpointIntervalInSeconds()
public void setCheckpointIntervalInSeconds(int value)
public EventHubSpoutConfig withCheckpointIntervalInSeconds(int value)
public int getReceiverCredits()
public void setReceiverCredits(int value)
public EventHubSpoutConfig withReceiverCredits(int value)
public int getMaxPendingMsgsPerPartition()
public void setMaxPendingMsgsPerPartition(int value)
public EventHubSpoutConfig withMaxPendingMsgsPerPartition(int value)
public long getEnqueueTimeFilter()
public void setEnqueueTimeFilter(long value)
public EventHubSpoutConfig withEnqueueTimeFilter(long value)
public String getTopologyName()
public void setTopologyName(String value)
public EventHubSpoutConfig withTopologyName(String value)
public IEventDataScheme getEventDataScheme()
public void setEventDataScheme(IEventDataScheme scheme)
public EventHubSpoutConfig withEventDataScheme(IEventDataScheme value)
public String getConsumerGroupName()
public void setConsumerGroupName(String value)
public EventHubSpoutConfig withConsumerGroupName(String value)
public String getConnectionString()
public void setTargetAddress(String targetFqnAddress)
public void setTargetAddress()
public EventHubSpoutConfig withTargetAddress(String targetFqnAddress)
public String getOutputStreamId()
public void setOutputStreamId(String outputStreamId)
public int getReceiverTimeoutInMillis()
public void setReceiverTimeoutInMillis(int receiverTimeoutInMillis)
Copyright © 2022 The Apache Software Foundation. All rights reserved.