edu.usc.bg.validator
Class ValidationMainClass

java.lang.Object
  extended by edu.usc.bg.validator.ValidationMainClass

public class ValidationMainClass
extends java.lang.Object


Field Summary
static int bucketDuration
           
static java.lang.String DB_TENANT_PROPERTY
           
static java.lang.String DB_TENANT_PROPERTY_DEFAULT
           
static edu.usc.bg.validator.Bucket[] freshnessBuckets
           
static java.lang.String VALIDATION_APPROACH_PROPERTY
           
static java.lang.String VALIDATION_APPROACH_PROPERTY_DEFAULT
           
static java.lang.String VALIDATION_BLOCK_PROPERTY
           
static java.lang.String VALIDATION_BLOCK_PROPERTY_DEFAULT
           
static java.lang.String VALIDATION_BUCKETS_PROPERTY
           
static java.lang.String VALIDATION_BUCKETS_PROPERTY_DEFAULT
           
static java.lang.String VALIDATION_DBDRIVER_PROPERTY
           
static java.lang.String VALIDATION_DBDRIVER_PROPERTY_DEFAULT
           
static java.lang.String VALIDATION_DBPWD_PROPERTY
           
static java.lang.String VALIDATION_DBPWD_PROPERTY_DEFAULT
           
static java.lang.String VALIDATION_DBURL_PROPERTY
           
static java.lang.String VALIDATION_DBURL_PROPERTY_DEFAULT
           
static java.lang.String VALIDATION_DBUSER_PROPERTY
           
static java.lang.String VALIDATION_DBUSER_PROPERTY_DEFAULT
           
static java.lang.String VALIDATION_THREADS_PROPERTY
           
static java.lang.String VALIDATION_THREADS_PROPERTY_DEFAULT
           
 
Constructor Summary
ValidationMainClass()
           
 
Method Summary
static void buildValidationIndexes(java.util.Properties props)
           
static void createValidationSchema(java.util.Properties props)
           
static void dropIndex(java.sql.Statement st, java.lang.String idxName)
           
static void dropSequence(java.sql.Statement st, java.lang.String seqName)
           
static void dropTable(java.sql.Statement st, java.lang.String tableName)
           
static void dumpFilesAndValidate(java.util.Properties props, java.util.HashMap<java.lang.Integer,java.lang.Integer>[] seqTracker, java.util.HashMap<java.lang.Integer,java.lang.Integer>[] staleSeqTracker, ClientDataStats expStat, java.io.PrintWriter outpS, java.lang.String dir)
           
static void main(java.lang.String[] args)
           
static edu.usc.bg.validator.TotalValidationThreadResults readReadFiles(java.util.Properties props, java.util.concurrent.ConcurrentHashMap<java.lang.String,resourceUpdateStat> updateStats, java.lang.String dir, java.util.HashMap<java.lang.Integer,java.lang.Integer>[] seqTracker, java.util.HashMap<java.lang.String,java.lang.Integer> initCnt, java.util.HashMap<java.lang.Integer,java.lang.Integer>[] staleSeqTracker)
           
static int readUpdateFiles(java.util.Properties props, java.util.concurrent.ConcurrentHashMap<java.lang.String,resourceUpdateStat> updateStats, java.lang.String dir)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DB_TENANT_PROPERTY

public static final java.lang.String DB_TENANT_PROPERTY
See Also:
Constant Field Values

DB_TENANT_PROPERTY_DEFAULT

public static final java.lang.String DB_TENANT_PROPERTY_DEFAULT
See Also:
Constant Field Values

VALIDATION_THREADS_PROPERTY

public static final java.lang.String VALIDATION_THREADS_PROPERTY
See Also:
Constant Field Values

VALIDATION_THREADS_PROPERTY_DEFAULT

public static final java.lang.String VALIDATION_THREADS_PROPERTY_DEFAULT
See Also:
Constant Field Values

VALIDATION_BLOCK_PROPERTY

public static final java.lang.String VALIDATION_BLOCK_PROPERTY
See Also:
Constant Field Values

VALIDATION_BLOCK_PROPERTY_DEFAULT

