Package one.microstream.afs.kafka

Class TopicIndex.Default

java.lang.Object

one.microstream.afs.kafka.TopicIndex.Default

All Implemented Interfaces:

AutoCloseable, TopicIndex

Enclosing interface:

TopicIndex

public static class TopicIndex.Default
extends Object
implements TopicIndex

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.afs.kafka.TopicIndex

TopicIndex.Default

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
void	close()
TopicIndex	delete(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)
Iterable<Blob>	get()
TopicIndex	put(Iterable<Blob> metadata)

Methods inherited from class java.lang.Object

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

Constructor Details

Default

public Default()

Method Details

get

public Iterable<Blob> get()

Specified by:

get in interface TopicIndex

put

public TopicIndex put(Iterable<Blob> metadata)

Specified by:

put in interface TopicIndex

delete

public TopicIndex delete(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)

Specified by:

delete in interface TopicIndex

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface TopicIndex