public class SocialDataAppender extends Configured implements DataAppender
conf, CONF_DATA_COLUMN_FORMAT, CONF_DATA_INPUT_PATH, CONF_DFS_DATA_DIR
Constructor and Description |
---|
SocialDataAppender()
Initializes a newly created
SocialDataAppender object with null. |
SocialDataAppender(Configuration conf)
Initializes a newly created
SocialDataAppender object with a
Configuration object |
Modifier and Type | Method and Description |
---|---|
SparseMatrix |
getItemAppender()
Get item appender.
|
SparseMatrix |
getUserAppender()
Get user appender.
|
void |
processData()
Process appender data.
|
void |
setItemMappingData(com.google.common.collect.BiMap<java.lang.String,java.lang.Integer> itemMappingData)
Set item mapping data.
|
void |
setUserMappingData(com.google.common.collect.BiMap<java.lang.String,java.lang.Integer> userMappingData)
Set user mapping data.
|
getConf, setConf
public SocialDataAppender()
SocialDataAppender
object with null.public SocialDataAppender(Configuration conf)
SocialDataAppender
object with a
Configuration
objectconf
- Configuration
object for constructionpublic void processData() throws java.io.IOException
processData
in interface DataAppender
java.io.IOException
- if I/O error occurs during processingpublic SparseMatrix getUserAppender()
SparseMatrix
object built by the social data.public SparseMatrix getItemAppender()
public void setUserMappingData(com.google.common.collect.BiMap<java.lang.String,java.lang.Integer> userMappingData)
setUserMappingData
in interface DataAppender
userMappingData
- user {raw id, inner id} mappublic void setItemMappingData(com.google.common.collect.BiMap<java.lang.String,java.lang.Integer> itemMappingData)
setItemMappingData
in interface DataAppender
itemMappingData
- item {raw id, inner id} mapCopyright © 2017. All Rights Reserved.