public class HiveSplitGenerator
extends org.apache.tez.runtime.api.InputInitializer
Constructor and Description |
---|
HiveSplitGenerator(org.apache.hadoop.conf.Configuration conf,
MapWork work) |
HiveSplitGenerator(org.apache.tez.runtime.api.InputInitializerContext initializerContext) |
Modifier and Type | Method and Description |
---|---|
void |
handleInputInitializerEvent(List<org.apache.tez.runtime.api.events.InputInitializerEvent> events) |
List<org.apache.tez.runtime.api.Event> |
initialize() |
void |
onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate) |
public HiveSplitGenerator(org.apache.hadoop.conf.Configuration conf, MapWork work) throws IOException
IOException
public HiveSplitGenerator(org.apache.tez.runtime.api.InputInitializerContext initializerContext) throws IOException, SerDeException
IOException
SerDeException
public List<org.apache.tez.runtime.api.Event> initialize() throws Exception
initialize
in class org.apache.tez.runtime.api.InputInitializer
Exception
public void onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate)
onVertexStateUpdated
in class org.apache.tez.runtime.api.InputInitializer
Copyright © 2021 The Apache Software Foundation. All rights reserved.