org.springframework.data.hadoop.hive
Class HiveTasklet

java.lang.Object
  org.springframework.data.hadoop.hive.HiveTasklet

All Implemented Interfaces:

Tasklet, InitializingBean

public class HiveTasklet
extends Object
implements InitializingBean, Tasklet

Hive tasklet running Hive scripts on demand, against a HiveClient.

Author:

Costin Leau

Constructor Summary

HiveTasklet()

Method Summary

void	afterPropertiesSet()
RepeatStatus	execute(StepContribution contribution, ChunkContext chunkContext)
void	setHiveClient(HiveClient hive) Sets the hive client for this tasklet.
void	setScripts(Collection<Resource> scripts) Sets the scripts to be executed by this tasklet.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveTasklet

public HiveTasklet()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

execute

public RepeatStatus execute(StepContribution contribution,
                            ChunkContext chunkContext)
                     throws Exception

Specified by:

execute in interface Tasklet

Throws:

Exception

setScripts

public void setScripts(Collection<Resource> scripts)

Sets the scripts to be executed by this tasklet.

Parameters:

scripts - The scripts to set.

setHiveClient

public void setHiveClient(HiveClient hive)

Sets the hive client for this tasklet.

Parameters:

hive - HiveClient to set