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, setConfpublic 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 DataAppenderjava.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 DataAppenderuserMappingData - user {raw id, inner id} mappublic void setItemMappingData(com.google.common.collect.BiMap<java.lang.String,java.lang.Integer> itemMappingData)
setItemMappingData in interface DataAppenderitemMappingData - item {raw id, inner id} mapCopyright © 2017. All Rights Reserved.