public class BulkLoadFromJdbcWithSimpleJoins
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.text.SimpleDateFormat |
dateFormat |
static DataMovementManager |
moveMgr |
Constructor and Description |
---|
BulkLoadFromJdbcWithSimpleJoins() |
Modifier and Type | Method and Description |
---|---|
void |
addRow(java.sql.ResultSet row,
WriteBatcher wb) |
Employee |
denormalize(Employee newEmployee) |
static void |
main(java.lang.String[] args) |
Employee |
populateEmployee(java.sql.ResultSet row,
Employee e) |
Employee.Salary |
populateSalary(java.sql.ResultSet row,
Employee.Salary s) |
Employee.Title |
populateTitle(java.sql.ResultSet row,
Employee.Title t) |
void |
processEmployee(WriteBatcher wb,
Employee employee) |
void |
run() |
public static final java.text.SimpleDateFormat dateFormat
public static final DataMovementManager moveMgr
public static void main(java.lang.String[] args) throws java.io.IOException, java.sql.SQLException
java.io.IOException
java.sql.SQLException
public Employee populateEmployee(java.sql.ResultSet row, Employee e) throws java.sql.SQLException
java.sql.SQLException
public Employee.Salary populateSalary(java.sql.ResultSet row, Employee.Salary s) throws java.sql.SQLException
java.sql.SQLException
public Employee.Title populateTitle(java.sql.ResultSet row, Employee.Title t) throws java.sql.SQLException
java.sql.SQLException
public void addRow(java.sql.ResultSet row, WriteBatcher wb) throws java.sql.SQLException
java.sql.SQLException
public void processEmployee(WriteBatcher wb, Employee employee)
public void run() throws java.io.IOException, java.sql.SQLException
java.io.IOException
java.sql.SQLException
Copyright © 2013-2018 MarkLogic Corporation.