org.springframework.data.hadoop.store.support
Class OutputContext

java.lang.Object
  org.springframework.data.hadoop.store.support.OutputContext

public class OutputContext
extends java.lang.Object

Context strategy keeping output state.

Author:

Janne Valkealahti

Constructor Summary

OutputContext()
Instantiates a new strategy context.

Method Summary

boolean	getRolloverState() Gets the rollover state.
void	init(org.apache.hadoop.fs.Path path)
org.apache.hadoop.fs.Path	resolvePath(org.apache.hadoop.fs.Path path) Resolve path.
void	rollStrategies() Roll strategies.
void	setCodecInfo(CodecInfo codecInfo) Sets the codec info.
void	setFileNamingStrategy(FileNamingStrategy fileNamingStrategy) Sets the file naming strategy.
void	setRolloverStrategy(RolloverStrategy rolloverStrategy) Sets the rollover strategy.
void	setWritePosition(long position) Sets the write position.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputContext

public OutputContext()

Instantiates a new strategy context.

Method Detail

setWritePosition

public void setWritePosition(long position)

Sets the write position.

Parameters:

position - the new write position

getRolloverState

public boolean getRolloverState()

Gets the rollover state.

Returns:

the rollover state

rollStrategies

public void rollStrategies()

Roll strategies.

resolvePath

public org.apache.hadoop.fs.Path resolvePath(org.apache.hadoop.fs.Path path)

Resolve path.

Parameters:

path - the path

Returns:

the path

init

public void init(org.apache.hadoop.fs.Path path)

setCodecInfo

public void setCodecInfo(CodecInfo codecInfo)

Sets the codec info.

Parameters:

codecInfo - the new codec info

setFileNamingStrategy

public void setFileNamingStrategy(FileNamingStrategy fileNamingStrategy)

Sets the file naming strategy.

Parameters:

fileNamingStrategy - the new file naming strategy

setRolloverStrategy

public void setRolloverStrategy(RolloverStrategy rolloverStrategy)

Sets the rollover strategy.

Parameters:

rolloverStrategy - the new rollover strategy