com.opendxl.databus.common.internal.adapter

Class PartitionInfoListAdapter

java.lang.Object

com.opendxl.databus.common.internal.adapter.PartitionInfoListAdapter

All Implemented Interfaces:

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

public class PartitionInfoListAdapter
extends java.lang.Object
implements Adapter<java.util.List<org.apache.kafka.common.PartitionInfo>,java.util.List<PartitionInfo>>

Adapter a List of PartitionInfo.

Constructor Summary

Constructors

Constructor and Description
PartitionInfoListAdapter()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionInfoListAdapter

public PartitionInfoListAdapter()

Method Detail

adapt

public java.util.List<PartitionInfo> adapt(java.util.List<org.apache.kafka.common.PartitionInfo> sourcePartitionInfoList)

Adapter pattern implementation for PartitionInfo List instance. Adapts a org.apache.kafka.common.PartitionInfo to a com.opendxl.databus.common.PartitionInfo instance.

Specified by:

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

Parameters:

sourcePartitionInfoList - a List of source org.apache.kafka.common.PartitionInfo.

Returns:

a List of PartitionInfo