@InterfaceStability.Unstable @InterfaceAudience.Public public abstract class InputInitializer extends Object
InputInitializer
s are typically used to initialize vertices
connected to data sources. They run in the App Master and can be used to
distribute data across the tasks for the vertex, determine the number of
tasks at runtime, update the Input payload etc.Constructor and Description |
---|
InputInitializer(InputInitializerContext initializerContext)
Constructor an instance of the InputInitializer.
|
Modifier and Type | Method and Description |
---|---|
InputInitializerContext |
getContext()
Return ahe
InputInitializerContext
for this specific instance of the Initializer. |
abstract void |
handleInputInitializerEvent(List<InputInitializerEvent> events)
Handle events meant for the specific Initializer.
|
abstract List<Event> |
initialize()
Run the initializer.
|
public InputInitializer(InputInitializerContext initializerContext)
initializerContext
- initializer context which can be used to access the payload, vertex
properties, etcpublic abstract List<Event> initialize() throws Exception
VertexManagerPlugin
for routingException
public abstract void handleInputInitializerEvent(List<InputInitializerEvent> events) throws Exception
events
- list of eventsException
public final InputInitializerContext getContext()
InputInitializerContext
for this specific instance of the Initializer.InputInitializerContext
for the initializerCopyright © 2014 Apache Software Foundation. All rights reserved.