public class GcTableSync extends Object
Constructor and Description |
---|
GcTableSync() |
Modifier and Type | Method and Description |
---|---|
void |
configureTableSync() |
GcTableSyncOutput |
fullSync() |
String |
getDatabaseFrom()
database from key
|
String |
getDatabaseTo()
database to key
|
GcTableSyncTableData |
getFromData()
data in the from table
|
List<Object> |
getFromGroupingUniqueValues()
grouping unique vals from source
|
int |
getFullSyncHourEnd()
grouperClient.syncTable.personSource.fullSyncHourEnd = 4
|
int |
getFullSyncHourStart()
grouperClient.syncTable.personSource.fullSyncHourStart = 3
|
int |
getGroupingSize() |
String |
getKey()
key in config that points to this instance of table sync
|
String |
getRealTimeSchema()
schema where real time table is.
|
String |
getRealTimeTable()
table where real time primary key and last_updated col is
|
String |
getStatusDatabase() |
String |
getStatusSchema()
grouperClient.syncTable.personSource.statusSchema =
|
String |
getStatusTable()
grouperClient.syncTable.personSource.statusTable = grouper_chance_log_consumer
|
GcTableSyncTableMetadata |
getTableMetadata() |
GcTableSyncTableData |
getToData()
data in the to table
|
Set<Object> |
getToGroupingUniqueValues()
grouping unique vals to source
|
GcTableSyncOutput |
incrementalSync() |
void |
logPeriodically(Map<String,Object> debugMap)
log periodically
|
static void |
main(String[] args) |
void |
processDatabaseColumnMetadata() |
void |
retrieveDataBatchFromDb(String dbName,
List<Object> bindVars,
String sql,
List<GcTableSyncRowData> dataReturnedHere,
GcTableSyncTableData gcTableSyncTableData) |
void |
selectStuffTest() |
void |
setDatabaseFrom(String databaseFrom1)
database from key
|
void |
setDatabaseTo(String databaseTo1)
database to key
|
void |
setFromData(GcTableSyncTableData fromData1)
data in the from table
|
void |
setFromGroupingUniqueValues(List<Object> fromGroupingUniqueValues1)
grouping unique vals from source
|
void |
setFullSyncHourEnd(int fullSyncHourEnd1) |
void |
setFullSyncHourStart(int fullSyncHourStart1)
grouperClient.syncTable.personSource.fullSyncHourStart = 3
|
void |
setGroupingSize(int groupingSize1) |
void |
setKey(String key1)
key in config that points to this instance of table sync
|
void |
setRealTimeSchema(String realTimeSchema1)
schema where real time table is.
|
void |
setRealTimeTable(String realTimeTable1)
table where real time primary key and last_updated col is
|
void |
setStatusDatabase(String statusDatabase1)
grouperClient.syncTable.personSource.statusDatabase = awsDev
|
void |
setStatusSchema(String statusSchema1)
grouperClient.syncTable.personSource.statusSchema =
|
void |
setStatusTable(String statusTable1)
grouperClient.syncTable.personSource.statusTable = grouper_chance_log_consumer
|
void |
setTableMetadata(GcTableSyncTableMetadata tableMetadata1) |
void |
setToData(GcTableSyncTableData toData1)
data in the to table
|
void |
setToGroupingUniqueValues(Set<Object> toGroupingUniqueValues1)
grouping unique vals to source
|
void |
sqlBatchAdd(Map<String,List<List<Object>>> sqlBatch,
String sql,
List<Object> args)
sql batch add
|
List<Integer> |
sqlBatchExecute(Map<String,List<List<Object>>> sqlBatch,
String sqlPrefix,
Map<String,Object> debugMap)
execute a batch, return the count
|
void |
statusAssignLastUpdated(String type,
long lastUpdated) |
boolean |
statusIsFullRunning(Map<String,Object> debugMap) |
Long |
statusRetrieveLastUpdated(String type)
type is
|
public String getKey()
public void setKey(String key1)
key1
- the key to setpublic GcTableSyncTableMetadata getTableMetadata()
public void setTableMetadata(GcTableSyncTableMetadata tableMetadata1)
tableMetadata1
- the tableMetadata to setpublic GcTableSyncTableData getFromData()
public void setFromData(GcTableSyncTableData fromData1)
fromData1
- the fromData to setpublic GcTableSyncTableData getToData()
public void setToData(GcTableSyncTableData toData1)
toData1
- the toData to setpublic boolean statusIsFullRunning(Map<String,Object> debugMap)
debugMap
- public GcTableSyncOutput incrementalSync()
public Long statusRetrieveLastUpdated(String type)
type
- full or incrementalpublic void statusAssignLastUpdated(String type, long lastUpdated)
type
- lastUpdated
- public GcTableSyncOutput fullSync()
public void logPeriodically(Map<String,Object> debugMap)
debugMap
- public void retrieveDataBatchFromDb(String dbName, List<Object> bindVars, String sql, List<GcTableSyncRowData> dataReturnedHere, GcTableSyncTableData gcTableSyncTableData)
dbName
- bindVars
- sql
- dataReturnedHere
- gcTableSyncTableData
- public void configureTableSync()
public String getRealTimeSchema()
public void setRealTimeSchema(String realTimeSchema1)
realTimeSchema1
- the realTimeSchema to setpublic String getRealTimeTable()
public void setRealTimeTable(String realTimeTable1)
realTimeTable1
- the realTimeTable to setpublic String getStatusDatabase()
public void setStatusDatabase(String statusDatabase1)
statusDatabase1
- the statusDatabase to setpublic String getStatusSchema()
public void setStatusSchema(String statusSchema1)
statusSchema1
- the statusSchema to setpublic String getStatusTable()
public void setStatusTable(String statusTable1)
statusTable1
- the statusTable to setpublic int getFullSyncHourStart()
public void setFullSyncHourStart(int fullSyncHourStart1)
fullSyncHourStart1
- the fullSyncHourStart to setpublic int getFullSyncHourEnd()
public void setFullSyncHourEnd(int fullSyncHourEnd1)
fullSyncHourEnd1
- the fullSyncHourEnd to setpublic List<Object> getFromGroupingUniqueValues()
public void setFromGroupingUniqueValues(List<Object> fromGroupingUniqueValues1)
fromGroupingUniqueValues1
- the fromGroupingUniqueValues to setpublic Set<Object> getToGroupingUniqueValues()
public void setToGroupingUniqueValues(Set<Object> toGroupingUniqueValues1)
toGroupingUniqueValues1
- the toGroupingUniqueValues to setpublic void processDatabaseColumnMetadata()
public void sqlBatchAdd(Map<String,List<List<Object>>> sqlBatch, String sql, List<Object> args)
sqlBatch
- sql
- args
- public List<Integer> sqlBatchExecute(Map<String,List<List<Object>>> sqlBatch, String sqlPrefix, Map<String,Object> debugMap)
sqlBatch
- sqlPrefix
- if we only want to run a certain prefixdebugMap
- public String getDatabaseTo()
public void setDatabaseTo(String databaseTo1)
databaseTo1
- the databaseTo to setpublic String getDatabaseFrom()
public void setDatabaseFrom(String databaseFrom1)
databaseFrom1
- the databaseFrom to setpublic int getGroupingSize()
public void setGroupingSize(int groupingSize1)
groupingSize1
- the groupingSize to setpublic static void main(String[] args)
args
- public void selectStuffTest()
Copyright © 2016 Internet2. All rights reserved.