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)
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

createChangelogStream, createCoordinatorStream, createStream, getOffsetsAfter, getSystemStreamMetadata, offsetComparator, validateChangelogStream, validateStream

Method Detail

getSystemStreamPartitionCounts

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

getNewestOffset

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