org.apache.samza.context

Interface ApplicationContainerContextFactory<T extends ApplicationContainerContext>

Type Parameters:

T - concrete type of ApplicationContainerContext created by this factory

All Superinterfaces:

java.io.Serializable

public interface ApplicationContainerContextFactory<T extends ApplicationContainerContext>
extends java.io.Serializable

The factory for creating ApplicationContainerContext instances for a SamzaApplication during container initialization.

Use ApplicationDescriptor.withApplicationContainerContextFactory(org.apache.samza.context.ApplicationContainerContextFactory<?>) to provide the ApplicationContainerContextFactory. Use Context.getApplicationContainerContext() to get the created ApplicationContainerContext instance for the current container.

The ApplicationContainerContextFactory implementation must be Serializable.

Method Summary

Modifier and Type	Method and Description
T	create(JobContext jobContext, ContainerContext containerContext) Creates an instance of the application-defined ApplicationContainerContext.

Method Detail

create

T create(JobContext jobContext,
         ContainerContext containerContext)

Creates an instance of the application-defined ApplicationContainerContext.

Parameters:

jobContext - framework-provided job context

containerContext - framework-provided container context

Returns:

a new instance of the application-defined ApplicationContainerContext