|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object felix.io.HadoopPostgreSQLPopulator
public class HadoopPostgreSQLPopulator
Class for populating tables from files/directories generated with hadoop.
Constructor Summary | |
---|---|
HadoopPostgreSQLPopulator()
|
Method Summary | |
---|---|
static void |
createAndPopulateTable(java.lang.String schema,
java.lang.String tableName,
java.util.List<java.lang.String> columnNames,
java.util.List<java.lang.String> columnTypes,
java.lang.String filePath)
Creates and populates the given schema.table from the given file. |
static void |
createAndPopulateTableFromDir(java.lang.String schema,
java.lang.String tableName,
java.util.List<java.lang.String> columnNames,
java.util.List<java.lang.String> columnTypes,
java.lang.String dirPath,
int nReducer)
Creates and populates the given schema.table from the given directory. |
static void |
dumpTableToHDFS(java.lang.String schema,
java.lang.String tableName,
int nColumn,
java.lang.String filePath)
Dumps given schema.table in to the given file. |
static void |
main(java.lang.String[] args)
Main test method. |
static void |
populateTable(java.lang.String schema,
java.lang.String tableName,
java.util.List<java.lang.String> columnNames,
java.util.List<java.lang.String> columnTypes,
java.lang.String filePath)
Populates the given schema.table from the given file. |
static void |
populateTableFromDir(java.lang.String schema,
java.lang.String tableName,
java.util.List<java.lang.String> columnNames,
java.util.List<java.lang.String> columnTypes,
java.lang.String dirPath,
int nReducer)
Populates the given schema.table from the given directory. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public HadoopPostgreSQLPopulator()
Method Detail |
---|
public static void dumpTableToHDFS(java.lang.String schema, java.lang.String tableName, int nColumn, java.lang.String filePath)
schema
- tableName
- nColumn
- filePath
- public static void createAndPopulateTable(java.lang.String schema, java.lang.String tableName, java.util.List<java.lang.String> columnNames, java.util.List<java.lang.String> columnTypes, java.lang.String filePath) throws java.lang.Exception
schema
- tableName
- columnNames
- columnTypes
- filePath
-
java.lang.Exception
public static void populateTableFromDir(java.lang.String schema, java.lang.String tableName, java.util.List<java.lang.String> columnNames, java.util.List<java.lang.String> columnTypes, java.lang.String dirPath, int nReducer) throws java.lang.Exception
schema
- tableName
- columnNames
- columnTypes
- dirPath
- nReducer
-
java.lang.Exception
public static void createAndPopulateTableFromDir(java.lang.String schema, java.lang.String tableName, java.util.List<java.lang.String> columnNames, java.util.List<java.lang.String> columnTypes, java.lang.String dirPath, int nReducer) throws java.lang.Exception
schema
- tableName
- columnNames
- columnTypes
- dirPath
- nReducer
-
java.lang.Exception
public static void populateTable(java.lang.String schema, java.lang.String tableName, java.util.List<java.lang.String> columnNames, java.util.List<java.lang.String> columnTypes, java.lang.String filePath) throws java.lang.Exception
schema
- tableName
- columnNames
- columnTypes
- filePath
-
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
args
-
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |