org.springframework.data.hadoop.store.strategy.naming

Class RollingFileNamingStrategy

java.lang.Object

org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy

org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy

All Implemented Interfaces:

org.springframework.core.Ordered, FileNamingStrategy, FileNamingStrategyFactory<FileNamingStrategy>

public class RollingFileNamingStrategy
extends AbstractFileNamingStrategy

A FileNamingStrategy which simply uses a rolling counter to give unique file name.

Author:

Janne Valkealahti

Field Summary

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
RollingFileNamingStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
RollingFileNamingStrategy	createInstance() Creates a new instance of FileNamingStrategy.
org.apache.hadoop.fs.Path	init(org.apache.hadoop.fs.Path path) Initialises a starting state of a strategy.
void	next() This method should be called to prepare next filename in case strategy doesn't know how to do it automatically.
void	reset() Resets the strategy to its original state.
org.apache.hadoop.fs.Path	resolve(org.apache.hadoop.fs.Path path) Resolve a current file path denoted by this strategy.
void	setPrefix(java.lang.String prefix) Sets the prefix preceding rolling number part.

Methods inherited from class org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy

getCodecInfo, getOrder, isEnabled, setCodecInfo, setEnabled, setOrder

Methods inherited from class java.lang.Object

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

Constructor Detail

RollingFileNamingStrategy

public RollingFileNamingStrategy()

Method Detail

resolve

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

Description copied from interface: FileNamingStrategy

Resolve a current file path denoted by this strategy.

Parameters:

path - the path

Returns:

the path

next

public void next()

Description copied from interface: FileNamingStrategy

This method should be called to prepare next filename in case strategy doesn't know how to do it automatically.

reset

public void reset()

Description copied from interface: FileNamingStrategy

Resets the strategy to its original state.

Specified by:

reset in interface FileNamingStrategy

Overrides:

reset in class AbstractFileNamingStrategy

init

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

Description copied from interface: FileNamingStrategy

Initialises a starting state of a strategy. Implementor of this method needs to check the final part of the Path and remove its own handled part if possible. Returned Path is then passed into next strategy for it to able to do its own initialisation logic.

Path passed to this method may be null indicating that no further processing should be done or simply we don't have information about the initialised path.

Specified by:

init in interface FileNamingStrategy

Overrides:

init in class AbstractFileNamingStrategy

Parameters:

path - the path

Returns:

the path

setPrefix

public void setPrefix(java.lang.String prefix)

Sets the prefix preceding rolling number part.

Parameters:

prefix - the new prefix

createInstance

public RollingFileNamingStrategy createInstance()

Description copied from interface: FileNamingStrategyFactory

Creates a new instance of FileNamingStrategy.

Specified by:

createInstance in interface FileNamingStrategyFactory<FileNamingStrategy>

Specified by:

createInstance in class AbstractFileNamingStrategy

Returns:

a new instance of file naming strategy