public class GcTableSyncConfiguration extends Object
Constructor and Description |
---|
GcTableSyncConfiguration() |
Modifier and Type | Method and Description |
---|---|
void |
configureTableSync(Map<String,Object> debugMap,
GcTableSync theGcTableSync,
String theConfigKey,
GcTableSyncSubtype theGcTableSyncSubtype) |
int |
getBatchSize()
batch size when batching data
|
String |
getChangeFlagColumnString()
if doing fullSyncChangeFlag (look for a col that says if the rows are equal, e.g.
|
String |
getColumnsString()
all columns, could be * which means all, or list of comma separated values, default to *
|
String |
getConfigKey()
key in config that points to this instance of table sync
|
String |
getDatabaseFrom()
database from key
|
String |
getDatabaseTo()
database to key
|
String |
getDatabaseToOrReadonly()
database to or readonly
|
String |
getDatabaseToReadonly()
database to key (readonly) if large queries should be performed against a different database
|
GcTableSync |
getGcTableSync()
gc table sync
|
GcTableSyncSubtype |
getGcTableSyncSubtype()
subtype which also implies which type (full | incremental)
|
String |
getGroupColumnString()
group column
|
int |
getGroupingSize() |
String |
getIncrementalAllColumnsColumnString()
name of a column in "FROM" table that has a sequence or last updated date
|
String |
getIncrementalPrimaryKeyTable()
table where real time primary key and last_updated col is
|
String |
getIncrementalProgressColumnString()
name of a column that has a sequence or last updated date
|
int |
getMaxBindVarsInSelect()
number of bind vars in select
|
String |
getPrimaryKeyColumnsString()
primary key columns, * means all columns, or list of comma separated values, default to *
|
String |
getStatusDatabase() |
int |
getSwitchFromIncrementalToFullIfOverGroupCount()
switch from incremental to full if the number of groups (and records over threshold) is over this threshold
i.e.
|
int |
getSwitchFromIncrementalToFullIfOverRecords()
switch from incremental to full if the number of incrementals is over this threshold
|
GcTableSyncSubtype |
getSwitchFromIncrementalToFullSubtype()
switch from incremental to full if the number of incrementals is over the threshold, this is full sync to switch to
fullSyncChangeFlag, fullSyncFull, fullSyncGroups
|
int |
getSwitchFromIncrementalToGroupIfOverRecordsInGroup()
switch from incremental to group (if theres a grouping col) if the number of incrementals for a certain group
|
String |
getTableFrom()
table name from
|
String |
getTableTo()
table name to
|
boolean |
isEnabled() |
Boolean |
retrieveConfigBoolean(String configName,
boolean required)
get a config name for this or dependency
|
Integer |
retrieveConfigInt(String configName,
boolean required)
get a config name for this or dependency
|
String |
retrieveConfigString(String configName,
boolean required)
get a config name for this or dependency
|
void |
setBatchSize(int batchSize1)
batch size when batching data
|
void |
setChangeFlagColumnString(String fullSyncChangeFlagColumnString1)
if doing fullSyncChangeFlag (look for a col that says if the rows are equal, e.g.
|
void |
setColumnsString(String columnsString1)
all columns, could be * which means all, or list of comma separated values, default to *
|
void |
setConfigKey(String key1)
key in config that points to this instance of table sync
|
void |
setDatabaseFrom(String databaseFrom1)
database from key
|
void |
setDatabaseTo(String databaseTo1)
database to key
|
void |
setDatabaseToReadonly(String databaseToReadonly1)
database to key (readonly) if large queries should be performed against a different database
|
void |
setEnabled(boolean enabled) |
void |
setGcTableSync(GcTableSync gcTableSync1)
gc table sync
|
void |
setGcTableSyncSubtype(GcTableSyncSubtype gcTableSyncSubtype1)
subtype which also implies which type (full | incremental)
|
void |
setGroupColumnString(String groupColumn1) |
void |
setGroupingSize(int groupSize1) |
void |
setIncrementalAllColumnsColumnString(String incrementalAllColumnsColumnString1)
name of a column in "FROM" table that has a sequence or last updated date
|
void |
setIncrementalPrimaryKeyTable(String realTimeTable1)
table where real time primary key and last_updated col is
|
void |
setIncrementalProgressColumnString(String incrementalAllColumnsColumnString1)
name of a column that has a sequence or last updated date
|
void |
setMaxBindVarsInSelect(int maxBindVarsInSelect1) |
void |
setPrimaryKeyColumnsString(String primaryKeyColumnsString1)
primary key columns, * means all columns, or list of comma separated values, default to *
|
void |
setStatusDatabase(String statusDatabase1)
grouperClient.syncTable.personSource.statusDatabase = awsDev
|
void |
setSwitchFromIncrementalToFullIfOverGroupCount(int switchFromIncrementalToFullIfOverGroupCount1)
switch from incremental to full if the number of groups (and records over threshold) is over this threshold
i.e.
|
void |
setSwitchFromIncrementalToFullIfOverRecords(int switchFromIncrementalToFullIfOverRecords1)
switch from incremental to full if the number of incrementals is over this threshold
|
void |
setSwitchFromIncrementalToFullSubtype(GcTableSyncSubtype switchFromIncrementalToFullSubtype1)
switch from incremental to full if the number of incrementals is over the threshold, this is full sync to switch to
fullSyncChangeFlag, fullSyncFull, fullSyncGroups
|
void |
setSwitchFromIncrementalToGroupIfOverRecordsInGroup(int switchFromIncrementalToGroupIfOverRecordsInGroup1)
switch from incremental to group (if theres a grouping col) if the number of incrementals for a certain group
|
void |
setTableFrom(String tableName1)
table name from
|
void |
setTableTo(String tableNameTo1)
table name to
|
public boolean isEnabled()
public void setEnabled(boolean enabled)
public String getDatabaseFrom()
public String getDatabaseTo()
public String getDatabaseToReadonly()
public String getDatabaseToOrReadonly()
public void setDatabaseToReadonly(String databaseToReadonly1)
databaseToReadonly1
- the databaseToReadonly to setpublic GcTableSyncSubtype getGcTableSyncSubtype()
public void setGcTableSyncSubtype(GcTableSyncSubtype gcTableSyncSubtype1)
gcTableSyncSubtype1
- the gcTableSyncSubtype to setpublic int getMaxBindVarsInSelect()
public void setMaxBindVarsInSelect(int maxBindVarsInSelect1)
maxBindVarsInSelect1
- public int getBatchSize()
public void setBatchSize(int batchSize1)
batchSize1
- the batchSize to setpublic int getGroupingSize()
public String getChangeFlagColumnString()
public void setChangeFlagColumnString(String fullSyncChangeFlagColumnString1)
fullSyncChangeFlagColumnString1
- public String getIncrementalProgressColumnString()
public void setIncrementalProgressColumnString(String incrementalAllColumnsColumnString1)
incrementalAllColumnsColumnString1
- public Integer retrieveConfigInt(String configName, boolean required)
configName
- required
- public Boolean retrieveConfigBoolean(String configName, boolean required)
configName
- required
- public String retrieveConfigString(String configName, boolean required)
configName
- required
- public String getIncrementalAllColumnsColumnString()
public void setIncrementalAllColumnsColumnString(String incrementalAllColumnsColumnString1)
incrementalAllColumnsColumnString1
- public String getPrimaryKeyColumnsString()
public void setPrimaryKeyColumnsString(String primaryKeyColumnsString1)
primaryKeyColumnsString1
- the primaryKeyColumnsString to setpublic String getColumnsString()
public void setColumnsString(String columnsString1)
columnsString1
- the columnsString to setpublic GcTableSync getGcTableSync()
public void setGcTableSync(GcTableSync gcTableSync1)
gcTableSync1
- public void configureTableSync(Map<String,Object> debugMap, GcTableSync theGcTableSync, String theConfigKey, GcTableSyncSubtype theGcTableSyncSubtype)
debugMap
- configKey
- gcTableSyncSubtype
- public int getSwitchFromIncrementalToFullIfOverGroupCount()
public void setSwitchFromIncrementalToFullIfOverGroupCount(int switchFromIncrementalToFullIfOverGroupCount1)
switchFromIncrementalToFullIfOverGroupCount1
- public int getSwitchFromIncrementalToGroupIfOverRecordsInGroup()
public void setSwitchFromIncrementalToGroupIfOverRecordsInGroup(int switchFromIncrementalToGroupIfOverRecordsInGroup1)
switchFromIncrementalToGroupIfOverRecordsInGroup1
- public GcTableSyncSubtype getSwitchFromIncrementalToFullSubtype()
public void setSwitchFromIncrementalToFullSubtype(GcTableSyncSubtype switchFromIncrementalToFullSubtype1)
switchFromIncrementalToFullSubtype1
- public int getSwitchFromIncrementalToFullIfOverRecords()
public void setSwitchFromIncrementalToFullIfOverRecords(int switchFromIncrementalToFullIfOverRecords1)
switchFromIncrementalToFullIfOverRecords1
- public String getConfigKey()
public String getIncrementalPrimaryKeyTable()
public String getStatusDatabase()
public String getTableFrom()
public String getTableTo()
public String getGroupColumnString()
public void setDatabaseFrom(String databaseFrom1)
databaseFrom1
- the databaseFrom to setpublic void setDatabaseTo(String databaseTo1)
databaseTo1
- the databaseTo to setpublic void setGroupColumnString(String groupColumn1)
groupColumn1
- the groupColumn to setpublic void setGroupingSize(int groupSize1)
groupSize1
- the groupSize to setpublic void setConfigKey(String key1)
key1
- the key to setpublic void setIncrementalPrimaryKeyTable(String realTimeTable1)
realTimeTable1
- the realTimeTable to setpublic void setStatusDatabase(String statusDatabase1)
statusDatabase1
- the statusDatabase to setpublic void setTableFrom(String tableName1)
tableName1
- the tableName to setpublic void setTableTo(String tableNameTo1)
tableNameTo1
- the tableNameTo to setCopyright © 2016 Internet2. All rights reserved.