com.opendxl.databus.common.internal.adapter

Class TopicPartitionInfoListAdapter

java.lang.Object

com.opendxl.databus.common.internal.adapter.TopicPartitionInfoListAdapter

All Implemented Interfaces:

Adapter<java.util.Map<java.lang.String,java.util.List<org.apache.kafka.common.PartitionInfo>>,java.util.Map<java.lang.String,java.util.List<PartitionInfo>>>

public final class TopicPartitionInfoListAdapter
extends java.lang.Object
implements Adapter<java.util.Map<java.lang.String,java.util.List<org.apache.kafka.common.PartitionInfo>>,java.util.Map<java.lang.String,java.util.List<PartitionInfo>>>

Adapter for a Map of Topic and Partition Info.

Constructor Summary

Constructors

Constructor and Description
TopicPartitionInfoListAdapter()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.util.List<PartitionInfo>>	adapt(java.util.Map<java.lang.String,java.util.List<org.apache.kafka.common.PartitionInfo>> sourceTopicPartitionInfoList) Adapter pattern implementation for Map<String, List<PartitionInfo>> instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicPartitionInfoListAdapter

public TopicPartitionInfoListAdapter()

Method Detail

adapt

public java.util.Map<java.lang.String,java.util.List<PartitionInfo>> adapt(java.util.Map<java.lang.String,java.util.List<org.apache.kafka.common.PartitionInfo>> sourceTopicPartitionInfoList)

Adapter pattern implementation for Map<String, List<PartitionInfo>> instance. Adapts a Map<String, List<org.apache.kafka.common.PartitionInfo>> to a Map<String, List<com.opendxl.databus.common.PartitionInfo>> instance.

Specified by:

adapt in interface Adapter<java.util.Map<java.lang.String,java.util.List<org.apache.kafka.common.PartitionInfo>>,java.util.Map<java.lang.String,java.util.List<PartitionInfo>>>

Parameters:

sourceTopicPartitionInfoList - a source Map of Topic and Partition Info List.

Returns:

a Map of Topic and PartitionInfo List.