public static final java.lang.String VALIDATION_BLOCK_PROPERTY_DEFAULT
See Also:
Constant Field Values

VALIDATION_BUCKETS_PROPERTY

public static final java.lang.String VALIDATION_BUCKETS_PROPERTY
See Also:
Constant Field Values

VALIDATION_BUCKETS_PROPERTY_DEFAULT

public static final java.lang.String VALIDATION_BUCKETS_PROPERTY_DEFAULT
See Also:
Constant Field Values

VALIDATION_APPROACH_PROPERTY

public static final java.lang.String VALIDATION_APPROACH_PROPERTY
See Also:
Constant Field Values

VALIDATION_APPROACH_PROPERTY_DEFAULT

public static final java.lang.String VALIDATION_APPROACH_PROPERTY_DEFAULT
See Also:
Constant Field Values

VALIDATION_DBURL_PROPERTY

public static final java.lang.String VALIDATION_DBURL_PROPERTY
See Also:
Constant Field Values

VALIDATION_DBURL_PROPERTY_DEFAULT

public static final java.lang.String VALIDATION_DBURL_PROPERTY_DEFAULT
See Also:
Constant Field Values

VALIDATION_DBUSER_PROPERTY

public static final java.lang.String VALIDATION_DBUSER_PROPERTY
See Also:
Constant Field Values

VALIDATION_DBUSER_PROPERTY_DEFAULT

public static final java.lang.String VALIDATION_DBUSER_PROPERTY_DEFAULT
See Also:
Constant Field Values

VALIDATION_DBPWD_PROPERTY

public static final java.lang.String VALIDATION_DBPWD_PROPERTY
See Also:
Constant Field Values

VALIDATION_DBPWD_PROPERTY_DEFAULT

public static final java.lang.String VALIDATION_DBPWD_PROPERTY_DEFAULT
See Also:
Constant Field Values

VALIDATION_DBDRIVER_PROPERTY

public static final java.lang.String VALIDATION_DBDRIVER_PROPERTY
See Also:
Constant Field Values

VALIDATION_DBDRIVER_PROPERTY_DEFAULT

public static final java.lang.String VALIDATION_DBDRIVER_PROPERTY_DEFAULT
See Also:
Constant Field Values

freshnessBuckets

public static edu.usc.bg.validator.Bucket[] freshnessBuckets

bucketDuration

public static int bucketDuration
Constructor Detail

ValidationMainClass

public ValidationMainClass()
Method Detail

buildValidationIndexes

public static void buildValidationIndexes(java.util.Properties props)

readUpdateFiles

public static int readUpdateFiles(java.util.Properties props,
                                  java.util.concurrent.ConcurrentHashMap<java.lang.String,resourceUpdateStat> updateStats,
                                  java.lang.String dir)

readReadFiles

public static edu.usc.bg.validator.TotalValidationThreadResults readReadFiles(java.util.Properties props,
                                                                              java.util.concurrent.ConcurrentHashMap<java.lang.String,resourceUpdateStat> updateStats,
                                                                              java.lang.String dir,
                                                                              java.util.HashMap<java.lang.Integer,java.lang.Integer>[] seqTracker,
                                                                              java.util.HashMap<java.lang.String,java.lang.Integer> initCnt,
                                                                              java.util.HashMap<java.lang.Integer,java.lang.Integer>[] staleSeqTracker)

dumpFilesAndValidate

public static void dumpFilesAndValidate(java.util.Properties props,
                                        java.util.HashMap<java.lang.Integer,java.lang.Integer>[] seqTracker,
                                        java.util.HashMap<java.lang.Integer,java.lang.Integer>[] staleSeqTracker,
                                        ClientDataStats expStat,
                                        java.io.PrintWriter outpS,
                                        java.lang.String dir)

dropSequence

public static void dropSequence(java.sql.Statement st,
                                java.lang.String seqName)

dropIndex

public static void dropIndex(java.sql.Statement st,
                             java.lang.String idxName)

dropTable

public static void dropTable(java.sql.Statement st,
                             java.lang.String tableName)

createValidationSchema

public static void createValidationSchema(java.util.Properties props)

main

public static void main(java.lang.String[] args)