Class EventHubStreamInputDataSource


  • public final class EventHubStreamInputDataSource
    extends StreamInputDataSource
    Describes an Event Hub input data source that contains stream data.
    • Constructor Detail

      • EventHubStreamInputDataSource

        public EventHubStreamInputDataSource()
    • Method Detail

      • consumerGroupName

        public String consumerGroupName()
        Get the consumerGroupName property: The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not specified, the input uses the Event Hub’s default consumer group.
        Returns:
        the consumerGroupName value.
      • withConsumerGroupName

        public EventHubStreamInputDataSource withConsumerGroupName​(String consumerGroupName)
        Set the consumerGroupName property: The name of an Event Hub Consumer Group that should be used to read events from the Event Hub. Specifying distinct consumer group names for multiple inputs allows each of those inputs to receive the same events from the Event Hub. If not specified, the input uses the Event Hub’s default consumer group.
        Parameters:
        consumerGroupName - the consumerGroupName value to set.
        Returns:
        the EventHubStreamInputDataSource object itself.
      • eventHubName

        public String eventHubName()
        Get the eventHubName property: The name of the Event Hub. Required on PUT (CreateOrReplace) requests.
        Returns:
        the eventHubName value.
      • withEventHubName

        public EventHubStreamInputDataSource withEventHubName​(String eventHubName)
        Set the eventHubName property: The name of the Event Hub. Required on PUT (CreateOrReplace) requests.
        Parameters:
        eventHubName - the eventHubName value to set.
        Returns:
        the EventHubStreamInputDataSource object itself.
      • serviceBusNamespace

        public String serviceBusNamespace()
        Get the serviceBusNamespace property: The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
        Returns:
        the serviceBusNamespace value.
      • withServiceBusNamespace

        public EventHubStreamInputDataSource withServiceBusNamespace​(String serviceBusNamespace)
        Set the serviceBusNamespace property: The namespace that is associated with the desired Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
        Parameters:
        serviceBusNamespace - the serviceBusNamespace value to set.
        Returns:
        the EventHubStreamInputDataSource object itself.
      • sharedAccessPolicyName

        public String sharedAccessPolicyName()
        Get the sharedAccessPolicyName property: The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
        Returns:
        the sharedAccessPolicyName value.
      • withSharedAccessPolicyName

        public EventHubStreamInputDataSource withSharedAccessPolicyName​(String sharedAccessPolicyName)
        Set the sharedAccessPolicyName property: The shared access policy name for the Event Hub, Service Bus Queue, Service Bus Topic, etc. Required on PUT (CreateOrReplace) requests.
        Parameters:
        sharedAccessPolicyName - the sharedAccessPolicyName value to set.
        Returns:
        the EventHubStreamInputDataSource object itself.
      • sharedAccessPolicyKey

        public String sharedAccessPolicyKey()
        Get the sharedAccessPolicyKey property: The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
        Returns:
        the sharedAccessPolicyKey value.
      • withSharedAccessPolicyKey

        public EventHubStreamInputDataSource withSharedAccessPolicyKey​(String sharedAccessPolicyKey)
        Set the sharedAccessPolicyKey property: The shared access policy key for the specified shared access policy. Required on PUT (CreateOrReplace) requests.
        Parameters:
        sharedAccessPolicyKey - the sharedAccessPolicyKey value to set.
        Returns:
        the EventHubStreamInputDataSource object itself.
      • authenticationMode

        public AuthenticationMode authenticationMode()
        Get the authenticationMode property: Authentication Mode.
        Returns:
        the authenticationMode value.
      • withAuthenticationMode

        public EventHubStreamInputDataSource withAuthenticationMode​(AuthenticationMode authenticationMode)
        Set the authenticationMode property: Authentication Mode.
        Parameters:
        authenticationMode - the authenticationMode value to set.
        Returns:
        the EventHubStreamInputDataSource object itself.