org.apache.samza.system

Interface SystemFactory

public interface SystemFactory

Build the SystemConsumer and SystemProducer for a particular system, as well as the accompanying SystemAdmin.

Method Summary

Modifier and Type	Method and Description
SystemAdmin	getAdmin(java.lang.String systemName, Config config)
SystemConsumer	getConsumer(java.lang.String systemName, Config config, MetricsRegistry registry)
SystemProducer	getProducer(java.lang.String systemName, Config config, MetricsRegistry registry)

Method Detail

getConsumer

SystemConsumer getConsumer(java.lang.String systemName,
                           Config config,
                           MetricsRegistry registry)

getProducer

SystemProducer getProducer(java.lang.String systemName,
                           Config config,
                           MetricsRegistry registry)

getAdmin

SystemAdmin getAdmin(java.lang.String systemName,
                     Config config)