Package com.here.platform.data.client.flink.impl

Class VolatileMetadataPartitionSelector

java.lang.Object

com.here.platform.data.client.flink.impl.VolatileMetadataPartitionSelector

public class VolatileMetadataPartitionSelector
extends Object

Constructor Summary

Constructors

Constructor	Description
VolatileMetadataPartitionSelector()

Method Summary

Modifier and Type	Method	Description
static scala.collection.Iterator<com.here.platform.data.client.scaladsl.CommitPartition>	getLatestPartitions(scala.collection.Iterator<com.here.platform.data.client.scaladsl.CommitPartition> partitions)

Methods inherited from class java.lang.Object

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

Constructor Details

VolatileMetadataPartitionSelector

public VolatileMetadataPartitionSelector()

Method Details

getLatestPartitions

public static scala.collection.Iterator<com.here.platform.data.client.scaladsl.CommitPartition> getLatestPartitions(scala.collection.Iterator<com.here.platform.data.client.scaladsl.CommitPartition> partitions)