IncrementalLoadFromJdbc
public class BulkLoadFromJdbcWithSimpleJoins
extends java.lang.Object
Modifier and Type | Field | Description |
---|---|---|
static
java.text.SimpleDateFormat |
dateFormat |
|
static DataMovementManager |
moveMgr |
Constructor | Description |
---|---|
BulkLoadFromJdbcWithSimpleJoins() |
Modifier and Type | Method | 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 © 2022 MarkLogic Corporation