Updated OperationMonitor
git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/portlets/user/tabular-data-gwt-service@99240 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
parent
29584b59c7
commit
b1460ad4e8
|
|
@ -7,9 +7,7 @@ import java.util.ArrayList;
|
|||
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.codelisthelper.CodelistMappingSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.AvailableCharsetList;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVExportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVExportSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVImportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVImportSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CheckCSVSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.exception.TDGWTServiceException;
|
||||
|
|
@ -18,33 +16,9 @@ import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadMonitor;
|
|||
import org.gcube.portlets.user.td.gwtservice.shared.file.HeaderPresence;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.history.OpHistory;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.history.RollBackSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.AddColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.ChangeTableTypeMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.CloneMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.CodelistMappingMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.DeleteColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.DeleteRowsMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.DenormalizationMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.DuplicatesMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.EditRowMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.ExtractCodelistMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.GroupByMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.LabelColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.MergeColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.NormalizationMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.OperationMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.OperationMonitorSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.ReplaceBatchColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.ReplaceColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.RollBackSessionMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.SplitColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.TaskResubmitMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.TaskResumeMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.TemplateApplyMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.UnionMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.sdmx.SDMXExportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.sdmx.SDMXExportSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.sdmx.SDMXImportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.sdmx.SDMXImportSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.share.ShareInfo;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.source.SDMXRegistrySource;
|
||||
|
|
@ -66,7 +40,6 @@ import org.gcube.portlets.user.td.gwtservice.shared.tr.column.AddColumnSession;
|
|||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.DeleteColumnSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.LabelColumnSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.ReplaceColumnSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.type.ChangeColumnTypeMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.type.ChangeColumnTypeSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.metadata.TRMetadata;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.normalization.DenormalizationSession;
|
||||
|
|
@ -238,40 +211,24 @@ public interface TDGWTService extends RemoteService {
|
|||
throws TDGWTServiceException;
|
||||
|
||||
// Task
|
||||
/**
|
||||
* Get Operation Monitor during the resubmit task
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public TaskResubmitMonitor getTaskResubmitMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Resubmit task
|
||||
*
|
||||
* @param taskResubmitSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startTaskResubmit(TaskResubmitSession taskResubmitSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the resume task
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public TaskResumeMonitor getTaskResumeMonitor()
|
||||
public String startTaskResubmit(TaskResubmitSession taskResubmitSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Resume task
|
||||
*
|
||||
* @param taskResumeSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startTaskResume(TaskResumeSession taskResumeSession)
|
||||
public String startTaskResume(TaskResumeSession taskResumeSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Validations
|
||||
|
|
@ -314,16 +271,7 @@ public interface TDGWTService extends RemoteService {
|
|||
* @param rollBackSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void rollBack(RollBackSession rollBackSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the rollback
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public RollBackSessionMonitor getRollBackMonitor()
|
||||
public String startRollBack(RollBackSession rollBackSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
|
|
@ -377,22 +325,14 @@ public interface TDGWTService extends RemoteService {
|
|||
/**
|
||||
* Start clone tabular resource
|
||||
*
|
||||
* @param labelColumnSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startCloneTabularResource(
|
||||
CloneTabularResourceSession cloneTabularResourceSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Clone operation
|
||||
*
|
||||
* @param cloneTabularResourceSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public CloneMonitor getCloneMonitor() throws TDGWTServiceException;
|
||||
|
||||
|
||||
public String startCloneTabularResource(
|
||||
CloneTabularResourceSession cloneTabularResourceSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
//
|
||||
/**
|
||||
* Initialize Codelists Paging Loader
|
||||
|
|
@ -418,7 +358,7 @@ public interface TDGWTService extends RemoteService {
|
|||
* @param s
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startTDOpen(TDOpenSession tdOpenSession)
|
||||
public void tdOpen(TDOpenSession tdOpenSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
|
|
@ -513,31 +453,14 @@ public interface TDGWTService extends RemoteService {
|
|||
/**
|
||||
* Start SDMX Import and invokes the client library
|
||||
*
|
||||
* @param s
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startSDMXImport(SDMXImportSession sdmxImportSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the SDMX Import operation
|
||||
*
|
||||
* @param sdmxImportSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public SDMXImportMonitor getSDMXImportMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Import CSV
|
||||
/**
|
||||
* Get File Upload Monitor during the file upload operation in Import CSV
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public FileUploadMonitor getFileUploadMonitor()
|
||||
public String startSDMXImport(SDMXImportSession sdmxImportSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// CSV Import
|
||||
/**
|
||||
*
|
||||
* @param s
|
||||
|
|
@ -590,238 +513,140 @@ public interface TDGWTService extends RemoteService {
|
|||
* @param s
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startCSVImport(CSVImportSession csvImportSession)
|
||||
public String startCSVImport(CSVImportSession csvImportSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the CSV Import operation
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public CSVImportMonitor getCSVImportMonitor() throws TDGWTServiceException;
|
||||
|
||||
|
||||
// Export CSV
|
||||
/**
|
||||
* Get Operation Monitor during the CSV Export operation
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public CSVExportMonitor getCSVExportMonitor() throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Start CSV Export and invokes the client library
|
||||
*
|
||||
* @param csvExportSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startCSVExport(CSVExportSession csvExportSession)
|
||||
public String startCSVExport(CSVExportSession csvExportSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Export SDMX
|
||||
/**
|
||||
* Get Operation Monitor during the SDMX Export operation
|
||||
* Start SDMX Export and invokes the client library
|
||||
*
|
||||
* @param exportSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public SDMXExportMonitor getSDMXExportMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Start SDMX Export and invokes the client library
|
||||
*
|
||||
* @param sdmxExportSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startSDMXExport(SDMXExportSession exportSession)
|
||||
public String startSDMXExport(SDMXExportSession exportSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Table Operations
|
||||
/**
|
||||
* Get Operation Monitor during the Change Table Type operation
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public ChangeTableTypeMonitor getChangeTableTypeMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start change table type
|
||||
*
|
||||
* @param labelColumnSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startChangeTableType(
|
||||
ChangeTableTypeSession changeTableTypeSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the union operation
|
||||
*
|
||||
* @param changeTableTypeSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public UnionMonitor getUnionMonitor() throws TDGWTServiceException;
|
||||
public String startChangeTableType(
|
||||
ChangeTableTypeSession changeTableTypeSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start Union and invokes the client library
|
||||
*
|
||||
* @param unionSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startUnion(UnionSession unionSession)
|
||||
public String startUnion(UnionSession unionSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Rows Operations
|
||||
/**
|
||||
* Get Operation Monitor during the Edit Row operation
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public EditRowMonitor getEditRowMonitor() throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Start edit row or add row
|
||||
*
|
||||
* @param labelColumnSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startEditRow(EditRowSession editRowSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Delete Rows operation
|
||||
*
|
||||
*
|
||||
* @param editRowSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public DeleteRowsMonitor getDeleteRowsMonitor()
|
||||
public String startEditRow(EditRowSession editRowSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start delete rows
|
||||
*
|
||||
* @param labelColumnSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startDeleteRows(DeleteRowsSession deleteRowsSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the operation on duplicates
|
||||
*
|
||||
*
|
||||
* @param deleteRowsSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public DuplicatesMonitor getDuplicatesMonitor()
|
||||
public String startDeleteRows(DeleteRowsSession deleteRowsSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Start operation on duplicates
|
||||
*
|
||||
* @param labelColumnSession
|
||||
* @param duplicatesSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startDuplicates(DuplicatesSession duplicatesSession)
|
||||
public String startDuplicates(DuplicatesSession duplicatesSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Column Operation
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Change Column Type operation
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public ChangeColumnTypeMonitor getChangeColumnTypeMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start change column type
|
||||
*
|
||||
*
|
||||
* @param changeColumnTypeSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startChangeColumnType(
|
||||
public String startChangeColumnType(
|
||||
ChangeColumnTypeSession changeColumnTypeSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Add Column operation
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public AddColumnMonitor getAddColumnMonitor() throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start add column
|
||||
*
|
||||
*
|
||||
*
|
||||
* @param addColumnSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startAddColumn(AddColumnSession addColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Delete Column operation
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public DeleteColumnMonitor getDeleteColumnMonitor()
|
||||
public String startAddColumn(AddColumnSession addColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start delete column
|
||||
*
|
||||
*
|
||||
* @param deleteColumnSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startDeleteColumn(DeleteColumnSession deleteColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Change the Column Label operation
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public LabelColumnMonitor getLabelColumnMonitor()
|
||||
public String startDeleteColumn(DeleteColumnSession deleteColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Start change the column label
|
||||
*
|
||||
* @param labelColumnSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startLabelColumn(LabelColumnSession labelColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Split Column operation
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public SplitColumnMonitor getSplitColumnMonitor()
|
||||
public String startLabelColumn(LabelColumnSession labelColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Start split column
|
||||
*
|
||||
|
|
@ -832,16 +657,8 @@ public interface TDGWTService extends RemoteService {
|
|||
* splitColumnSession) throws TDGWTServiceException;
|
||||
*/
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Merge Column operation
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public MergeColumnMonitor getMergeColumnMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Start merge column
|
||||
*
|
||||
|
|
@ -852,14 +669,7 @@ public interface TDGWTService extends RemoteService {
|
|||
* mergeColumnSession) throws TDGWTServiceException;
|
||||
*/
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the Group By operation
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public GroupByMonitor getGroupByMonitor() throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start group by
|
||||
|
|
@ -884,44 +694,27 @@ public interface TDGWTService extends RemoteService {
|
|||
OccurrencesForReplaceBatchColumnSession occurrencesForReplaceBatchColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during the batch replace on column
|
||||
*
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public ReplaceBatchColumnMonitor getReplaceBatchColumnMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start batch replace on column
|
||||
*
|
||||
* @param replaceBatchColumnSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startReplaceBatchColumn(
|
||||
public String startReplaceBatchColumn(
|
||||
ReplaceBatchColumnSession replaceBatchColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Replace Operation
|
||||
/**
|
||||
* Get Operation Monitor during the replace the Column Value operation
|
||||
*
|
||||
* Start replace the column value
|
||||
*
|
||||
* @param replaceColumnSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public ReplaceColumnMonitor getReplaceColumnMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Start replace the column value
|
||||
*
|
||||
* @param labelColumnSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startReplaceColumn(ReplaceColumnSession replaceColumnSession)
|
||||
public String startReplaceColumn(ReplaceColumnSession replaceColumnSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Templates
|
||||
|
|
@ -934,22 +727,16 @@ public interface TDGWTService extends RemoteService {
|
|||
*/
|
||||
public ArrayList<TemplateData> getTemplates() throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Get Operation Monitor during Apply Template operation
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public TemplateApplyMonitor getTemplateApplyMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
* Start Apply Template
|
||||
*
|
||||
* @param templateApplySession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
void startTemplateApply(TemplateApplySession templateApplySession)
|
||||
public String startTemplateApply(TemplateApplySession templateApplySession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
|
|
@ -958,7 +745,7 @@ public interface TDGWTService extends RemoteService {
|
|||
* @param templateDeleteSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
void startTemplateDelete(TemplateDeleteSession templateDeleteSession)
|
||||
public void templateDelete(TemplateDeleteSession templateDeleteSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Locales
|
||||
|
|
@ -968,7 +755,7 @@ public interface TDGWTService extends RemoteService {
|
|||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
ArrayList<String> getLocales() throws TDGWTServiceException;
|
||||
public ArrayList<String> getLocales() throws TDGWTServiceException;
|
||||
|
||||
// History
|
||||
/**
|
||||
|
|
@ -977,7 +764,7 @@ public interface TDGWTService extends RemoteService {
|
|||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
ArrayList<OpHistory> getHistory() throws TDGWTServiceException;
|
||||
public ArrayList<OpHistory> getHistory() throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Retrieve History for specific tabular resource
|
||||
|
|
@ -986,14 +773,15 @@ public interface TDGWTService extends RemoteService {
|
|||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
ArrayList<OpHistory> getHistory(TRId trId) throws TDGWTServiceException;
|
||||
public ArrayList<OpHistory> getHistory(TRId trId)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
OpHistory getLastOperationInfo() throws TDGWTServiceException;
|
||||
public OpHistory getLastOperationInfo() throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
*
|
||||
|
|
@ -1001,92 +789,96 @@ public interface TDGWTService extends RemoteService {
|
|||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
OpHistory getLastOperationInfo(TRId trId) throws TDGWTServiceException;
|
||||
public OpHistory getLastOperationInfo(TRId trId)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Helper Extract Codelist
|
||||
/**
|
||||
* Get Operation Monitor during the Extract Codelist operation
|
||||
* Start Extract Codelist and invokes the client library
|
||||
*
|
||||
*
|
||||
* @param extractCodelistSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public ExtractCodelistMonitor getExtractCodelistMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Start Extract Codelist and invokes the client library
|
||||
*
|
||||
* @param extractCodelistSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startExtractCodelist(
|
||||
public String startExtractCodelist(
|
||||
ExtractCodelistSession extractCodelistSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Helper Codelist Mapping Import
|
||||
public CodelistMappingMonitor getCodelistMappingMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
*
|
||||
* @param codelistMappingSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void setCodelistMappingSession(
|
||||
CodelistMappingSession codelistMappingSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @param codelistMappingSession
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void getFileFromWorkspace(
|
||||
CodelistMappingSession codelistMappingSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
public void startCodelistMappingImport(
|
||||
|
||||
/**
|
||||
* Start Codelist Mapping Import
|
||||
*
|
||||
* @param codelistMappingSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public String startCodelistMappingImport(
|
||||
CodelistMappingSession codelistMappingSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Normalization
|
||||
/**
|
||||
* Get Operation Monitor during the Normalization operation
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public NormalizationMonitor getNormalizationMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Start Normalization and invokes the client library
|
||||
*
|
||||
* @param normalizationSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startNormalization(NormalizationSession normalizationSession)
|
||||
public String startNormalization(NormalizationSession normalizationSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// Denormalization
|
||||
/**
|
||||
* Get Operation Monitor during the denormalization operation
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public DenormalizationMonitor getDenormalizationMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
/**
|
||||
* Start Denormalization and invokes the client library
|
||||
*
|
||||
*
|
||||
* @param denormalizationSession
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public void startDenormalization(
|
||||
public String startDenormalization(
|
||||
DenormalizationSession denormalizationSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
|
||||
|
||||
// Operation Monitor
|
||||
/**
|
||||
* Get Operation Monitor
|
||||
* Get Operation Monitor
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public OperationMonitor getOperationMonitor(OperationMonitorSession operationMonitorSession)
|
||||
public OperationMonitor getOperationMonitor(
|
||||
OperationMonitorSession operationMonitorSession)
|
||||
throws TDGWTServiceException;
|
||||
|
||||
// File Upload Monitor
|
||||
/**
|
||||
* Get File Upload Monitor during the file upload operation in Import CSV
|
||||
*
|
||||
* @return
|
||||
* @throws TDGWTServiceException
|
||||
*/
|
||||
public FileUploadMonitor getFileUploadMonitor()
|
||||
throws TDGWTServiceException;
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -7,9 +7,7 @@ import java.util.ArrayList;
|
|||
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.codelisthelper.CodelistMappingSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.AvailableCharsetList;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVExportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVExportSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVImportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVImportSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CheckCSVSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.extract.ExtractCodelistSession;
|
||||
|
|
@ -17,33 +15,9 @@ import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadMonitor;
|
|||
import org.gcube.portlets.user.td.gwtservice.shared.file.HeaderPresence;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.history.OpHistory;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.history.RollBackSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.AddColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.ChangeTableTypeMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.CloneMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.CodelistMappingMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.DeleteColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.DeleteRowsMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.DenormalizationMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.DuplicatesMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.EditRowMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.ExtractCodelistMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.GroupByMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.LabelColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.MergeColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.OperationMonitorSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.NormalizationMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.OperationMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.ReplaceBatchColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.ReplaceColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.RollBackSessionMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.SplitColumnMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.TaskResubmitMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.TaskResumeMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.TemplateApplyMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.UnionMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.sdmx.SDMXExportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.OperationMonitorSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.sdmx.SDMXExportSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.sdmx.SDMXImportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.sdmx.SDMXImportSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.share.ShareInfo;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.source.SDMXRegistrySource;
|
||||
|
|
@ -65,7 +39,6 @@ import org.gcube.portlets.user.td.gwtservice.shared.tr.column.AddColumnSession;
|
|||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.DeleteColumnSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.LabelColumnSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.ReplaceColumnSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.type.ChangeColumnTypeMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.column.type.ChangeColumnTypeSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.metadata.TRMetadata;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.tr.normalization.DenormalizationSession;
|
||||
|
|
@ -126,10 +99,8 @@ public interface TDGWTServiceAsync {
|
|||
void getConnection(RefColumn refColumn, AsyncCallback<ColumnData> callback);
|
||||
|
||||
//Task
|
||||
void getTaskResubmitMonitor(AsyncCallback<TaskResubmitMonitor> callback);
|
||||
void startTaskResubmit(TaskResubmitSession taskResubmitSession,AsyncCallback<Void> callback);
|
||||
void getTaskResumeMonitor(AsyncCallback<TaskResumeMonitor> callback);
|
||||
void startTaskResume(TaskResumeSession taskResumeSession,AsyncCallback<Void> callback);
|
||||
void startTaskResubmit(TaskResubmitSession taskResubmitSession,AsyncCallback<String> callback);
|
||||
void startTaskResume(TaskResumeSession taskResumeSession,AsyncCallback<String> callback);
|
||||
|
||||
|
||||
//Validations
|
||||
|
|
@ -139,8 +110,7 @@ public interface TDGWTServiceAsync {
|
|||
|
||||
|
||||
//RollBack
|
||||
void rollBack(RollBackSession rollBackSession,AsyncCallback<Void> callback);
|
||||
void getRollBackMonitor(AsyncCallback<RollBackSessionMonitor> callback);
|
||||
void startRollBack(RollBackSession rollBackSession,AsyncCallback<String> callback);
|
||||
void discard(TRId trId,AsyncCallback<RollBackSession> callback);
|
||||
|
||||
//Share
|
||||
|
|
@ -156,11 +126,10 @@ public interface TDGWTServiceAsync {
|
|||
AsyncCallback<CodelistPagingLoadResult> callback);
|
||||
|
||||
//Open
|
||||
void startTDOpen(TDOpenSession tdOpenSession, AsyncCallback<Void> callback);
|
||||
void tdOpen(TDOpenSession tdOpenSession, AsyncCallback<Void> callback);
|
||||
|
||||
//Clone
|
||||
void getCloneMonitor(AsyncCallback<CloneMonitor> callback);
|
||||
void startCloneTabularResource(CloneTabularResourceSession cloneTabularResourceSession, AsyncCallback<Void> callback);
|
||||
String startCloneTabularResource(CloneTabularResourceSession cloneTabularResourceSession, AsyncCallback<String> callback);
|
||||
|
||||
|
||||
//SDMX
|
||||
|
|
@ -173,15 +142,10 @@ public interface TDGWTServiceAsync {
|
|||
void setSDMXRegistrySource(SDMXRegistrySource sdmxRegistrySource, AsyncCallback<Void> callback);
|
||||
|
||||
//Import SDMX
|
||||
void getSDMXImportMonitor(AsyncCallback<SDMXImportMonitor> callback);
|
||||
|
||||
void startSDMXImport(SDMXImportSession sdmxImportSession,AsyncCallback<Void> callback);
|
||||
void startSDMXImport(SDMXImportSession sdmxImportSession,AsyncCallback<String> callback);
|
||||
|
||||
//File Upload Monitor
|
||||
void getFileUploadMonitor(AsyncCallback<FileUploadMonitor> callback);
|
||||
|
||||
//Import CSV
|
||||
void getCSVImportMonitor(AsyncCallback<CSVImportMonitor> callback);
|
||||
|
||||
void setCSVSession(CSVImportSession csvImportSession, AsyncCallback<Void> callback);
|
||||
|
||||
|
|
@ -193,70 +157,48 @@ public interface TDGWTServiceAsync {
|
|||
|
||||
void checkCSV(long errorsLimit, AsyncCallback<CheckCSVSession> callback);
|
||||
|
||||
void startCSVImport(CSVImportSession csvImportSession, AsyncCallback<Void> callback);
|
||||
void startCSVImport(CSVImportSession csvImportSession, AsyncCallback<String> callback);
|
||||
|
||||
//Export CSV
|
||||
void getCSVExportMonitor(AsyncCallback<CSVExportMonitor> callback);
|
||||
|
||||
void startCSVExport(CSVExportSession csvExportSession, AsyncCallback<Void> callback);
|
||||
void startCSVExport(CSVExportSession csvExportSession, AsyncCallback<String> callback);
|
||||
|
||||
//Export SDMX
|
||||
void getSDMXExportMonitor(AsyncCallback<SDMXExportMonitor> callback);
|
||||
void startSDMXExport(SDMXExportSession exportSession, AsyncCallback<Void> callback);
|
||||
void startSDMXExport(SDMXExportSession exportSession, AsyncCallback<String> callback);
|
||||
|
||||
|
||||
//Table Operation
|
||||
void getChangeTableTypeMonitor(AsyncCallback<ChangeTableTypeMonitor> callback);
|
||||
void startChangeTableType(ChangeTableTypeSession changeTableTypeSession,AsyncCallback<Void> callback);
|
||||
void getUnionMonitor(AsyncCallback<UnionMonitor> callback);
|
||||
void startUnion(UnionSession unionSession, AsyncCallback<Void> callback);
|
||||
void startChangeTableType(ChangeTableTypeSession changeTableTypeSession,AsyncCallback<String> callback);
|
||||
void startUnion(UnionSession unionSession, AsyncCallback<String> callback);
|
||||
|
||||
|
||||
|
||||
//Rows Operation
|
||||
void getEditRowMonitor(AsyncCallback<EditRowMonitor> callback);
|
||||
void startEditRow(EditRowSession editRowSession,AsyncCallback<Void> callback);
|
||||
|
||||
void getDeleteRowsMonitor(AsyncCallback<DeleteRowsMonitor> callback);
|
||||
void startDeleteRows(DeleteRowsSession deleteRowsSession,AsyncCallback<Void> callback);
|
||||
|
||||
void getDuplicatesMonitor(AsyncCallback<DuplicatesMonitor> callback);
|
||||
void startDuplicates(DuplicatesSession duplicatesSession,AsyncCallback<Void> callback);
|
||||
|
||||
void startEditRow(EditRowSession editRowSession,AsyncCallback<String> callback);
|
||||
void startDeleteRows(DeleteRowsSession deleteRowsSession,AsyncCallback<String> callback);
|
||||
void startDuplicates(DuplicatesSession duplicatesSession,AsyncCallback<String> callback);
|
||||
|
||||
//Column Operation
|
||||
void getChangeColumnTypeMonitor(AsyncCallback<ChangeColumnTypeMonitor> callback);
|
||||
void startChangeColumnType(ChangeColumnTypeSession changeColumnTypeSession,AsyncCallback<Void> callback);
|
||||
void getAddColumnMonitor(AsyncCallback<AddColumnMonitor> callback);
|
||||
void startAddColumn(AddColumnSession addColumnSession,AsyncCallback<Void> callback);
|
||||
void getDeleteColumnMonitor(AsyncCallback<DeleteColumnMonitor> callback);
|
||||
void startDeleteColumn(DeleteColumnSession deleteColumnSession,AsyncCallback<Void> callback);
|
||||
void getLabelColumnMonitor(AsyncCallback<LabelColumnMonitor> callback);
|
||||
void startLabelColumn(LabelColumnSession labelColumnSession,AsyncCallback<Void> callback);
|
||||
void startChangeColumnType(ChangeColumnTypeSession changeColumnTypeSession,AsyncCallback<String> callback);
|
||||
void startAddColumn(AddColumnSession addColumnSession,AsyncCallback<String> callback);
|
||||
void startDeleteColumn(DeleteColumnSession deleteColumnSession,AsyncCallback<String> callback);
|
||||
void startLabelColumn(LabelColumnSession labelColumnSession,AsyncCallback<String> callback);
|
||||
|
||||
void getSplitColumnMonitor(AsyncCallback<SplitColumnMonitor> callback);
|
||||
/*void startSplitColumn(SplitColumnSession splitColumnSession,AsyncCallback<Void> callback);*/
|
||||
void getMergeColumnMonitor(AsyncCallback<MergeColumnMonitor> callback);
|
||||
/*void startSplitColumn(MergeColumnSession mergeColumnSession,AsyncCallback<Void> callback); */
|
||||
void getGroupByMonitor(AsyncCallback<GroupByMonitor> callback);
|
||||
/*void startGroupBy(GroupBySession groupBySession,AsyncCallback<Void> callback);*/
|
||||
|
||||
|
||||
|
||||
//BatchReplace Operation
|
||||
void getOccurrencesForBatchReplace(OccurrencesForReplaceBatchColumnSession occurrencesForReplaceBatchColumnSession, AsyncCallback<ArrayList<Occurrences>> callback);
|
||||
void getReplaceBatchColumnMonitor(AsyncCallback<ReplaceBatchColumnMonitor> callback);
|
||||
void startReplaceBatchColumn(ReplaceBatchColumnSession replaceBatchColumnSession,AsyncCallback<Void> callback);
|
||||
void startReplaceBatchColumn(ReplaceBatchColumnSession replaceBatchColumnSession,AsyncCallback<String> callback);
|
||||
|
||||
//Replace Operation
|
||||
void getReplaceColumnMonitor(AsyncCallback<ReplaceColumnMonitor> callback);
|
||||
void startReplaceColumn(ReplaceColumnSession replaceColumnSession,AsyncCallback<Void> callback);
|
||||
void startReplaceColumn(ReplaceColumnSession replaceColumnSession,AsyncCallback<String> callback);
|
||||
|
||||
//Templates
|
||||
void getTemplates(AsyncCallback<ArrayList<TemplateData>> callback);
|
||||
void getTemplateApplyMonitor(AsyncCallback<TemplateApplyMonitor> callback);
|
||||
void startTemplateApply(TemplateApplySession templateDeleteSession,AsyncCallback<Void> callback);
|
||||
void startTemplateDelete(TemplateDeleteSession templateDeleteSession,AsyncCallback<Void> callback);
|
||||
void startTemplateApply(TemplateApplySession templateDeleteSession,AsyncCallback<String> callback);
|
||||
void templateDelete(TemplateDeleteSession templateDeleteSession,AsyncCallback<Void> callback);
|
||||
|
||||
//Locales
|
||||
void getLocales(AsyncCallback<ArrayList<String>> callback);
|
||||
|
|
@ -268,25 +210,24 @@ public interface TDGWTServiceAsync {
|
|||
void getLastOperationInfo(TRId trId, AsyncCallback<OpHistory> callback);
|
||||
|
||||
//Helper Extract Codelist
|
||||
void getExtractCodelistMonitor(AsyncCallback<ExtractCodelistMonitor> callback);
|
||||
void startExtractCodelist(ExtractCodelistSession extractCodelistSession, AsyncCallback<Void> callback);
|
||||
void startExtractCodelist(ExtractCodelistSession extractCodelistSession, AsyncCallback<String> callback);
|
||||
|
||||
//Helper Codelist Mapping Import
|
||||
void getCodelistMappingMonitor(AsyncCallback<CodelistMappingMonitor> callback);
|
||||
void setCodelistMappingSession(CodelistMappingSession codelistMappingSession, AsyncCallback<Void> callback);
|
||||
void getFileFromWorkspace(CodelistMappingSession codelistMappingSession, AsyncCallback<Void> callback);
|
||||
void startCodelistMappingImport(CodelistMappingSession codelistMappingSession, AsyncCallback<Void> callback);
|
||||
void startCodelistMappingImport(CodelistMappingSession codelistMappingSession, AsyncCallback<String> callback);
|
||||
|
||||
//Normalization
|
||||
void getNormalizationMonitor(AsyncCallback<NormalizationMonitor> callback);
|
||||
void startNormalization(NormalizationSession normalizationSession, AsyncCallback<Void> callback);
|
||||
void startNormalization(NormalizationSession normalizationSession, AsyncCallback<String> callback);
|
||||
|
||||
//Denormalization
|
||||
void getDenormalizationMonitor(AsyncCallback<DenormalizationMonitor> callback);
|
||||
void startDenormalization(DenormalizationSession denormalizationSession, AsyncCallback<Void> callback);
|
||||
void startDenormalization(DenormalizationSession denormalizationSession, AsyncCallback<String> callback);
|
||||
|
||||
//Operation Monitor
|
||||
void getOperationMonitor(OperationMonitorSession operationMonitorSession, AsyncCallback<OperationMonitor> callback);
|
||||
|
||||
//File Upload Monitor
|
||||
void getFileUploadMonitor(AsyncCallback<FileUploadMonitor> callback);
|
||||
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -21,6 +21,7 @@ import org.slf4j.LoggerFactory;
|
|||
|
||||
|
||||
/**
|
||||
* Returns a representation of the csv file in JSON
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
|
|
|
|||
|
|
@ -24,7 +24,6 @@ import org.gcube.portlets.user.td.gwtservice.server.file.FileUtil;
|
|||
import org.gcube.portlets.user.td.gwtservice.shared.exception.TDGWTSessionExpiredException;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadState;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.CodelistMappingMonitor;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
|
|
@ -62,12 +61,12 @@ public class CodelistMappingUploadServlet extends HttpServlet {
|
|||
logger.info("Codelist Mapping session id: "+session.getId());
|
||||
|
||||
CodelistMappingFileUploadSession codelistMappingFileUploadSession=new CodelistMappingFileUploadSession();
|
||||
CodelistMappingMonitor codelistMappingMonitor=new CodelistMappingMonitor();
|
||||
//CodelistMappingMonitor codelistMappingMonitor=new CodelistMappingMonitor();
|
||||
FileUploadMonitor fileUploadMonitor=new FileUploadMonitor();
|
||||
|
||||
codelistMappingFileUploadSession.setId(session.getId());
|
||||
codelistMappingFileUploadSession.setFileUploadState(FileUploadState.STARTED);
|
||||
codelistMappingFileUploadSession.setCodelistMappingMonitor(codelistMappingMonitor);
|
||||
//codelistMappingFileUploadSession.setCodelistMappingMonitor(codelistMappingMonitor);
|
||||
SessionUtil.setFileUploadMonitor(session,fileUploadMonitor);
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -18,10 +18,9 @@ import org.apache.commons.fileupload.FileItemFactory;
|
|||
import org.apache.commons.fileupload.FileUploadException;
|
||||
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
|
||||
import org.apache.commons.fileupload.servlet.ServletFileUpload;
|
||||
import org.gcube.portlets.user.td.gwtservice.server.file.FileUploadListener;
|
||||
import org.gcube.portlets.user.td.gwtservice.server.file.CSVFileUploadSession;
|
||||
import org.gcube.portlets.user.td.gwtservice.server.file.FileUploadListener;
|
||||
import org.gcube.portlets.user.td.gwtservice.server.file.FileUtil;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVImportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.exception.TDGWTSessionExpiredException;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadState;
|
||||
|
|
@ -62,12 +61,12 @@ public class LocalUploadServlet extends HttpServlet {
|
|||
logger.info("CSV Import session id: "+session.getId());
|
||||
|
||||
CSVFileUploadSession fileUploadSession=new CSVFileUploadSession();
|
||||
CSVImportMonitor csvImportMonitor=new CSVImportMonitor();
|
||||
//CSVImportMonitor csvImportMonitor=new CSVImportMonitor();
|
||||
FileUploadMonitor fileUploadMonitor=new FileUploadMonitor();
|
||||
|
||||
fileUploadSession.setId(session.getId());
|
||||
fileUploadSession.setFileUploadState(FileUploadState.STARTED);
|
||||
fileUploadSession.setCsvImportMonitor(csvImportMonitor);
|
||||
//fileUploadSession.setCsvImportMonitor(csvImportMonitor);
|
||||
SessionUtil.setFileUploadMonitor(session, fileUploadMonitor);
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -1,137 +1,89 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.server;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* email: <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class SessionConstants {
|
||||
protected static final String CURRENT_TABULAR_RESOURCE = "CURRENT_TABULAR_RESOURCE";
|
||||
protected static final String CURRENT_TR_ID = "CURRENT_TR_ID";
|
||||
protected static final String TDOPEN_SESSION = "TDOPEN_SESSION";
|
||||
protected static final String TABULAR_RESOURCE_LIST = "TABULAR_RESOURCE_LIST";
|
||||
|
||||
protected static final String OPERATIONS_TASKS="OPERATION_TASKS";
|
||||
|
||||
protected static final String OPERATIONS_TASKS_STARTED="OPERATION_TASKS_STARTED";
|
||||
protected static final String FILE_UPLOAD_MONITOR = "FILE_UPLOAD_MONITOR";
|
||||
|
||||
protected static final String TR_TASK_MANAGER = "TR_TASK_MANAGER";
|
||||
|
||||
protected static final String SDMX_REGISTRY_SOURCE = "SDMX_REGISTRY_SOURCE";
|
||||
|
||||
|
||||
|
||||
protected static final String SDMX_CLIENT_ATTRIBUTE = "SDMX_CLIENT";
|
||||
protected static final String SDMX_IMPORT_SESSION = "SDMX_IMPORT";
|
||||
protected static final String SDMX_IMPORT_TABULAR_RESOURCE = "SDMX_IMPORT_TABULAR_RESOURCE";
|
||||
protected static final String SDMX_IMPORT_TASK = "SDMX_IMPORT_TASK";
|
||||
|
||||
|
||||
protected static final String SDMX_EXPORT_SESSION = "SDMX_EXPORT_SESSION";
|
||||
protected static final String SDMX_EXPORT_TASK = "SDMX_EXPORT_TASK";
|
||||
|
||||
|
||||
protected static final String CSV_IMPORT_SESSION = "CSV_IMPORT";
|
||||
protected static final String CSV_IMPORT_FILE_UPLOAD_SESSION = "CSV_IMPORT_FILE_UPLOAD";
|
||||
protected static final String CSV_IMPORT_TASK = "CSV_IMPORT_TASK";
|
||||
protected static final String CSV_IMPORT_TABULAR_RESOURCE = "CSV_IMPORT_TABULAR_RESOURCE";
|
||||
|
||||
protected static final String CSV_EXPORT_SESSION = "CSV_EXPORT_SESSION";
|
||||
protected static final String CSV_EXPORT_TASK = "CSV_EXPORT_TASK";
|
||||
protected static final String CSV_EXPORT_END = "CSV_EXPORT_END";
|
||||
protected static final String CSV_EXPORT_MONITOR = "CSV_EXPORT_MONITOR";
|
||||
|
||||
protected static final String CLONE_TABULAR_RESOURCE_SESSION = "CLONE_TABULAR_RESOURCE_SESSION";
|
||||
protected static final String CLONE_TABULAR_RESOURCE_MONITOR = "CLONE_TABULAR_RESOURCE_MONITOR";
|
||||
protected static final String CLONE_TABULAR_RESOURCE_TASK = "CLONE_TABULAR_RESOURCE_TASK";
|
||||
|
||||
|
||||
protected static final String CHANGE_COLUMN_TYPE_SESSION = "CHANGE_COLUMN_TYPE_SESSION";
|
||||
protected static final String CHANGE_COLUMN_TYPE_MONITOR = "CHANGE_COLUMN_TYPE_MONITOR";
|
||||
protected static final String CHANGE_COLUMN_TYPE_TASK = "CHANGE_COLUMN_TYPE_TASK";
|
||||
|
||||
|
||||
protected static final String ADD_COLUMN_SESSION = "ADD_COLUMN_SESSION";
|
||||
protected static final String ADD_COLUMN_MONITOR = "ADD_COLUMN_MONITOR";
|
||||
protected static final String ADD_COLUMN_TASK = "ADD_COLUMN_TASK";
|
||||
|
||||
protected static final String DELETE_COLUMN_SESSION = "DELETE_COLUMN_SESSION";
|
||||
protected static final String DELETE_COLUMN_MONITOR = "DELETE_COLUMN_MONITOR";
|
||||
protected static final String DELETE_COLUMN_TASK = "DELETE_COLUMN_TASK";
|
||||
|
||||
protected static final String EDIT_ROW_SESSION = "EDIT_ROW_SESSION";
|
||||
protected static final String EDIT_ROW_MONITOR = "EDIT_ROW_MONITOR";
|
||||
protected static final String EDIT_ROW_TASK = "EDIT_ROW_TASK";
|
||||
|
||||
protected static final String TASK_RESUBMIT_SESSION = "TASK_RESUBMIT_SESSION";
|
||||
protected static final String TASK_RESUBMIT_MONITOR = "TASK_RESUBMIT_MONITOR";
|
||||
protected static final String TASK_RESUBMIT_TASK = "TASK_RESUBMIT_TASK";
|
||||
|
||||
protected static final String TASK_RESUME_SESSION = "TASK_RESUME_SESSION";
|
||||
protected static final String TASK_RESUME_MONITOR = "TASK_RESUME_MONITOR";
|
||||
protected static final String TASK_RESUME_TASK = "TASK_RESUME_TASK";
|
||||
|
||||
protected static final String REPLACE_COLUMN_SESSION = "REPLACE_COLUMN_SESSION";
|
||||
protected static final String REPLACE_COLUMN_MONITOR = "REPLACE_COLUMN_MONITOR";
|
||||
protected static final String REPLACE_COLUMN_TASK = "REPLACE_COLUMN_TASK";
|
||||
|
||||
protected static final String GROUPBY_SESSION = "GROUPBY_SESSION";
|
||||
protected static final String GROUPBY_MONITOR = "GROUPBY_MONITOR";
|
||||
protected static final String GROUPBY_TASK = "GROUPBY_TASK";
|
||||
|
||||
protected static final String UNION_SESSION = "UNION_SESSION";
|
||||
protected static final String UNION_MONITOR = "UNION_MONITOR";
|
||||
protected static final String UNION_TASK = "UNION_TASK";
|
||||
|
||||
protected static final String NORMALIZATION_SESSION = "NORMALIZATION_SESSION";
|
||||
protected static final String NORMALIZATION_MONITOR = "NORMALIZATION_MONITOR";
|
||||
protected static final String NORMALIZATION_TASK = "NORMALIZATION_TASK";
|
||||
|
||||
protected static final String DENORMALIZATION_SESSION = "DENORMALIZATION_SESSION";
|
||||
protected static final String DENORMALIZATION_MONITOR = "DENORMALIZATION_MONITOR";
|
||||
protected static final String DENORMALIZATION_TASK = "DENORMALIZATION_TASK";
|
||||
|
||||
protected static final String REPLACE_BATCH_COLUMN_SESSION = "REPLACE_BATCH_COLUMN_SESSION";
|
||||
protected static final String REPLACE_BATCH_COLUMN_MONITOR = "REPLACE_BATCH_COLUMN_MONITOR";
|
||||
protected static final String REPLACE_BATCH_COLUMN_TASK = "REPLACE_BATCH_COLUMN_TASK";
|
||||
|
||||
protected static final String CHANGE_THE_COLUMN_LABEL_SESSION = "CHANGE_THE_COLUMN_LABEL_SESSION";
|
||||
protected static final String CHANGE_THE_COLUMN_LABEL_MONITOR = "CHANGE_THE_COLUMN_LABEL_MONITOR";
|
||||
protected static final String CHANGE_THE_COLUMN_LABEL_TASK = "CHANGE_THE_COLUMN_LABEL_TASK";
|
||||
|
||||
|
||||
protected static final String CHANGE_TABLE_TYPE_SESSION = "CHANGE_TABLE_TYPE_SESSION";
|
||||
protected static final String CHANGE_TABLE_TYPE_MONITOR = "CHANGE_TABLE_TYPE_MONITOR";
|
||||
protected static final String CHANGE_TABLE_TYPE_TASK = "CHANGE_TABLE_TYPE_TASK";
|
||||
|
||||
|
||||
protected static final String DELETE_ROWS_SESSION = "DELETE_ROWS_SESSION";
|
||||
protected static final String DELETE_ROWS_MONITOR = "DELETE_ROWS_MONITOR";
|
||||
protected static final String DELETE_ROWS_TASK = "DELETE_ROWS_TASK";
|
||||
|
||||
|
||||
protected static final String DUPLICATES_ROWS_SESSION = "DUPLICATES_ROWS_SESSION";
|
||||
protected static final String DUPLICATES_ROWS_MONITOR = "DUPLICATES_ROWS_MONITOR";
|
||||
protected static final String DUPLICATES_ROWS_TASK = "DUPLICATES_ROWS_TASK";
|
||||
|
||||
|
||||
protected static final String TEMPLATE_APPLY_SESSION = "TEMPLATE_APPLY_SESSION";
|
||||
protected static final String TEMPLATE_APPLY_MONITOR = "TEMPLATE_APPLY_MONITOR";
|
||||
protected static final String TEMPLATE_APPLY_TASK = "TEMPLATE_APPLY_TASK";
|
||||
|
||||
|
||||
protected static final String CODELISTS_PAGING_LOADED = "CODELISTS_PAGING_LOADED";
|
||||
protected static final String CODELISTS_PAGING_LOADED_FILTERED_COPY = "CODELISTS_PAGING_LOADED_FILTERED_COPY";
|
||||
protected static final String CODELISTS_PAGING_LOADED_FILTER = "CODELISTS_PAGING_LOADED_FILTER";
|
||||
|
||||
protected static final String ROLLBACK_SESSION = "ROLLBACK_SESSION";
|
||||
protected static final String ROLLBACK_MONITOR = "ROLLBACK_MONITOR";
|
||||
protected static final String ROLLBACK_TASK = "ROLLBACK_TASK";
|
||||
|
||||
protected static final String EXTRACT_CODELIST_SESSION = "EXTRACT_CODELIST_SESSION";
|
||||
protected static final String EXTRACT_CODELIST_MONITOR = "EXTRACT_CODELIST_MONITOR";
|
||||
protected static final String EXTRACT_CODELIST_TASK = "EXTRACT_CODELIST_TASK";
|
||||
|
||||
|
||||
protected static final String SPLIT_COLUMN_SESSION = "SPLIT_COLUMN_SESSION";
|
||||
protected static final String SPLIT_COLUMN_MONITOR = "SPLIT_COLUMN_MONITOR";
|
||||
protected static final String SPLIT_COLUMN_TASK = "SPLIT_COLUMN_TASK";
|
||||
|
||||
protected static final String MERGE_COLUMN_SESSION = "MERGE_COLUMN_SESSION";
|
||||
protected static final String MERGE_COLUMN_MONITOR = "MERGE_COLUMN_MONITOR";
|
||||
protected static final String MERGE_COLUMN_TASK = "MERGE_COLUMN_TASK";
|
||||
|
||||
protected static final String CODELIST_MAPPING_SESSION = "CODELIST_MAPPING_SESSION";
|
||||
protected static final String CODELIST_MAPPING_FILE_UPLOAD_SESSION = "CODELIST_MAPPING_FILE_UPLOAD_SESSION";
|
||||
protected static final String CODELIST_MAPPING_TASK = "CODELIST_MAPPING_TASK";
|
||||
protected static final String CODELIST_MAPPING_MONITOR = "CODELIST_MAPPING_MONITOR";
|
||||
|
||||
protected static final String FILE_UPLOAD_MONITOR = "FILE_UPLOAD_MONITOR";
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
|
|
@ -3,7 +3,6 @@ package org.gcube.portlets.user.td.gwtservice.server.file;
|
|||
import java.io.File;
|
||||
import java.io.Serializable;
|
||||
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVImportMonitor;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.csv.CSVParserConfiguration;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadState;
|
||||
|
||||
|
|
@ -26,7 +25,7 @@ public class CSVFileUploadSession implements Serializable {
|
|||
|
||||
protected CSVParserConfiguration parserConfiguration;
|
||||
|
||||
protected CSVImportMonitor csvImportMonitor;
|
||||
//protected CSVImportMonitor csvImportMonitor;
|
||||
|
||||
|
||||
public String getId() {
|
||||
|
|
@ -69,23 +68,13 @@ public class CSVFileUploadSession implements Serializable {
|
|||
this.parserConfiguration = parserConfiguration;
|
||||
}
|
||||
|
||||
public CSVImportMonitor getCsvImportMonitor() {
|
||||
return csvImportMonitor;
|
||||
}
|
||||
|
||||
public void setCsvImportMonitor(CSVImportMonitor csvImportMonitor) {
|
||||
this.csvImportMonitor = csvImportMonitor;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return "CSVFileUploadSession [id=" + id + ", fileUploadState="
|
||||
+ fileUploadState + ", csvFile=" + csvFile + ", csvName="
|
||||
+ csvName + ", parserConfiguration=" + parserConfiguration
|
||||
+ ", csvImportMonitor=" + csvImportMonitor + "]";
|
||||
+ "]";
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -4,7 +4,6 @@ import java.io.File;
|
|||
import java.io.Serializable;
|
||||
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.file.FileUploadState;
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.monitor.CodelistMappingMonitor;
|
||||
|
||||
/**
|
||||
*
|
||||
|
|
@ -23,7 +22,7 @@ public class CodelistMappingFileUploadSession implements Serializable {
|
|||
protected File codelistMappingFile;
|
||||
protected String codelistMappingName;
|
||||
|
||||
protected CodelistMappingMonitor codelistMappingMonitor;
|
||||
//protected CodelistMappingMonitor codelistMappingMonitor;
|
||||
|
||||
public String getId() {
|
||||
return id;
|
||||
|
|
@ -58,23 +57,16 @@ public class CodelistMappingFileUploadSession implements Serializable {
|
|||
this.codelistMappingName = codelistMappingName;
|
||||
}
|
||||
|
||||
public CodelistMappingMonitor getCodelistMappingMonitor() {
|
||||
return codelistMappingMonitor;
|
||||
}
|
||||
|
||||
public void setCodelistMappingMonitor(
|
||||
CodelistMappingMonitor codelistMappingMonitor) {
|
||||
this.codelistMappingMonitor = codelistMappingMonitor;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return "CodelistMappingFileUploadSession [id=" + id
|
||||
+ ", fileUploadState=" + fileUploadState
|
||||
+ ", codelistMappingFile=" + codelistMappingFile
|
||||
+ ", codelistMappingName=" + codelistMappingName
|
||||
+ ", codelistMappingMonitor=" + codelistMappingMonitor + "]";
|
||||
+ ", codelistMappingName=" + codelistMappingName + "]";
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class AddColumnMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,13 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
public class ChangeTableTypeMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = 991656197616922469L;
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -1,14 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
public class CloneMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private static final long serialVersionUID = 8626668361737808483L;
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -1,16 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
*
|
||||
*/
|
||||
public class CodelistMappingMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -9004720851025676043L;
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class DeleteColumnMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,12 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
public class DeleteRowsMonitor extends OperationMonitor implements Serializable {
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private static final long serialVersionUID = -1547897501452634298L;
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* email: <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class DenormalizationMonitor extends OperationMonitor implements
|
||||
Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -1943471748865606817L;
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -1,11 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
public class DuplicatesMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = 2329951047629617335L;
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -1,12 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
public class EditRowMonitor extends OperationMonitor implements Serializable {
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private static final long serialVersionUID = -1547897501452634298L;
|
||||
|
||||
}
|
||||
|
|
@ -1,19 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class ExtractCodelistMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = -9042796707453619895L;
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class GroupByMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class LabelColumnMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class MergeColumnMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,17 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* email: <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class NormalizationMonitor extends OperationMonitor implements
|
||||
Serializable {
|
||||
|
||||
private static final long serialVersionUID = -7021715301225849091L;
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class ReplaceBatchColumnMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class ReplaceColumnMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,19 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class RollBackSessionMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = -4213157032725005579L;
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class SplitColumnMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,17 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
*
|
||||
*/
|
||||
public class TaskResubmitMonitor extends OperationMonitor implements Serializable {
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private static final long serialVersionUID = -1547897501452634298L;
|
||||
|
||||
}
|
||||
|
|
@ -1,17 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
*
|
||||
*/
|
||||
public class TaskResumeMonitor extends OperationMonitor implements Serializable {
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private static final long serialVersionUID = -1547897501452634298L;
|
||||
|
||||
}
|
||||
|
|
@ -1,19 +0,0 @@
|
|||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
* Apply Template Monitor
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class TemplateApplyMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = 7429207202237589027L;
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.monitor;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class UnionMonitor extends OperationMonitor implements Serializable {
|
||||
|
||||
|
||||
private static final long serialVersionUID = -7694151843138161474L;
|
||||
|
||||
}
|
||||
|
|
@ -1,92 +0,0 @@
|
|||
/**
|
||||
*
|
||||
*/
|
||||
package org.gcube.portlets.user.td.gwtservice.shared.tr.column.type;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
import org.gcube.portlets.user.td.gwtservice.shared.task.State;
|
||||
import org.gcube.portlets.user.td.widgetcommonevent.shared.TRId;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author "Giancarlo Panichi"
|
||||
* <a href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
||||
*
|
||||
*/
|
||||
public class ChangeColumnTypeMonitor implements Serializable {
|
||||
|
||||
private static final long serialVersionUID = 5378053063599667767L;
|
||||
|
||||
protected float progress;
|
||||
protected State status;
|
||||
protected String statusDescription;
|
||||
protected Throwable error;
|
||||
protected TRId trId;
|
||||
protected String columnName;
|
||||
|
||||
public float getProgress(){
|
||||
return progress;
|
||||
};
|
||||
|
||||
public State getStatus(){
|
||||
return status;
|
||||
}
|
||||
|
||||
public String getStatusDescription(){
|
||||
return statusDescription;
|
||||
}
|
||||
|
||||
public void setProgress(float progress) {
|
||||
this.progress = progress;
|
||||
}
|
||||
|
||||
public void setStatus(State status) {
|
||||
this.status = status;
|
||||
}
|
||||
|
||||
public void setStatus(int status) {
|
||||
this.status = State.values()[status];
|
||||
}
|
||||
|
||||
|
||||
|
||||
public void setStatusDescription(String statusDescription) {
|
||||
this.statusDescription = statusDescription;
|
||||
}
|
||||
|
||||
public Throwable getError() {
|
||||
return error;
|
||||
}
|
||||
|
||||
public void setError(Throwable error) {
|
||||
this.error = error;
|
||||
}
|
||||
|
||||
public TRId getTrId() {
|
||||
return trId;
|
||||
}
|
||||
|
||||
public void setTrId(TRId trId) {
|
||||
this.trId = trId;
|
||||
}
|
||||
|
||||
public String getColumnName() {
|
||||
return columnName;
|
||||
}
|
||||
|
||||
public void setColumnName(String columnName) {
|
||||
this.columnName = columnName;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return "ChangeColumnTypeMonitor [progress=" + progress + ", status="
|
||||
+ status + ", statusDescription=" + statusDescription
|
||||
+ ", error=" + error + ", trId=" + trId + ", columnName="
|
||||
+ columnName + "]";
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue