org.apache.samza.system

Interface ExtendedSystemAdmin

All Superinterfaces:

SystemAdmin

public interface ExtendedSystemAdmin
extends SystemAdmin

Interface extends the more generic SystemAdmin interface TODO: Merge this interface method with SystemAdmin when we upgrade to JDK 1.8

Method Summary

Modifier and Type	Method and Description
java.lang.String	getNewestOffset(SystemStreamPartition ssp, java.lang.Integer maxRetries) Deprecated.
java.util.Map<java.lang.String,SystemStreamMetadata>	getSystemStreamPartitionCounts(java.util.Set<java.lang.String> streamNames, long cacheTTL)

Methods inherited from interface org.apache.samza.system.SystemAdmin

clearStream, createStream, deleteMessages, getOffsetsAfter, getSSPMetadata, getSystemStreamMetadata, offsetComparator, start, stop, validateStream

Method Detail

getSystemStreamPartitionCounts

java.util.Map<java.lang.String,SystemStreamMetadata> getSystemStreamPartitionCounts(java.util.Set<java.lang.String> streamNames,
                                                                                    long cacheTTL)

getNewestOffset

@Deprecated
java.lang.String getNewestOffset(SystemStreamPartition ssp,
                                             java.lang.Integer maxRetries)

Deprecated.

Deprecated: Use SystemAdmin.getSSPMetadata(java.util.Set<org.apache.samza.system.SystemStreamPartition>), ideally combined with caching (i.e. SSPMetadataCache). Makes fewer offset requests than getSystemStreamMetadata