org.apache.samza.system

Interface SystemAdmin

All Known Implementing Classes:

SinglePartitionWithoutOffsetsSystemAdmin

public interface SystemAdmin

Helper interface attached to an underlying system to fetch information about streams, partitions, offsets, etc. This interface is useful for providing utility methods that Samza needs in order to interact with a system.

Method Summary

Modifier and Type	Method and Description
void	createChangelogStream(java.lang.String streamName, int numOfPartitions) An API to create a change log stream
java.util.Map<SystemStreamPartition,java.lang.String>	getOffsetsAfter(java.util.Map<SystemStreamPartition,java.lang.String> offsets) Fetches the offsets for the messages immediately after the supplied offsets for a group of SystemStreamPartitions.
java.util.Map<java.lang.String,SystemStreamMetadata>	getSystemStreamMetadata(java.util.Set<java.lang.String> streamNames) Fetch metadata from a system for a set of streams.

Method Detail

getOffsetsAfter

java.util.Map<SystemStreamPartition,java.lang.String> getOffsetsAfter(java.util.Map<SystemStreamPartition,java.lang.String> offsets)

Fetches the offsets for the messages immediately after the supplied offsets for a group of SystemStreamPartitions.

Parameters:

offsets - Map from SystemStreamPartition to current offsets.

Returns:

Map from SystemStreamPartition to offsets immediately after the current offsets.

getSystemStreamMetadata

java.util.Map<java.lang.String,SystemStreamMetadata> getSystemStreamMetadata(java.util.Set<java.lang.String> streamNames)

Fetch metadata from a system for a set of streams.

Parameters:

streamNames - The streams to to fetch metadata for.

Returns:

A map from stream name to SystemStreamMetadata for each stream requested in the parameter set.

createChangelogStream

void createChangelogStream(java.lang.String streamName,
                           int numOfPartitions)

An API to create a change log stream

Parameters:

streamName - The name of the stream to be created in the underlying stream

numOfPartitions - The number of partitions in the changelog stream