http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/FilemgrDeleteStepMeta.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/FilemgrDeleteStepMeta.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/FilemgrDeleteStepMeta.java deleted file mode 100644 index e89484c..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/FilemgrDeleteStepMeta.java +++ /dev/null @@ -1,349 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - -package org.apache.oodt.filemgrdelete; - -import org.eclipse.swt.widgets.Shell; -import org.pentaho.di.core.CheckResult; -import org.pentaho.di.core.CheckResultInterface; -import org.pentaho.di.core.annotations.Step; -import org.pentaho.di.core.database.DatabaseMeta; -import org.pentaho.di.core.exception.KettleException; -import org.pentaho.di.core.exception.KettleStepException; -import org.pentaho.di.core.exception.KettleValueException; -import org.pentaho.di.core.exception.KettleXMLException; -import org.pentaho.di.core.row.RowMetaInterface; -import org.pentaho.di.core.row.ValueMeta; -import org.pentaho.di.core.row.ValueMetaInterface; -import org.pentaho.di.core.variables.VariableSpace; -import org.pentaho.di.core.xml.XMLHandler; -import org.pentaho.di.i18n.BaseMessages; -import org.pentaho.di.repository.ObjectId; -import org.pentaho.di.repository.Repository; -import org.pentaho.di.trans.Trans; -import org.pentaho.di.trans.TransMeta; -import org.pentaho.di.trans.step.*; -import org.pentaho.metastore.api.IMetaStore; -import org.w3c.dom.Node; - -import java.util.List; - -/** - * This class is part of the demo step plug-in implementation. - * It demonstrates the basics of developing a plug-in step for PDI. - * - * The demo step adds a new string field to the row stream and sets its - * value to "Hello World!". The user may select the name of the new field. - * - * This class is the implementation of StepMetaInterface. - * Classes implementing this interface need to: - * - * - keep track of the step settings - * - serialize step settings both to xml and a repository - * - provide new instances of objects implementing StepDialogInterface, StepInterface and StepDataInterface - * - report on how the step modifies the meta-data of the row-stream (row structure and field types) - * - perform a sanity-check on the settings provided by the user - * - */ - -@Step( - id = "FilemgrCheck", - image = "org/apache/oodt/filemgrcheck/resources/check/oodt.jpg", - i18nPackageName="bi.meteorite.filemgrcheck", - name="FilemgrCheckStep.Name", - description = "FilemgrCheckStep.TooltipDesc", - categoryDescription="i18n:org.pentaho.di.trans.step:BaseStep.Category.Transform" -) -public class FilemgrDeleteStepMeta extends BaseStepMeta implements StepMetaInterface { - - /** - * The PKG member is used when looking up internationalized strings. - * The properties file with localized keys is expected to reside in - * {the package of the class specified}/messages/messages_{locale}.properties - */ - private static Class<?> PKG = FilemgrDeleteStepMeta.class; // for i18n purposes - - /** - * Stores the name of the field added to the row-stream. - */ - private String outputField; - private String filenameField; - private String serverURLField; - private String resultField; - - /** - * Constructor should call super() to make sure the base class has a chance to initialize properly. - */ - public FilemgrDeleteStepMeta() { - super(); - } - - /** - * Called by Spoon to get a new instance of the SWT dialog for the step. - * A standard implementation passing the arguments to the constructor of the step dialog is recommended. - * - * @param shell an SWT Shell - * @param meta description of the step - * @param transMeta description of the the transformation - * @param name the name of the step - * @return new instance of a dialog for this step - */ - public StepDialogInterface getDialog(Shell shell, StepMetaInterface meta, TransMeta transMeta, String name) { - return new FilemgrDeleteStepDialog(shell, meta, transMeta, name); - } - - /** - * Called by PDI to get a new instance of the step implementation. - * A standard implementation passing the arguments to the constructor of the step class is recommended. - * - * @param stepMeta description of the step - * @param stepDataInterface instance of a step data class - * @param cnr copy number - * @param transMeta description of the transformation - * @param disp runtime implementation of the transformation - * @return the new instance of a step implementation - */ - public StepInterface getStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta, Trans disp) { - return new FilemgrDeleteStep(stepMeta, stepDataInterface, cnr, transMeta, disp); - } - - /** - * Called by PDI to get a new instance of the step data class. - */ - public StepDataInterface getStepData() { - return new FilemgrDeleteStepData(); - } - - /** - * This method is called every time a new step is created and should allocate/set the step configuration - * to sensible defaults. The values set here will be used by Spoon when a new step is created. - */ - public void setDefault() { - outputField = "demo_field"; - filenameField = "fieldname"; - serverURLField = "http://localhost:9000";; - resultField = "result"; - } - - /** - * Getter for the name of the field added by this step - * @return the name of the field added - */ - public String getOutputField() { - return outputField; - } - - /** - * Setter for the name of the field added by this step - * @param outputField the name of the field added - */ - public void setOutputField(String outputField) { - this.outputField = outputField; - } - - - public String getFilenameField(){ - return filenameField; - } - - public void setFilenameField(String filenameField){ - this.filenameField = filenameField; - } - /** - * This method is used when a step is duplicated in Spoon. It needs to return a deep copy of this - * step meta object. Be sure to create proper deep copies if the step configuration is stored in - * modifiable objects. - * - * See org.pentaho.di.trans.steps.rowgenerator.RowGeneratorMeta.clone() for an example on creating - * a deep copy. - * - * @return a deep copy of this - */ - public Object clone() { - Object retval = super.clone(); - return retval; - } - - /** - * This method is called by Spoon when a step needs to serialize its configuration to XML. The expected - * return value is an XML fragment consisting of one or more XML tags. - * - * Please use org.pentaho.di.core.xml.XMLHandler to conveniently generate the XML. - * - * @return a string containing the XML serialization of this step - */ - public String getXML() throws KettleValueException { - - // only one field to serialize - String xml = " "; - xml += " " +XMLHandler.addTagValue("outputfield", outputField); - xml += " " +XMLHandler.addTagValue("filenamefield", filenameField); - xml += " " +XMLHandler.addTagValue("serverurlfield", serverURLField); - xml += " " +XMLHandler.addTagValue("resultfield", resultField); - return xml; - } - - /** - * This method is called by PDI when a step needs to load its configuration from XML. - * - * Please use org.pentaho.di.core.xml.XMLHandler to conveniently read from the - * XML node passed in. - * - * @param stepnode the XML node containing the configuration - * @param databases the databases available in the transformation - * @param metaStore the metaStore to optionally read from - */ - public void loadXML(Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore) throws KettleXMLException { - - try { - setOutputField(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "outputfield"))); - setFilenameField(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "filenamefield"))); - setServerURLField(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "serverurlfield"))); - setResultField(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "resultfield"))); - } catch (Exception e) { - throw new KettleXMLException("Demo plugin unable to read step info from XML node", e); - } - - } - /** - * This method is called by Spoon when a step needs to serialize its configuration to a repository. - * The repository implementation provides the necessary methods to save the step attributes. - * - * @param rep the repository to save to - * @param metaStore the metaStore to optionally write to - * @param id_transformation the id to use for the transformation when saving - * @param id_step the id to use for the step when saving - */ - public void saveRep(Repository rep, IMetaStore metaStore, ObjectId id_transformation, ObjectId id_step) throws KettleException - { - try{ - rep.saveStepAttribute(id_transformation, id_step, "outputfield", outputField); //$NON-NLS-1$ - } - catch(Exception e){ - throw new KettleException("Unable to save step into repository: "+id_step, e); - } - } - - /** - * This method is called by PDI when a step needs to read its configuration from a repository. - * The repository implementation provides the necessary methods to read the step attributes. - * - * @param rep the repository to read from - * @param metaStore the metaStore to optionally read from - * @param id_step the id of the step being read - * @param databases the databases available in the transformation - */ - public void readRep(Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases) throws KettleException { - try{ - outputField = rep.getStepAttributeString(id_step, "outputfield"); //$NON-NLS-1$ - } - catch(Exception e){ - throw new KettleException("Unable to load step from repository", e); - } - } - - /** - * This method is called to determine the changes the step is making to the row-stream. - * To that end a RowMetaInterface object is passed in, containing the row-stream structure as it is when entering - * the step. This method must apply any changes the step makes to the row stream. Usually a step adds fields to the - * row-stream. - * - * @param inputRowMeta the row structure coming in to the step - * @param name the name of the step making the changes - * @param info row structures of any info steps coming in - * @param nextStep the description of a step this step is passing rows to - * @param space the variable space for resolving variables - * @param repository the repository instance optionally read from - * @param metaStore the metaStore to optionally read from - */ - public void getFields(RowMetaInterface inputRowMeta, String name, RowMetaInterface[] info, StepMeta nextStep, VariableSpace space, Repository repository, IMetaStore metaStore) throws KettleStepException{ - - /* - * This implementation appends the outputField to the row-stream - */ - - // a value meta object contains the meta data for a field - ValueMetaInterface v = new ValueMeta(outputField, ValueMeta.TYPE_STRING); - - // setting trim type to "both" - v.setTrimType(ValueMeta.TRIM_TYPE_BOTH); - - // the name of the step that adds this field - v.setOrigin(name); - - // modify the row structure and add the field this step generates - inputRowMeta.addValueMeta(v); - - } - - - /** - * This method is called when the user selects the "Verify Transformation" option in Spoon. - * A list of remarks is passed in that this method should add to. Each remark is a comment, warning, error, or ok. - * The method should perform as many checks as necessary to catch design-time errors. - * - * Typical checks include: - * - verify that all mandatory configuration is given - * - verify that the step receives any input, unless it's a row generating step - * - verify that the step does not receive any input if it does not take them into account - * - verify that the step finds fields it relies on in the row-stream - * - * @param remarks - * @param transMeta - * @param stepMeta - * @param prev - * @param input - * @param output - * @param info - * @param space - * @param repository - * @param metaStore - */ - public void check(List<CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String input[], String output[], RowMetaInterface info, VariableSpace space, Repository repository, IMetaStore metaStore) { - - CheckResult cr; - - // See if there are input streams leading to this step! - if (input.length > 0) { - cr = new CheckResult(CheckResult.TYPE_RESULT_OK, BaseMessages.getString(PKG, "Demo.CheckResult.ReceivingRows.OK"), stepMeta); - remarks.add(cr); - } else { - cr = new CheckResult(CheckResult.TYPE_RESULT_ERROR, BaseMessages.getString(PKG, "Demo.CheckResult.ReceivingRows.ERROR"), stepMeta); - remarks.add(cr); - } - - } - - - public void setServerURLField(String serverURLField) { - this.serverURLField = serverURLField; - } - - public String getServerURLField() { - return serverURLField; - } - - - public void setResultField(String resultField) { - this.resultField = resultField; - } - - public String getResultField() { - return resultField; - } -}
http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/OODTConfig.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/OODTConfig.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/OODTConfig.java deleted file mode 100644 index 0ebe318..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/OODTConfig.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - - -package org.apache.oodt.filemgrdelete; - - -import org.apache.oodt.cas.filemgr.system.XmlRpcFileManagerClient; - -import java.net.URL; -import java.util.logging.Level; -import java.util.logging.Logger; - -/** - * Created by bugg on 07/03/14. - */ -public class OODTConfig { - - private static final Logger LOG = Logger.getLogger(OODTConfig.class.getName()); - - private URL fmUrl; - - public URL getFmUrl(){ - return this.fmUrl; - } - - private static XmlRpcFileManagerClient client = null; - - public boolean loadXMLRpcClient(String fmUrlStr){ - try { - client = new XmlRpcFileManagerClient(new URL(fmUrlStr)); - } catch (Exception e) { - LOG.log(Level.SEVERE, - "Unable to create file manager client: Message: " - + e.getMessage() + ": errors to follow"); - } - return true; - } - - public XmlRpcFileManagerClient getXMLRpcClient(){ - return client; - } -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/OODTProcesses.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/OODTProcesses.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/OODTProcesses.java deleted file mode 100644 index c33bcb7..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/OODTProcesses.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrdelete; - -import org.apache.oodt.cas.filemgr.structs.Product; -import org.apache.oodt.cas.filemgr.structs.Reference; -import org.apache.oodt.cas.filemgr.system.XmlRpcFileManagerClient; - -import java.io.File; -import java.net.URI; -import java.util.List; - -/** - * Created by bugg on 07/03/14. - */ -public class OODTProcesses { - - public boolean deleteProductByName(OODTConfig config, String filename) throws Exception { - XmlRpcFileManagerClient client = config.getXMLRpcClient(); - Product p = client.getProductByName(filename); - List<Reference> refs = client.getProductReferences(p); - if (refs == null) { - throw new Exception("FileManager returned null References"); - } - for (Reference ref : refs) { - if (!client.removeFile(new File(new URI(ref.getDataStoreReference())) - .getAbsolutePath())) { - throw new Exception("Failed to delete file '" - + ref.getDataStoreReference() + "'"); - } - } - if (client.removeProduct(p)) { - // printer.println("Successfully deleted product '" - // + p.getProductName() + "'"); - return true; - } else { - throw new Exception("Delete product returned false"); - } - } - - -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/PushPullObjectFactory.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/PushPullObjectFactory.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/PushPullObjectFactory.java deleted file mode 100644 index a710e1f..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/PushPullObjectFactory.java +++ /dev/null @@ -1,74 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrdelete; - -//OODT imports -import org.apache.oodt.cas.filemgr.ingest.Cache; -import org.apache.oodt.cas.filemgr.ingest.CacheFactory; -import org.apache.oodt.cas.filemgr.ingest.Ingester; - -//JDK imports -import java.lang.reflect.InvocationTargetException; - -/** - * - * @author bfoster - * @version $Revision$ - * - * <p> - * Describe your class here - * </p>. - */ -public class PushPullObjectFactory { - - private PushPullObjectFactory() throws InstantiationException { - throw new InstantiationException("Don't construct factory classes!"); - } - - public static <T> T createNewInstance(Class<T> clazz) throws InstantiationException { - try { - return clazz.newInstance(); - } catch (Exception e) { - throw new InstantiationException( - "Failed to create new object : " - + e.getMessage()); - } - } - - public static Ingester createIngester(String ingesterClass, - String cacheFactoryClass) throws InstantiationException, - IllegalAccessException, ClassNotFoundException, - IllegalArgumentException, SecurityException, - InvocationTargetException, NoSuchMethodException { - String dataTransferFactory = "org.apache.oodt.cas.filemgr.datatransfer.LocalDataTransferFactory"; - System.out.println("TRANSFER: " + dataTransferFactory); - if (cacheFactoryClass == null || cacheFactoryClass.equals("")) { - return (Ingester) Class.forName(ingesterClass).getConstructor( - dataTransferFactory.getClass()).newInstance( - dataTransferFactory); - } else { - Class<CacheFactory> cacheFactory = (Class<CacheFactory>) Class - .forName(cacheFactoryClass); - Cache cache = cacheFactory.newInstance().createCache(); - return (Ingester) Class.forName(ingesterClass).getConstructor( - dataTransferFactory.getClass(), cache.getClass()) - .newInstance(dataTransferFactory, cache); - } - } - -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/messages/messages_en_US.properties ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/messages/messages_en_US.properties b/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/messages/messages_en_US.properties deleted file mode 100644 index ef95599..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrdelete/messages/messages_en_US.properties +++ /dev/null @@ -1,11 +0,0 @@ -Demo.Shell.Title=Demo step -Demo.FieldName.Label=Output field name -Demo.CheckResult.ReceivingRows.OK=Step is receiving input from other steps. -Demo.CheckResult.ReceivingRows.ERROR=No input received from other steps! - -FilemgrDeleteStep.Name=OODT Filemgr File Delete -FilemgrDeleteStep.TooltipDesc=Remove a file from the file manager - -FilemgrDelete.FieldName.Label=Stream Field Name -FilemgrDelete.ServerURL.Label=Filemgr URL -FilemgrDelete.Result.Label=Result Field http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStep.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStep.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStep.java deleted file mode 100644 index eb9cc62..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStep.java +++ /dev/null @@ -1,244 +0,0 @@ -package org.apache.oodt.filemgrget; - -import org.apache.oodt.cas.filemgr.structs.exceptions.CatalogException; -import org.apache.oodt.cas.filemgr.structs.exceptions.ConnectionException; -import org.apache.oodt.cas.filemgr.structs.exceptions.DataTransferException; -import org.pentaho.di.core.Const; -import org.pentaho.di.core.exception.KettleException; -import org.pentaho.di.core.row.RowMeta; -import org.pentaho.di.trans.Trans; -import org.pentaho.di.trans.TransMeta; -import org.pentaho.di.trans.step.*; -import sun.util.logging.resources.logging_de; - -import java.io.IOException; -import java.net.MalformedURLException; -import java.util.Map; - -import static org.pentaho.di.core.row.RowDataUtil.allocateRowData; - -/** -* Copyright 2014 OSBI Ltd -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ - -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -public class FilemgrGetStep extends BaseStep implements StepInterface { - - private OODTConfig oodt = new OODTConfig(); - private OODTProcesses oodtproc = new OODTProcesses(); - private FilemgrGetStepData data; - private FilemgrGetStepMeta meta; - /** - * The constructor should simply pass on its arguments to the parent class. - * - * @param s step description - * @param stepDataInterface step data class - * @param c step copy - * @param t transformation description - * @param dis transformation executing - */ - public FilemgrGetStep(StepMeta s, StepDataInterface stepDataInterface, int c, TransMeta t, Trans dis) { - super(s, stepDataInterface, c, t, dis); - } - - /** - * This method is called by PDI during transformation startup. - * - * It should initialize required for step execution. - * - * The meta and data implementations passed in can safely be cast - * to the step's respective implementations. - * - * It is mandatory that super.init() is called to ensure correct behavior. - * - * Typical tasks executed here are establishing the connection to a database, - * as wall as obtaining resources, like file handles. - * - * @param smi step meta interface implementation, containing the step settings - * @param sdi step data interface implementation, used to store runtime information - * - * @return true if initialization completed successfully, false if there was an error preventing the step from working. - * - */ - public boolean init(StepMetaInterface smi, StepDataInterface sdi) { - // Casting to step-specific implementation classes is safe - meta = (FilemgrGetStepMeta) smi; - data = (FilemgrGetStepData) sdi; - - - logDetailed("loading xmlrpcclient"); - try { - oodt.loadXMLRpcClient(meta.getServerURLField()); - } catch (MalformedURLException e) { - logError("Incorrect URL", e); - } catch (ConnectionException e) { - logError("There was a problem connecting", e); - } - logDetailed("finished loading xmlrpcclient"); - - - return super.init(meta, data); - } - - - private Object[] buildEmptyRow() { - - return allocateRowData(data.outputRowMeta.size()); - } - - /** - * Once the transformation starts executing, the processRow() method is called repeatedly - * by PDI for as long as it returns true. To indicate that a step has finished processing rows - * this method must call setOutputDone() and return false; - * - * Steps which process incoming rows typically call getRow() to read a single row from the - * input stream, change or add row content, call putRow() to pass the changed row on - * and return true. If getRow() returns null, no more rows are expected to come in, - * and the processRow() implementation calls setOutputDone() and returns false to - * indicate that it is done too. - * - * Steps which generate rows typically construct a new row Object[] using a call to - * RowDataUtil.allocateRowData(numberOfFields), add row content, and call putRow() to - * pass the new row on. Above process may happen in a loop to generate multiple rows, - * at the end of which processRow() would call setOutputDone() and return false; - * - * @param smi the step meta interface containing the step settings - * @param sdi the step data interface that should be used to store - * - * @return true to indicate that the function should be called again, false if the step is done - */ - public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException { - - - if ( first ) { - first = false; - data.outputRowMeta = new RowMeta(); - meta.getFields( data.outputRowMeta, getStepname(), null, null, this, repository, metaStore ); - } - - if(meta.getProcessType() == Process.LIST){ - try { - Map<String, Map<String, String>> products = oodtproc.getAllProducts(oodt, environmentSubstitute(meta.getProductTypeField())); - for (Map.Entry<String, Map<String,String>> entry : products.entrySet()) - { - Object[] row = buildEmptyRow(); - - incrementLinesRead(); - - row[0] = entry.getKey(); - int i = 1; - for(Map.Entry<String,String> innerentry : entry.getValue().entrySet()){ - row[i] = innerentry.getValue(); - i++; - } - - putRow(data.outputRowMeta, row); - } - - } catch (Exception e) { - logError("Could not get data", e); - } - - } - else if(meta.getProcessType() == Process.GET && meta.getSearchType() == Search.ID){ - - try { - String lookup = meta.getLookup(); - if(!Const.isEmpty(lookup)){ - lookup = environmentSubstitute(lookup); - } - - Object[] row = buildEmptyRow(); - row[0] = oodtproc.getProductByID(oodt, lookup); - putRow(data.outputRowMeta, row); - - } catch (CatalogException e) { - logError("Catalog Exception", e); - } catch (DataTransferException e) { - logError("Data Transfer Exception", e); - } catch (IOException e) { - logError("IO Exception",e); - } - } - else if(meta.getProcessType() == Process.GET && meta.getSearchType() == Search.NAME){ - try { - String lookup = meta.getLookup(); - if(!Const.isEmpty(lookup)){ - lookup = environmentSubstitute(lookup); - } - - Object[] row = buildEmptyRow(); - row[0] = oodtproc.getProductByName(oodt, lookup); - putRow(data.outputRowMeta, row); - } catch (CatalogException e) { - logError("Catalog Exception", e); - } catch (DataTransferException e) { - logError("Data Transfer Exception", e); - } catch (IOException e) { - logError("IO Exception", e); - } - } - - - // log progress if it is time to to so - if (checkFeedback(getLinesRead())) { - logBasic("Linenr " + getLinesRead()); // Some basic logging - } - - // indicate that processRow() should be called again - setOutputDone(); - return false; - } - - /** - * This method is called by PDI once the step is done processing. - * - * The dispose() method is the counterpart to init() and should release any resources - * acquired for step execution like file handles or database connections. - * - * The meta and data implementations passed in can safely be cast - * to the step's respective implementations. - * - * It is mandatory that super.dispose() is called to ensure correct behavior. - * - * @param smi step meta interface implementation, containing the step settings - * @param sdi step data interface implementation, used to store runtime information - */ - public void dispose(StepMetaInterface smi, StepDataInterface sdi) { - - // Casting to step-specific implementation classes is safe - FilemgrGetStepMeta meta = (FilemgrGetStepMeta) smi; - FilemgrGetStepData data = (FilemgrGetStepData) sdi; - - super.dispose(meta, data); - } - -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepData.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepData.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepData.java deleted file mode 100644 index ada2397..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepData.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrget; - -import org.pentaho.di.core.row.RowMetaInterface; -import org.pentaho.di.trans.step.BaseStepData; -import org.pentaho.di.trans.step.StepDataInterface; - -/** -* Copyright 2014 OSBI Ltd -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -public class FilemgrGetStepData extends BaseStepData implements StepDataInterface { - - public RowMetaInterface outputRowMeta; - - public String fieldname; - - public FilemgrGetStepData() - { - super(); - } -} - http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepDialog.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepDialog.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepDialog.java deleted file mode 100644 index c6aaf0b..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepDialog.java +++ /dev/null @@ -1,438 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrget; - -import org.eclipse.swt.SWT; -import org.eclipse.swt.events.*; -import org.eclipse.swt.layout.FormAttachment; -import org.eclipse.swt.layout.FormData; -import org.eclipse.swt.layout.FormLayout; -import org.eclipse.swt.layout.RowLayout; -import org.eclipse.swt.widgets.*; -import org.pentaho.di.core.Const; -import org.pentaho.di.i18n.BaseMessages; -import org.pentaho.di.trans.TransMeta; -import org.pentaho.di.trans.step.BaseStepMeta; -import org.pentaho.di.trans.step.StepDialogInterface; -import org.pentaho.di.ui.core.widget.TextVar; -import org.pentaho.di.ui.trans.step.BaseStepDialog; - -/** -* Copyright 2014 OSBI Ltd -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -public class FilemgrGetStepDialog extends BaseStepDialog implements StepDialogInterface { - - /** - * The PKG member is used when looking up internationalized strings. - * The properties file with localized keys is expected to reside in - * {the package of the class specified}/messages/messages_{locale}.properties - */ - private static Class<?> PKG = FilemgrGetStepMeta.class; // for i18n purposes - - // this is the object the stores the step's settings - // the dialog reads the settings from it when opening - // the dialog writes the settings to it when confirmed - private FilemgrGetStepMeta meta; - - // text field holding the name of the field to add to the row stream - //private Text wHelloFieldName; - - // text field holding the name of the field to check the filename against - private TextVar wFilenameField; - private Text wServerURLField; - private TextVar wResultField; - private Button[] radioButtons2 = new Button[2]; - private Button[] radioButtons = new Button[2]; - private Search selectedsearch; - private Process selectedprocess; - /** - * The constructor should simply invoke super() and save the incoming meta - * object to a local variable, so it can conveniently read and write settings - * from/to it. - * - * @param parent the SWT shell to open the dialog in - * @param in the meta object holding the step's settings - * @param transMeta transformation description - * @param sname the step name - */ - public FilemgrGetStepDialog(Shell parent, Object in, TransMeta transMeta, String sname) { - super(parent, (BaseStepMeta) in, transMeta, sname); - meta = (FilemgrGetStepMeta) in; - } - - /** - * This method is called by Spoon when the user opens the settings dialog of the step. - * It should open the dialog and return only once the dialog has been closed by the user. - * - * If the user confirms the dialog, the meta object (passed in the constructor) must - * be updated to reflect the new step settings. The changed flag of the meta object must - * reflect whether the step configuration was changed by the dialog. - * - * If the user cancels the dialog, the meta object must not be updated, and its changed flag - * must remain unaltered. - * - * The open() method must return the name of the step after the user has confirmed the dialog, - * or null if the user cancelled the dialog. - */ - public String open() { - - // store some convenient SWT variables - Shell parent = getParent(); - Display display = parent.getDisplay(); - - // SWT code for preparing the dialog - shell = new Shell(parent, SWT.DIALOG_TRIM | SWT.RESIZE | SWT.MIN | SWT.MAX); - props.setLook(shell); - setShellImage(shell, meta); - - // Save the value of the changed flag on the meta object. If the user cancels - // the dialog, it will be restored to this saved value. - // The "changed" variable is inherited from BaseStepDialog - changed = meta.hasChanged(); - - // The ModifyListener used on all controls. It will update the meta object to - // indicate that changes are being made. - ModifyListener lsMod = new ModifyListener() { - public void modifyText(ModifyEvent e) { - meta.setChanged(); - } - }; - - // ------------------------------------------------------- // - // SWT code for building the actual settings dialog // - // ------------------------------------------------------- // - FormLayout formLayout = new FormLayout(); - formLayout.marginWidth = Const.FORM_MARGIN; - formLayout.marginHeight = Const.FORM_MARGIN; - - shell.setLayout(formLayout); - shell.setText(BaseMessages.getString(PKG, "FilemgrGetStep.Name")); - - int middle = props.getMiddlePct(); - int margin = Const.MARGIN; - - // Stepname line - wlStepname = new Label(shell, SWT.RIGHT); - wlStepname.setText(BaseMessages.getString(PKG, "System.Label.StepName")); - props.setLook(wlStepname); - fdlStepname = new FormData(); - fdlStepname.left = new FormAttachment(0, 0); - fdlStepname.right = new FormAttachment(middle, -margin); - fdlStepname.top = new FormAttachment(0, margin); - wlStepname.setLayoutData(fdlStepname); - - wStepname = new Text(shell, SWT.SINGLE | SWT.LEFT | SWT.BORDER); - wStepname.setText(stepname); - props.setLook(wStepname); - wStepname.addModifyListener(lsMod); - fdStepname = new FormData(); - fdStepname.left = new FormAttachment(middle, 0); - fdStepname.top = new FormAttachment(0, margin); - fdStepname.right = new FormAttachment(100, 0); - wStepname.setLayoutData(fdStepname); - - // servername field value - Label wlServerName = new Label(shell, SWT.RIGHT); - wlServerName.setText(BaseMessages.getString(PKG, "FilemgrGet.ServerURL.Label")); - props.setLook(wlServerName); - FormData fdlServerName = new FormData(); - fdlServerName.left = new FormAttachment(0, 0); - fdlServerName.right = new FormAttachment(middle, -margin); - fdlServerName.top = new FormAttachment(wStepname, margin); - wlServerName.setLayoutData(fdlServerName); - - wServerURLField = new Text(shell, SWT.SINGLE | SWT.LEFT | SWT.BORDER); - props.setLook(wServerURLField); - wServerURLField.addModifyListener(lsMod); - FormData fdServerName = new FormData(); - fdServerName.left = new FormAttachment(middle, 0); - fdServerName.right = new FormAttachment(100, 0); - fdServerName.top = new FormAttachment(wStepname, margin); - wServerURLField.setLayoutData(fdServerName); - - // product type - Label wlValName = new Label(shell, SWT.RIGHT); - wlValName.setText(BaseMessages.getString(PKG, "FilemgrGet.ProductType.Label")); - props.setLook(wlValName); - FormData fdlValName = new FormData(); - fdlValName.left = new FormAttachment(0, 0); - fdlValName.right = new FormAttachment(middle, -margin); - fdlValName.top = new FormAttachment(wServerURLField, margin); - wlValName.setLayoutData(fdlValName); - - wFilenameField = new TextVar(transMeta, shell, SWT.SINGLE | SWT.LEFT | SWT.BORDER); - props.setLook(wFilenameField); - wFilenameField.addModifyListener(lsMod); - FormData fdValName = new FormData(); - fdValName.left = new FormAttachment(middle, 0); - fdValName.right = new FormAttachment(100, 0); - fdValName.top = new FormAttachment(wServerURLField, margin); - wFilenameField.setLayoutData(fdValName); - - - // processtype value - Label wlProcessTypeName = new Label(shell, SWT.RIGHT); - wlProcessTypeName.setText(BaseMessages.getString(PKG, "FilemgrGet.ProcessType.Label")); - props.setLook(wlProcessTypeName); - FormData fdlProcessTypeName = new FormData(); - fdlProcessTypeName.left = new FormAttachment(0, 0); - fdlProcessTypeName.right = new FormAttachment(middle, -margin); - fdlProcessTypeName.top = new FormAttachment(wFilenameField, margin); - wlProcessTypeName.setLayoutData(fdlProcessTypeName); - - Composite composite = new Composite(shell, SWT.NULL); - composite.setLayout(new RowLayout()); - radioButtons2[0] = new Button(composite, SWT.RADIO); - radioButtons2[0].setSelection(true); - radioButtons2[0].setText("List Products"); - radioButtons2[0].pack(); - radioButtons2[1] = new Button(composite, SWT.RADIO); - radioButtons2[1].setSelection(false); - radioButtons2[1].setText("Get Product"); - radioButtons2[1].pack(); - props.setLook(radioButtons2[0]); - props.setLook(radioButtons2[1]); - - - //wFilenameField.addModifyListener(lsMod); - FormData fdProcessTypeName = new FormData(); - fdProcessTypeName.left = new FormAttachment(middle, 0); - fdProcessTypeName.right = new FormAttachment(100, 0); - fdProcessTypeName.top = new FormAttachment(wFilenameField, margin); - composite.setLayoutData(fdProcessTypeName); - - - // search type value - Label wlSearchName = new Label(shell, SWT.RIGHT); - wlSearchName.setText(BaseMessages.getString(PKG, "FilemgrGet.SearchType.Label")); - props.setLook(wlSearchName); - FormData fdlSearchName = new FormData(); - fdlSearchName.left = new FormAttachment(0, 0); - fdlSearchName.right = new FormAttachment(middle, -margin); - fdlSearchName.top = new FormAttachment(composite, margin); - wlSearchName.setLayoutData(fdlSearchName); - - Composite composite1 = new Composite(shell, SWT.NULL); - composite1.setLayout(new RowLayout()); - radioButtons[0] = new Button(composite1, SWT.RADIO); - radioButtons[0].setSelection(true); - radioButtons[0].setText("Name"); - radioButtons[0].pack(); - radioButtons[1] = new Button(composite1, SWT.RADIO); - radioButtons[1].setSelection(false); - radioButtons[1].setText("ID"); - radioButtons[1].pack(); - props.setLook(radioButtons[0]); - props.setLook(radioButtons[1]); - radioButtons[0].addSelectionListener(new SelectionAdapter() { - public void widgetSelected(SelectionEvent e) { - selectedsearch = Search.NAME; - } - }); - radioButtons[1].addSelectionListener(new SelectionAdapter() { - public void widgetSelected(SelectionEvent e) { - selectedsearch = Search.ID; - } - }); - - FormData fdSearchName = new FormData(); - fdSearchName.left = new FormAttachment(middle, 0); - fdSearchName.right = new FormAttachment(100, 0); - fdSearchName.top = new FormAttachment(composite, margin); - composite1.setLayoutData(fdSearchName); - - if(meta.getProcessType()==Process.LIST){ - radioButtons[0].setEnabled(false); - radioButtons[1].setEnabled(false); - } - - - // servername field value - Label wlResultName = new Label(shell, SWT.RIGHT); - wlResultName.setText(BaseMessages.getString(PKG, "FilemgrGet.Result.Label")); - props.setLook(wlResultName); - FormData fdlResultName = new FormData(); - fdlResultName.left = new FormAttachment(0, 0); - fdlResultName.right = new FormAttachment(middle, -margin); - fdlResultName.top = new FormAttachment(composite1, margin); - wlResultName.setLayoutData(fdlResultName); - - wResultField = new TextVar(transMeta, shell, SWT.SINGLE | SWT.LEFT | SWT.BORDER); - props.setLook(wResultField); - wResultField.addModifyListener(lsMod); - FormData fdResultName = new FormData(); - fdResultName.left = new FormAttachment(middle, 0); - fdResultName.right = new FormAttachment(100, 0); - fdResultName.top = new FormAttachment(composite1, margin); - wResultField.setLayoutData(fdResultName); - wResultField.addModifyListener(new ModifyListener() { - public void modifyText(ModifyEvent e) { - wResultField.setToolTipText(transMeta.environmentSubstitute(wResultField.getText())); - } - }); - - if(meta.getProcessType()==Process.LIST){ - wResultField.setEnabled(false); - } - // OK and cancel buttons - wOK = new Button(shell, SWT.PUSH); - wOK.setText(BaseMessages.getString(PKG, "System.Button.OK")); - wCancel = new Button(shell, SWT.PUSH); - wCancel.setText(BaseMessages.getString(PKG, "System.Button.Cancel")); - - BaseStepDialog.positionBottomButtons(shell, new Button[] { wOK, wCancel }, margin, wResultField); - - // Add listeners for cancel and OK - lsCancel = new Listener() { - public void handleEvent(Event e) {cancel();} - }; - lsOK = new Listener() { - public void handleEvent(Event e) {ok();} - }; - - wCancel.addListener(SWT.Selection, lsCancel); - wOK.addListener(SWT.Selection, lsOK); - - /** - * Radio button listeners - */ - radioButtons2[0].addSelectionListener(new SelectionAdapter() { - public void widgetSelected(SelectionEvent e) { - selectedprocess = Process.LIST; - wResultField.setEnabled(false); - radioButtons[0].setEnabled(false); - radioButtons[1].setEnabled(false); - - } - }); - radioButtons2[1].addSelectionListener(new SelectionAdapter() { - public void widgetSelected(SelectionEvent e) { - selectedprocess = Process.GET; - radioButtons[0].setEnabled(true); - radioButtons[1].setEnabled(true); - wResultField.setEnabled(true); - } - }); - - // default listener (for hitting "enter") - lsDef = new SelectionAdapter() { - public void widgetDefaultSelected(SelectionEvent e) {ok();} - }; - wStepname.addSelectionListener(lsDef); - wFilenameField.addSelectionListener(lsDef); - wServerURLField.addSelectionListener(lsDef); - wResultField.addSelectionListener(lsDef); - // Detect X or ALT-F4 or something that kills this window and cancel the dialog properly - shell.addShellListener(new ShellAdapter() { - public void shellClosed(ShellEvent e) {cancel();} - }); - - // Set/Restore the dialog size based on last position on screen - // The setSize() method is inherited from BaseStepDialog - setSize(); - - // populate the dialog with the values from the meta object - populateDialog(); - - // restore the changed flag to original value, as the modify listeners fire during dialog population - meta.setChanged(changed); - - // open dialog and enter event loop - shell.open(); - while (!shell.isDisposed()) { - if (!display.readAndDispatch()) - display.sleep(); - } - - // at this point the dialog has closed, so either ok() or cancel() have been executed - // The "stepname" variable is inherited from BaseStepDialog - return stepname; - } - - /** - * This helper method puts the step configuration stored in the meta object - * and puts it into the dialog controls. - */ - private void populateDialog() { - wStepname.selectAll(); - wFilenameField.setText(meta.getProductTypeField()); - wServerURLField.setText(meta.getServerURLField()); - wResultField.setText(meta.getResultField()); - if(meta.getSearchType() == Search.NAME){ - radioButtons[0].setSelection(true); - radioButtons[1].setSelection(false); - selectedsearch = Search.NAME; - } - else{ - radioButtons[1].setSelection(true); - radioButtons[0].setSelection(false); - selectedsearch = Search.ID; - } - - if(meta.getProcessType() == Process.LIST){ - radioButtons2[0].setSelection(true); - radioButtons2[1].setSelection(false); - selectedprocess= Process.LIST; - } - else{ - radioButtons2[1].setSelection(true); - radioButtons2[0].setSelection(false); - selectedprocess = Process.GET; - } - - } - - /** - * Called when the user cancels the dialog. - */ - private void cancel() { - // The "stepname" variable will be the return value for the open() method. - // Setting to null to indicate that dialog was cancelled. - stepname = null; - // Restoring original "changed" flag on the met aobject - meta.setChanged(changed); - // close the SWT dialog window - dispose(); - } - - /** - * Called when the user confirms the dialog - */ - private void ok() { - stepname = wStepname.getText(); - meta.setProductName(wFilenameField.getText()); - meta.setServerURLField(wServerURLField.getText()); - meta.setResultField(wResultField.getText()); - meta.setProcessType(selectedprocess); - meta.setSearchType(selectedsearch); - // close the SWT dialog window - dispose(); - } -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepMeta.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepMeta.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepMeta.java deleted file mode 100644 index 3b295fc..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/FilemgrGetStepMeta.java +++ /dev/null @@ -1,410 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrget; - -import org.eclipse.swt.widgets.Shell; -import org.pentaho.di.core.CheckResult; -import org.pentaho.di.core.CheckResultInterface; -import org.pentaho.di.core.annotations.Step; -import org.pentaho.di.core.database.DatabaseMeta; -import org.pentaho.di.core.exception.KettleException; -import org.pentaho.di.core.exception.KettleStepException; -import org.pentaho.di.core.exception.KettleValueException; -import org.pentaho.di.core.exception.KettleXMLException; -import org.pentaho.di.core.row.RowMetaInterface; -import org.pentaho.di.core.row.ValueMeta; -import org.pentaho.di.core.row.ValueMetaInterface; -import org.pentaho.di.core.variables.VariableSpace; -import org.pentaho.di.core.xml.XMLHandler; -import org.pentaho.di.i18n.BaseMessages; -import org.pentaho.di.repository.ObjectId; -import org.pentaho.di.repository.Repository; -import org.pentaho.di.trans.Trans; -import org.pentaho.di.trans.TransMeta; -import org.pentaho.di.trans.step.*; -import org.pentaho.metastore.api.IMetaStore; -import org.w3c.dom.Node; - -import java.util.List; - -/** -* Copyright 2014 OSBI Ltd -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ - -@Step( - id = "FilemgrGet", - image = "org/apache/oodt/filemgrcheck/resources/check/oodt.jpg", - i18nPackageName="bi.meteorite.filemgrget", - name="FilemgrGetStep.Name", - description = "FilemgrGetStep.TooltipDesc", - categoryDescription="i18n:org.pentaho.di.trans.step:BaseStep.Category.BigData" -) -public class FilemgrGetStepMeta extends BaseStepMeta implements StepMetaInterface { - - /** - * The PKG member is used when looking up internationalized strings. - * The properties file with localized keys is expected to reside in - * {the package of the class specified}/messages/messages_{locale}.properties - */ - private static Class<?> PKG = FilemgrGetStepMeta.class; // for i18n purposes - - /** - * Stores the name of the field added to the row-stream. - */ - private String outputField; - private String productName; - private String serverURLField; - private String resultField; - private Search searchtypeField; - private Process processtypeField; - - /** - * Constructor should call super() to make sure the base class has a chance to initialize properly. - */ - public FilemgrGetStepMeta() { - super(); - } - - /** - * Called by Spoon to get a new instance of the SWT dialog for the step. - * A standard implementation passing the arguments to the constructor of the step dialog is recommended. - * - * @param shell an SWT Shell - * @param meta description of the step - * @param transMeta description of the the transformation - * @param name the name of the step - * @return new instance of a dialog for this step - */ - public StepDialogInterface getDialog(Shell shell, StepMetaInterface meta, TransMeta transMeta, String name) { - return new FilemgrGetStepDialog(shell, meta, transMeta, name); - } - - /** - * Called by PDI to get a new instance of the step implementation. - * A standard implementation passing the arguments to the constructor of the step class is recommended. - * -gf * @param stepMeta description of the step - * @param stepDataInterface instance of a step data class - * @param cnr copy number - * @param transMeta description of the transformation - * @param disp runtime implementation of the transformation - * @return the new instance of a step implementation - */ - public StepInterface getStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta, Trans disp) { - return new FilemgrGetStep(stepMeta, stepDataInterface, cnr, transMeta, disp); - } - - /** - * Called by PDI to get a new instance of the step data class. - */ - public StepDataInterface getStepData() { - return new FilemgrGetStepData(); - } - - /** - * This method is called every time a new step is created and should allocate/set the step configuration - * to sensible defaults. The values set here will be used by Spoon when a new step is created. - */ - public void setDefault() { - outputField = "demo_field"; - serverURLField = "http://localhost:9000";; - resultField = "result"; - productName = "GenericFile"; - searchtypeField = Search.NAME; - processtypeField = Process.LIST; - } - - /** - * Getter for the name of the field added by this step - * @return the name of the field added - */ - public String getOutputField() { - return outputField; - } - - /** - * Setter for the name of the field added by this step - * @param outputField the name of the field added - */ - public void setOutputField(String outputField) { - this.outputField = outputField; - } - - - public String getProductTypeField(){ - return productName; - } - - public void setProductName(String productName){ - this.productName = productName; - } - /** - * This method is used when a step is duplicated in Spoon. It needs to return a deep copy of this - * step meta object. Be sure to create proper deep copies if the step configuration is stored in - * modifiable objects. - * - * See org.pentaho.di.trans.steps.rowgenerator.RowGeneratorMeta.clone() for an example on creating - * a deep copy. - * - * @return a deep copy of this - */ - public Object clone() { - return super.clone(); - } - - /** - * This method is called by Spoon when a step needs to serialize its configuration to XML. The expected - * return value is an XML fragment consisting of one or more XML tags. - * - * Please use org.pentaho.di.core.xml.XMLHandler to conveniently generate the XML. - * - * @return a string containing the XML serialization of this step - */ - public String getXML() throws KettleValueException { - - // only one field to serialize - String xml = " "; - xml += " " +XMLHandler.addTagValue("outputfield", outputField); - xml += " " +XMLHandler.addTagValue("filenamefield", productName); - xml += " " +XMLHandler.addTagValue("serverurlfield", serverURLField); - xml += " " +XMLHandler.addTagValue("resultfield", resultField); - xml += " " +XMLHandler.addTagValue("producttypefield", productName); - xml += " " +XMLHandler.addTagValue("searchtypefield", searchtypeField.toString()); - xml += " " +XMLHandler.addTagValue("processtypefield", processtypeField.toString()); - return xml; - } - - /** - * This method is called by PDI when a step needs to load its configuration from XML. - * - * Please use org.pentaho.di.core.xml.XMLHandler to conveniently read from the - * XML node passed in. - * - * @param stepnode the XML node containing the configuration - * @param databases the databases available in the transformation - * @param metaStore the metaStore to optionally read from - */ - public void loadXML(Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore) throws KettleXMLException { - - try { - setOutputField(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "outputfield"))); - setProductName(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "filenamefield"))); - setServerURLField(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "serverurlfield"))); - setResultField(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "resultfield"))); - setProductName(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "producttypefield"))); - setSearchType(Search.valueOf(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "searchtypefield")))); - setProcessType(Process.valueOf(XMLHandler.getNodeValue(XMLHandler.getSubNode(stepnode, "processtypefield")))); - - } catch (Exception e) { - throw new KettleXMLException("Demo plugin unable to read step info from XML node", e); - } - - } - /** - * This method is called by Spoon when a step needs to serialize its configuration to a repository. - * The repository implementation provides the necessary methods to save the step attributes. - * - * @param rep the repository to save to - * @param metaStore the metaStore to optionally write to - * @param id_transformation the id to use for the transformation when saving - * @param id_step the id to use for the step when saving - */ - public void saveRep(Repository rep, IMetaStore metaStore, ObjectId id_transformation, ObjectId id_step) throws KettleException - { - try{ - rep.saveStepAttribute(id_transformation, id_step, "outputfield", outputField); //$NON-NLS-1$ - } - catch(Exception e){ - throw new KettleException("Unable to save step into repository: "+id_step, e); - } - } - - /** - * This method is called by PDI when a step needs to read its configuration from a repository. - * The repository implementation provides the necessary methods to read the step attributes. - * - * @param rep the repository to read from - * @param metaStore the metaStore to optionally read from - * @param id_step the id of the step being read - * @param databases the databases available in the transformation - */ - public void readRep(Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases) throws KettleException { - try{ - outputField = rep.getStepAttributeString(id_step, "outputfield"); //$NON-NLS-1$ - } - catch(Exception e){ - throw new KettleException("Unable to load step from repository", e); - } - } - - /** - * This method is called to determine the changes the step is making to the row-stream. - * To that end a RowMetaInterface object is passed in, containing the row-stream structure as it is when entering - * the step. This method must apply any changes the step makes to the row stream. Usually a step adds fields to the - * row-stream. - * - * @param inputRowMeta the row structure coming in to the step - * @param name the name of the step making the changes - * @param info row structures of any info steps coming in - * @param nextStep the description of a step this step is passing rows to - * @param space the variable space for resolving variables - * @param repository the repository instance optionally read from - * @param metaStore the metaStore to optionally read from - */ - public void getFields(RowMetaInterface inputRowMeta, String name, RowMetaInterface[] info, StepMeta nextStep, VariableSpace space, Repository repository, IMetaStore metaStore) throws KettleStepException{ - - /* - * This implementation appends the outputField to the row-stream - */ - if(getProcessType() == Process.LIST){ - // a value meta object contains the meta data for a field - ValueMetaInterface v = new ValueMeta("id", ValueMeta.TYPE_STRING); - - // setting trim type to "both" - v.setTrimType(ValueMeta.TRIM_TYPE_BOTH); - - // the name of the step that adds this field - v.setOrigin(name); - - // modify the row structure and add the field this step generates - inputRowMeta.addValueMeta(v); - - ValueMetaInterface v2 = new ValueMeta("type", ValueMeta.TYPE_STRING); - v2.setTrimType(ValueMeta.TRIM_TYPE_BOTH); - v2.setOrigin(name); - inputRowMeta.addValueMeta(v2); - - ValueMetaInterface v3 = new ValueMeta("name", ValueMeta.TYPE_STRING); - v3.setTrimType(ValueMeta.TRIM_TYPE_BOTH); - v3.setOrigin(name); - inputRowMeta.addValueMeta(v3); - - ValueMetaInterface v4 = new ValueMeta("structure", ValueMeta.TYPE_STRING); - v4.setTrimType(ValueMeta.TRIM_TYPE_BOTH); - v4.setOrigin(name); - inputRowMeta.addValueMeta(v4); - - ValueMetaInterface v5 = new ValueMeta("transferstatus", ValueMeta.TYPE_STRING); - v5.setTrimType(ValueMeta.TRIM_TYPE_BOTH); - v5.setOrigin(name); - inputRowMeta.addValueMeta(v5); - - ValueMetaInterface v6 = new ValueMeta("metadata", ValueMeta.TYPE_STRING); - v6.setTrimType(ValueMeta.TRIM_TYPE_BOTH); - v6.setOrigin(name); - inputRowMeta.addValueMeta(v6); - } - else{ - ValueMetaInterface v6 = new ValueMeta("export", ValueMeta.TYPE_STRING); - v6.setTrimType(ValueMeta.TRIM_TYPE_BOTH); - v6.setOrigin(name); - inputRowMeta.addValueMeta(v6); - } - } - - /** - * This method is called when the user selects the "Verify Transformation" option in Spoon. - * A list of remarks is passed in that this method should add to. Each remark is a comment, warning, error, or ok. - * The method should perform as many checks as necessary to catch design-time errors. - * - * Typical checks include: - * - verify that all mandatory configuration is given - * - verify that the step receives any input, unless it's a row generating step - * - verify that the step does not receive any input if it does not take them into account - * - verify that the step finds fields it relies on in the row-stream - * - * @param remarks the list of remarks to append to - * @param transMeta the description of the transformation - * @param stepMeta the description of the step - * @param prev the structure of the incoming row-stream - * @param input names of steps sending input to the step - * @param output names of steps this step is sending output to - * @param info fields coming in from info steps - * @param metaStore metaStore to optionally read from - */ - public void check(List<CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String input[], String output[], RowMetaInterface info, VariableSpace space, Repository repository, IMetaStore metaStore) { - - CheckResult cr; - - // See if there are input streams leading to this step! - if (input.length > 0) { - cr = new CheckResult(CheckResult.TYPE_RESULT_OK, BaseMessages.getString(PKG, "Demo.CheckResult.ReceivingRows.OK"), stepMeta); - remarks.add(cr); - } else { - cr = new CheckResult(CheckResult.TYPE_RESULT_ERROR, BaseMessages.getString(PKG, "Demo.CheckResult.ReceivingRows.ERROR"), stepMeta); - remarks.add(cr); - } - - } - - - public void setServerURLField(String serverURLField) { - this.serverURLField = serverURLField; - } - - public String getServerURLField() { - return serverURLField; - } - - - public void setResultField(String resultField) { - this.resultField = resultField; - } - - public String getResultField() { - return resultField; - } - - - public Process getProcessType() { - - return processtypeField; - } - - public void setProcessType(Process processtypeField){ - this.processtypeField = processtypeField; - } - - public Search getSearchType() { - return searchtypeField; - } - - public void setSearchType(Search searchType){ - this.searchtypeField = searchType; - } - - public String getLookup() { - return resultField; - } - - public void setLookup(String lookup){ - this.resultField = lookup; - } -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/OODTConfig.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/OODTConfig.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/OODTConfig.java deleted file mode 100644 index dc295f9..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/OODTConfig.java +++ /dev/null @@ -1,60 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrget; - -import org.apache.oodt.cas.filemgr.structs.exceptions.ConnectionException; -import org.apache.oodt.cas.filemgr.system.XmlRpcFileManagerClient; - -import java.net.MalformedURLException; -import java.net.URL; -import java.util.logging.Level; -import java.util.logging.Logger; - -/** -* Copyright 2014 OSBI Ltd -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -public class OODTConfig { - - private static final Logger LOG = Logger.getLogger(OODTConfig.class.getName()); - - private static XmlRpcFileManagerClient client = null; - - public boolean loadXMLRpcClient(String fmUrlStr) throws MalformedURLException, ConnectionException { - - client = new XmlRpcFileManagerClient(new URL(fmUrlStr), true); - - return true; - } - - public XmlRpcFileManagerClient getXMLRpcClient(){ - return client; - } - -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/OODTProcesses.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/OODTProcesses.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/OODTProcesses.java deleted file mode 100644 index 4da706f..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/OODTProcesses.java +++ /dev/null @@ -1,130 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrget; - -import com.google.gson.Gson; -import org.apache.oodt.cas.filemgr.datatransfer.DataTransfer; -import org.apache.oodt.cas.filemgr.datatransfer.LocalDataTransferFactory; -import org.apache.oodt.cas.filemgr.structs.Product; -import org.apache.oodt.cas.filemgr.structs.ProductPage; -import org.apache.oodt.cas.filemgr.structs.ProductType; -import org.apache.oodt.cas.filemgr.structs.exceptions.CatalogException; -import org.apache.oodt.cas.filemgr.structs.exceptions.DataTransferException; -import org.apache.oodt.cas.filemgr.system.XmlRpcFileManagerClient; -import org.apache.oodt.cas.metadata.Metadata; - -import java.io.File; -import java.io.IOException; -import java.util.*; - -/** - * Copyright 2014 OSBI Ltd - * <p/> - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * <p/> - * http://www.apache.org/licenses/LICENSE-2.0 - * <p/> - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -public class OODTProcesses { - - - public Map<String, Map<String, String>> getAllProducts(OODTConfig config, String productTypeName) throws Exception { - XmlRpcFileManagerClient client = config.getXMLRpcClient(); - ProductType type = client.getProductTypeByName(productTypeName); - if (type == null) { - throw new Exception("FileManager returned null ProductType"); - } - ProductPage firstPage = client.getFirstPage(type); - if (firstPage == null) { - throw new Exception("FileManager returned null product page"); - } - - Map<String, Map<String, String>> o = new ConcurrentHashMap<String, Map<String, String>>(); - - for (int pid = 0; pid < firstPage.getTotalPages(); pid++) { - if (pid > 0) { - firstPage = client.getNextPage(type, firstPage); - } - for (Product p : firstPage.getPageProducts()) { - Metadata met = client.getMetadata(p); - - Map<String, String> h = new ConcurrentHashMap<String, String>(); - h.put("name", p.getProductName()); - h.put("type", p.getProductType().getName()); - h.put("structure", p.getProductStructure()); - h.put("transferstatus", p.getTransferStatus()); - Gson g = new Gson(); - String json = g.toJson(met.getHashtable()); - h.put("metadata", json); - o.put(p.getProductId(), h); - - } - - } - return o; - - } - - - public String getProductByID(OODTConfig config, String id) throws CatalogException, IOException, DataTransferException { - Product product = config.getXMLRpcClient().getProductById(id); - product.setProductReferences(config.getXMLRpcClient().getProductReferences(product)); - LocalDataTransferFactory ldtf = new LocalDataTransferFactory(); - DataTransfer dt = ldtf.createDataTransfer(); - String rand = UUID.randomUUID().toString(); - File theDir = new File("/tmp/oodt/" + rand); - boolean mkdir = false; - if (!theDir.exists()) { - mkdir = theDir.mkdir(); - } - if (mkdir) { - dt.retrieveProduct(product, new File("/tmp/oodt/" + rand)); - return "/tmp/oodt/" + rand + "/" + product.getProductName(); - } else { - return null; - } - } - - public String getProductByName(OODTConfig config, String name) throws CatalogException, IOException, DataTransferException { - Product product = config.getXMLRpcClient().getProductByName(name); - product.setProductReferences(config.getXMLRpcClient().getProductReferences(product)); - LocalDataTransferFactory ldtf = new LocalDataTransferFactory(); - DataTransfer dt = ldtf.createDataTransfer(); - String rand = UUID.randomUUID().toString(); - File theDir = new File("/tmp/oodt/" + rand); - boolean mkdir = false; - if (!theDir.exists()) { - mkdir = theDir.mkdir(); - } - if (mkdir) { - dt.retrieveProduct(product, new File("/tmp/oodt/" + rand)); - return "/tmp/oodt/" + rand + "/" + product.getProductName(); - } else { - return null; - } - - } - -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/Process.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/Process.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/Process.java deleted file mode 100644 index a780e0f..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/Process.java +++ /dev/null @@ -1,37 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrget; - -/** -* Copyright 2014 OSBI Ltd -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -public enum Process { - LIST,GET -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/Search.java ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/Search.java b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/Search.java deleted file mode 100644 index d3cd5ad..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/Search.java +++ /dev/null @@ -1,37 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.oodt.filemgrget; - -/** -* Copyright 2014 OSBI Ltd -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -public enum Search { - NAME,ID -} http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/messages/messages_en_US.properties ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/messages/messages_en_US.properties b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/messages/messages_en_US.properties deleted file mode 100644 index f40155a..0000000 --- a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/messages/messages_en_US.properties +++ /dev/null @@ -1,9 +0,0 @@ -FilemgrGetStep.Name=OODT Filemgr File Get -FilemgrGetStep.TooltipDesc=Get the file from the repository - -FilemgrGet.ProductType.Label=Product Type Field -FilemgrGet.ProcessType.Label=Process Type -FilemgrGet.SearchType.Label=Search Type -FilemgrGet.FieldName.Label=Product Type -FilemgrGet.ServerURL.Label=Filemgr URL -FilemgrGet.Result.Label=Product Name/ID http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/resources/get/oodt.jpg ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/resources/get/oodt.jpg b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/resources/get/oodt.jpg deleted file mode 100644 index 5810409..0000000 Binary files a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/resources/get/oodt.jpg and /dev/null differ http://git-wip-us.apache.org/repos/asf/oodt/blob/2fc7bced/tools/pdi_plugin/src/org/apache/oodt/filemgrget/resources/get/oodt.png ---------------------------------------------------------------------- diff --git a/tools/pdi_plugin/src/org/apache/oodt/filemgrget/resources/get/oodt.png b/tools/pdi_plugin/src/org/apache/oodt/filemgrget/resources/get/oodt.png deleted file mode 100644 index e69de29..0000000
