|
Spring for Apache Hadoop | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.data.hadoop.store.strategy.naming.AbstractFileNamingStrategy org.springframework.data.hadoop.store.strategy.naming.RollingFileNamingStrategy
public class RollingFileNamingStrategy
A FileNamingStrategy
which simply uses a rolling counter to give unique file name.
Field Summary |
---|
Fields inherited from interface org.springframework.core.Ordered |
---|
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE |
Constructor Summary | |
---|---|
RollingFileNamingStrategy()
|
Method Summary | |
---|---|
org.apache.hadoop.fs.Path |
init(org.apache.hadoop.fs.Path path)
Initialises a starting state of a strategy. |
void |
reset()
Resets the strategy. |
org.apache.hadoop.fs.Path |
resolve(org.apache.hadoop.fs.Path path)
Resolve a current filename. |
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, setCodecInfo, setOrder |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RollingFileNamingStrategy()
Method Detail |
---|
public org.apache.hadoop.fs.Path resolve(org.apache.hadoop.fs.Path path)
FileNamingStrategy
public void reset()
FileNamingStrategy
public org.apache.hadoop.fs.Path init(org.apache.hadoop.fs.Path path)
FileNamingStrategy
Path
and
remove it's 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.
init
in interface FileNamingStrategy
init
in class AbstractFileNamingStrategy
path
- the path
public void setPrefix(java.lang.String prefix)
prefix
- the new prefix
|
Spring for Apache Hadoop | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |