public interface IPartitionManagerFactory extends Serializable
Modifier and Type | Method and Description |
---|---|
IPartitionManager |
create(EventHubSpoutConfig spoutConfig,
String partitionId,
IStateStore stateStore,
IEventHubReceiver receiver) |
IPartitionManager create(EventHubSpoutConfig spoutConfig, String partitionId, IStateStore stateStore, IEventHubReceiver receiver)
Copyright © 2023 The Apache Software Foundation. All rights reserved.