zeta.tool
Class ZetaReorg

java.lang.Object
  |
  +--zeta.tool.ZetaReorg

public class ZetaReorg

extends java.lang.Object

Field Summary

private java.util.List	bestWorkstation
private int	bestWorkstationIdx
private java.util.Map	bestWorkstationUser
private java.sql.Connection	connection
private long	workUnitIdComplete

Constructor Summary

private

ZetaReorg(java.lang.String user, java.lang.String password)

Method Summary

private void	close()
private java.lang.Object[]	getBestWorkstation(java.sql.Statement stmt, int taskId, int serverId, int workstationId, int userId, int range)
private java.sql.Timestamp	getLastUpdate(java.sql.Statement stmt, int serverId, int workstationId)
private void	hardReorg(int taskId, long maxWorkUnitId, int days, int workstationId, boolean ignoreRange)
static void	main(java.lang.String[] args)
private void	reorg(boolean check)
private void	reorg(int taskId, long workUnitId)
private void	reorg(int taskId, long workUnitId, int userId, int workstationId)
private void	serverReorg(int taskId, long maxWorkUnitId, int days, int workstationId) It is not good to change the server.
private void	updateUsersForRecomputation(java.sql.Statement stmt, int taskId, int serverId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

connection

private java.sql.Connection connection

workUnitIdComplete

private long workUnitIdComplete

bestWorkstation

private java.util.List bestWorkstation

bestWorkstationIdx

private int bestWorkstationIdx

bestWorkstationUser

private java.util.Map bestWorkstationUser

Constructor Detail

ZetaReorg

private ZetaReorg(java.lang.String user,
                  java.lang.String password)
           throws java.lang.Exception

Method Detail

main

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

close

private void close()

hardReorg

private void hardReorg(int taskId,
                       long maxWorkUnitId,
                       int days,
                       int workstationId,
                       boolean ignoreRange)
                throws java.io.IOException,
                       java.sql.SQLException

java.io.IOException

java.sql.SQLException

serverReorg

private void serverReorg(int taskId,
                         long maxWorkUnitId,
                         int days,
                         int workstationId)
                  throws java.io.IOException,
                         java.sql.SQLException

It is not good to change the server. But the results can be computed faster. All server should be well synchronized!!

java.io.IOException

java.sql.SQLException

reorg

private void reorg(int taskId,
                   long workUnitId)
            throws java.io.IOException,
                   java.sql.SQLException

java.io.IOException

java.sql.SQLException

reorg

private void reorg(int taskId,
                   long workUnitId,
                   int userId,
                   int workstationId)
            throws java.io.IOException,
                   java.sql.SQLException

java.io.IOException

java.sql.SQLException

reorg

private void reorg(boolean check)
            throws java.io.IOException,
                   java.sql.SQLException

java.io.IOException

java.sql.SQLException

getBestWorkstation

private java.lang.Object[] getBestWorkstation(java.sql.Statement stmt,
                                              int taskId,
                                              int serverId,
                                              int workstationId,
                                              int userId,
                                              int range)
                                       throws java.sql.SQLException

java.sql.SQLException

getLastUpdate

private java.sql.Timestamp getLastUpdate(java.sql.Statement stmt,
                                         int serverId,
                                         int workstationId)
                                  throws java.sql.SQLException

java.sql.SQLException

updateUsersForRecomputation

private void updateUsersForRecomputation(java.sql.Statement stmt,
                                         int taskId,
                                         int serverId)
                                  throws java.sql.SQLException

java.sql.SQLException