org.apache.samza.context

Interface ApplicationTaskContextFactory<T extends ApplicationTaskContext>

Type Parameters:

T - concrete type of ApplicationTaskContext created by this factory

All Superinterfaces:

java.io.Serializable

public interface ApplicationTaskContextFactory<T extends ApplicationTaskContext>
extends java.io.Serializable

The factory for creating ApplicationTaskContext instances for a SamzaApplicationduring task initialization.

Use ApplicationDescriptor.withApplicationTaskContextFactory(org.apache.samza.context.ApplicationTaskContextFactory<?>) to provide the ApplicationTaskContextFactory. Use Context.getApplicationTaskContext() to get the created ApplicationTaskContext instance for the current task.

The ApplicationTaskContextFactory implementation must be Serializable.

Method Summary

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

Method Detail

create

T create(JobContext jobContext,
         ContainerContext containerContext,
         TaskContext taskContext,
         ApplicationContainerContext applicationContainerContext)

Creates an instance of the application-defined ApplicationTaskContext.

Parameters:

jobContext - framework-provided job context

containerContext - framework-provided container context

taskContext - framework-provided task context

applicationContainerContext - application-defined container context

Returns:

a new instance of the application-defined ApplicationTaskContext