Newer
Older
brinn
committed
/*
* Copyright 2010 ETH Zuerich, CISD
*
* 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.
*/
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
brinn
committed
import java.io.File;
import java.io.FileOutputStream;
import java.io.FileReader;
brinn
committed
import java.io.IOException;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
brinn
committed
import java.util.List;
import java.util.Map;
import ch.systemsx.cisd.openbis.dss.client.api.v1.IDataSetDss;
import ch.systemsx.cisd.openbis.dss.generic.shared.api.v1.NewDataSetMetadataDTO;
import ch.systemsx.cisd.openbis.generic.client.cli.Login;
brinn
committed
import ch.systemsx.cisd.openbis.plugin.screening.client.api.v1.IScreeningOpenbisServiceFacade;
import ch.systemsx.cisd.openbis.plugin.screening.client.api.v1.IScreeningOpenbisServiceFacadeFactory;
brinn
committed
import ch.systemsx.cisd.openbis.plugin.screening.client.api.v1.ScreeningOpenbisServiceFacade.IImageOutputStreamProvider;
import ch.systemsx.cisd.openbis.plugin.screening.client.api.v1.ScreeningOpenbisServiceFacadeFactory;
brinn
committed
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.ExperimentIdentifier;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.FeatureVector;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.FeatureVectorDataset;
brinn
committed
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.FeatureVectorDatasetReference;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.FeatureVectorWithDescription;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.Geometry;
brinn
committed
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.ImageDatasetMetadata;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.ImageDatasetReference;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.MaterialIdentifier;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.MaterialTypeIdentifier;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.Plate;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.PlateIdentifier;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.PlateImageReference;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.PlateWellMaterialMapping;
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.WellIdentifier;
brinn
committed
import ch.systemsx.cisd.openbis.plugin.screening.shared.api.v1.dto.WellPosition;
/**
* Simple Matlab interface for openBIS for Screening. It is meant to be used in one Matlab session
* at a time, i.e. it is <i>not</i> multi-threading safe.
brinn
committed
* <p>
* While written in Java, the API is idiomatic for Matlab, i.e. values are returned as
* multi-dimensional arrays. For the <code>get...</code> and <code>load...</code> methods the first
* index will contain the actual data, while the second index will contain per-row annotations. For
* <code>getFeatureMatrix</code>, the third index contains per-column annotations. This allows
* simple access with Matlab's slicing operator, see doc of e.g. {@link #getFeatureMatrix(String)}.
* <p>
* A typical Matlab session looks like:
*
* <pre>
* % Add the API jar file to the classpath
* javaaddpath('/home/brinn/matlab/openbis_screening_api-batteries_included.jar')
* % Login to server
* OpenBISScreeningML.login('user', 'secret', 'https://www.infectome.org')
brinn
committed
*
* % ...perform calls on the server...
*
* % Logout to close the session on the server
* OpenBISScreeningML.logout()
brinn
committed
* </pre>
*
* <i>Note: using this login your password will end up in the Matlab command history. An alternative
* that avoids this is to call the {@link ch.systemsx.cisd.openbis.generic.client.cli.Login} class.
* Logging in on the console will grant this class access to the openBIS server.</i>
* <p>
* To learn the API one needs to understand three basic notions: code, augmented code and perm id.
* Space, project, experiment, plate and well have their own <b>code</b>, which is unique only in
* the context of the parent.<br>
* That's why one needs <b>augmented code</b> to point e.g. to one experiment, because two different
* projects can have experiments with the same code.<br>
* Such an augmented code for experiment has a form of "/space-code/project-code/experiment-code".<br>
* For plate it has a form of "/space-code/plate-code" (note that plate code is unique on the space
* level). <br>
* The drawback of an augmented code is that it's not persistent. If someone e.g. moves the
* experiment from one space to the other augmented code of the experiment becomes invalid. That is
* why experiments, plates and datasets have <b>perm id</b> (permament identifier) which never
* change and allow to refer to them with one "magic" identifier, e.g. 20110516124520378-737166.
* </p>
brinn
committed
* @author Bernd Rinn
*/
public class OpenBISScreeningML
brinn
committed
{
private static interface ITileNumberIterable extends Iterable<Integer>
{
public void setMaximumNumberOfTiles(int numberOfTiles);
public int getMaximumNumberOfTiles();
}
private static final class ImageReferenceAndFile
{
private final PlateImageReference imageReference;
private final File imageFile;
private BufferedOutputStream outputStream;
ImageReferenceAndFile(PlateImageReference imageReference, File imageFile)
{
this.imageReference = imageReference;
this.imageFile = imageFile;
}
public PlateImageReference getImageReference()
{
return imageReference;
}
public File getImageFile()
{
return imageFile;
}
public OutputStream open() throws IOException
{
if (outputStream == null)
{
outputStream = new BufferedOutputStream(new FileOutputStream(imageFile));
}
return outputStream;
}
public void close() throws IOException
{
if (outputStream != null)
{
outputStream.close();
}
outputStream = null;
}
}
static final String DATASETS_FOLDER = "openbis_datasets";
private static File temporarySessionDir;
private static Map<PlateImageReference, File> loadedImages;
static IScreeningOpenbisServiceFacadeFactory facadeFactory =
ScreeningOpenbisServiceFacadeFactory.INSTANCE;
brinn
committed
private static IScreeningOpenbisServiceFacade openbis = null;
private static List<ExperimentIdentifier> experiments = null;
private static List<Plate> plates = null;
private static Map<String, List<Plate>> experimentToPlateMap =
new HashMap<String, List<Plate>>();
private static Map<String, ExperimentIdentifier> experimentCodeToExperimentMap =
new HashMap<String, ExperimentIdentifier>();
private static Map<String, Plate> plateCodeToPlateMap = new HashMap<String, Plate>();
private OpenBISScreeningML()
brinn
committed
{
// Not to be constructed.
}
brinn
committed
//
// Versioning
//
/**
* The version of the API.
*/
public static final String VERSION = "1";
brinn
committed
/**
* The required version ("major.minor") of the screening API on the openBIS application server.
brinn
committed
*/
public static final String REQUIRES_OPENBIS_AS_API = "1.7";
brinn
committed
/**
* The required version ("major.minor") of the screening API on the openBIS datastore server.
brinn
committed
*/
public static final String REQUIRES_OPENBIS_DSS_API = "1.1";
private static File dataSetsDir;
/**
* Root temporary directory for data sets and images. By default <code>java.io.tmpdir</code> is
* used.
*/
static File tempDir = new File(System.getProperty("java.io.tmpdir"));
static final String TEMP_DIR_PREFIX = "openbis_";
static final String TEMP_DIR_POSTFIX = "_temp_dir";
brinn
committed
//
// Authentication methods
//
/**
* Login to the openBIS server given as <var>url</var>.
* <p>
* Matlab example:
*
* <pre>
* OpenBISScreeningML.login('user', 'secret', 'https://www.infectome.org')
brinn
committed
* </pre>
*
* @param user The user id on the server
* @param password The password on the server
* @param url The URL, e.g. <code>https://www.infectome.org</var>
*/
public static void login(String user, String password, String url)
{
IScreeningOpenbisServiceFacade facade = facadeFactory.tryToCreate(user, password, url);
if (facade == null)
brinn
committed
{
throw new RuntimeException("Login failed.");
}
init(facade);
}
private static void init(IScreeningOpenbisServiceFacade openBisFacade)
openbis = openBisFacade;
dataSetsDir = new File(tempDir, DATASETS_FOLDER);
if (dataSetsDir.isDirectory() == false && dataSetsDir.mkdirs() == false)
{
throw new RuntimeException("Couldn't create a data set directory.");
}
temporarySessionDir =
new File(tempDir, TEMP_DIR_PREFIX + System.currentTimeMillis() / 1000
+ TEMP_DIR_POSTFIX);
if (temporarySessionDir.mkdirs() == false)
{
throw new RuntimeException("Couldn't create a temporary directory.");
}
loadedImages = new HashMap<PlateImageReference, File>();
brinn
committed
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
experiments = openbis.listExperiments();
experimentCodeToExperimentMap.clear();
for (ExperimentIdentifier e : experiments)
{
experimentCodeToExperimentMap.put(e.getAugmentedCode(), e);
}
plates = openbis.listPlates();
plateCodeToPlateMap.clear();
experimentToPlateMap.clear();
for (Plate p : plates)
{
final String plateCode = p.getAugmentedCode();
plateCodeToPlateMap.put(plateCode, p);
final String experimentCode = p.getExperimentIdentifier().getAugmentedCode();
List<Plate> experimentPlates = experimentToPlateMap.get(experimentCode);
if (experimentPlates == null)
{
experimentPlates = new ArrayList<Plate>();
experimentToPlateMap.put(experimentCode, experimentPlates);
}
experimentPlates.add(p);
}
}
/**
* Logs out and closes the session on the server.
* <p>
* Matlab example:
*
* <pre>
* OpenBISScreeningML.logout()
brinn
committed
* </pre>
*/
public static void logout()
{
if (openbis == null)
{
return;
}
openbis.logout();
if (Login.OPENBIS_TOKEN_FILE.exists())
{
Login.OPENBIS_TOKEN_FILE.delete();
}
delete(temporarySessionDir);
brinn
committed
openbis = null;
}
private static void delete(File file)
{
if (file.isDirectory())
{
File[] files = file.listFiles();
for (File child : files)
{
delete(child);
}
}
file.delete();
}
brinn
committed
//
// Information methods
//
/**
* Lists all experiment.
* <p>
* Matlab example:
*
* <pre>
* % Get the experiments
* exps = OpenBISScreeningML.listExperiments();
brinn
committed
* % How many experiments do we have?
* length(exps)
* % Get all information about experiment 3
* exp3 = exps(3,:)
* % Get the perm ids for all experiments
* permids = exps(:,2)
* </pre>
*
* @return Each row contains information about one experiment:
brinn
committed
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
* <p>
* <code>{ experiment augmented code, experiment perm id, experiment space code,
* experiment project code, experiment code }</code>
*/
public static Object[][] listExperiments()
{
checkLoggedIn();
final Object[][] result = new Object[experiments.size()][5];
for (int i = 0; i < experiments.size(); ++i)
{
final Object[] annotations =
new Object[]
{ experiments.get(i).getAugmentedCode(), experiments.get(i).getPermId(),
experiments.get(i).getSpaceCode(),
experiments.get(i).getProjectCode(),
experiments.get(i).getExperimentCode() };
System.arraycopy(annotations, 0, result[i], 0, annotations.length);
}
return result;
}
/**
* Lists all plates.
* <p>
* Matlab example:
*
* <pre>
* % Get the plates
* plates = OpenBISScreeningML.listPlates();
brinn
committed
* % How many plates do we have?
* length(plates)
* % Get all information about plate 2
* plate2 = plates(2,:)
* % Get the simple plate codes for all plates
* codes = plates(:,4)
* </pre>
*
* @return Each row contains information about one plate:
* <p>
* <code>{ plate augmented code, plate perm id, plate space code, plate code,
* experiment augmented code, experiment perm id, experiment space code,
* experiment project code, experiment code }</code>
*/
public static Object[][] listPlates()
{
checkLoggedIn();
return listPlates(plates);
brinn
committed
}
brinn
committed
/**
* Lists the plates of <var>experiment</var>.
* <p>
* Matlab example:
*
* <pre>
* % Get the plates of experiment MYEXP in project PROJ of space SPACE
* plates = OpenBISScreeningML.listPlates('/SPACE/PROJ/MYEXP');
brinn
committed
* % How many plates do we have?
* length(plates)
* % Get all information about plate 2
* plate2 = plates(2,:)
* % Get the augmented plate codes for all plates
* acodes = plates(:,1)
* </pre>
*
* @param experiment The augmented code of the experiment to list the plates for
* @return Each row contains information about one plate:
* <p>
* <code>{ plate augmented code, plate perm id, plate space code, plate code,
* experiment augmented code, experiment perm id, experiment space code,
* experiment project code, experiment code }</code>
*/
public static Object[][] listPlates(String experiment)
{
checkLoggedIn();
final List<Plate> experimentPlates = experimentToPlateMap.get(experiment);
if (experimentPlates == null)
{
throw new RuntimeException("No experiment with that code found.");
}
return listPlates(experimentPlates);
}
private static Object[][] listPlates(final List<Plate> list)
{
final Object[][] result = new Object[list.size()][9];
for (int i = 0; i < list.size(); ++i)
brinn
committed
{
final Object[] annotations =
new Object[]
{ list.get(i).getAugmentedCode(), plates.get(i).getPermId(),
list.get(i).tryGetSpaceCode(), plates.get(i).getPlateCode(),
list.get(i).getExperimentIdentifier().getAugmentedCode(),
list.get(i).getExperimentIdentifier().getPermId(),
list.get(i).getExperimentIdentifier().getSpaceCode(),
list.get(i).getExperimentIdentifier().getProjectCode(),
list.get(i).getExperimentIdentifier().getExperimentCode(), };
brinn
committed
System.arraycopy(annotations, 0, result[i], 0, annotations.length);
}
return result;
}
/**
* Returns the properties of specified well for specified plate.
* <p>
* Matlab example:
*
* <pre>
* % Get properties for well A03 of plate P005 in space SPACE
* properties = OpenBISScreeningML.getWellProperties('/SPACE/P005', 1, 3)
* % Get property type code of first property
* properties(1,1)
* % Get property value of first property
* properties(1,2)
* </pre>
*
* @param augmentedPlateCode The augmented plate code
* @param row The row in the plate to get the well properties for
* @param column The column in the plate to get the well properties for
* @return A two dimensional array where the first column contains the property codes and the
* second column the corresponding property values.
*/
public static Object[][] getWellProperties(String augmentedPlateCode, int row, int column)
{
checkLoggedIn();
WellPosition wellPosition = new WellPosition(row, column);
WellIdentifier wellIdentifier = getWell(augmentedPlateCode, wellPosition);
List<Map.Entry<String, String>> list =
new ArrayList<Map.Entry<String, String>>(openbis.getWellProperties(wellIdentifier)
.entrySet());
Object[][] result = new Object[list.size()][2];
for (int i = 0; i < list.size(); i++)
{
result[i] = new Object[]
{ list.get(i).getKey(), list.get(i).getValue() };
}
return result;
}
/**
* Updates properties of specified well for specified plate.
* <p>
* Matlab example:
*
* <pre>
* % Updates properties DESCRIPTION and NUMBER for well A03 of plate P005 in space SPACE
* properties = {'DESCRIPTION' 'hello example'; 'NUMBER' 3.14}
* OpenBISScreeningML.updateWellProperties('/SPACE/P005', 1, 3, properties)
* </pre>
*
* @param augmentedPlateCode The augmented plate code
* @param row The row in the plate to get the well properties for
* @param column The column in the plate to get the well properties for
* @param properties A two dimensional array where the first column contains the property codes
* and the second column the corresponding property values.
*/
public static void updateWellProperties(String augmentedPlateCode, int row, int column,
Object[][] properties)
{
checkLoggedIn();
WellPosition wellPosition = new WellPosition(row, column);
WellIdentifier wellIdentifier = getWell(augmentedPlateCode, wellPosition);
openbis.updateWellProperties(wellIdentifier, createMap(properties));
}
private static WellIdentifier getWell(String augmentedPlateCode, WellPosition wellPosition)
{
Plate plate = getPlate(augmentedPlateCode);
List<WellIdentifier> wells = openbis.listPlateWells(plate);
for (WellIdentifier wellIdentifier : wells)
{
if (wellIdentifier.getWellPosition().equals(wellPosition))
{
return wellIdentifier;
}
}
throw new RuntimeException("Plate '" + augmentedPlateCode + "' has no well at "
+ wellPosition + ".");
}
brinn
committed
/**
* Fetches metadata of the image datasets for the specified <var>plate</var>.
* <p>
* Matlab example:
*
* <pre>
* % Get the metadata of image datasets of plate P005 from space SPACE
* imagesMetadata = OpenBISScreeningML.getImagesMetadata('/SPACE/P005');
* % How many image datasets do we have? Usually there will be just one.
* length(imagesMetadata)
* % What is the number of tiles in the first image dataset?
* imagesMetadata(1, 3)
* </pre>
*
* @param augmentedPlateCode The augmented plate code.
* @return <code>{ images width, images height, number of tiles in the well,
* number of tiles rows, number of tiles columns, number of plate rows, number of plate columns }</code>
* .
*/
public static Object[][] getImagesMetadata(String augmentedPlateCode)
{
checkLoggedIn();
final Plate plateId = getPlate(augmentedPlateCode);
final List<ImageDatasetReference> imageDatasets = listRawImageDatasets(plateId);
final List<ImageDatasetMetadata> metaList = openbis.listImageMetadata(imageDatasets);
Object[][] result = new Object[metaList.size()][];
for (int i = 0; i < metaList.size(); ++i)
{
ImageDatasetMetadata meta = metaList.get(i);
ImageDatasetReference imageDatasetReference = imageDatasets.get(i);
Geometry plateGeometry = imageDatasetReference.getPlateGeometry();
result[i] =
new Object[]
{ meta.getWidth(), meta.getHeight(), meta.getNumberOfTiles(),
meta.getTilesRows(), meta.getTilesCols(),
plateGeometry.getNumberOfRows(), plateGeometry.getNumberOfColumns() };
brinn
committed
/**
* Lists all channels measured in <var>experiment</var>.
* <p>
* Matlab example:
*
* <pre>
* % Get the channels of experiment MYEXP in project PROJ of space SPACE
* channels = OpenBISScreeningML.listChannels('/SPACE/PROJ/MYEXP');
brinn
committed
* % How many channels do we have?
* length(channels)
* % What is the name of channel 1?
* channels(1)
* </pre>
*
* @param experiment The augmented code of the experiment to list the channels for
* @return Each row contains information about one channel. Currently the only information
* available is the channel name.
*/
public static Object[][] listChannels(String experiment)
{
checkLoggedIn();
final List<Plate> experimentPlates = experimentToPlateMap.get(experiment);
if (experimentPlates == null)
{
throw new RuntimeException("No experiment with that code found.");
}
if (experimentPlates.isEmpty())
{
return new Object[0][];
}
final List<ImageDatasetReference> imageDatasets =
openbis.listRawImageDatasets(experimentPlates);
brinn
committed
if (imageDatasets.isEmpty())
{
return new Object[0][];
}
final List<ImageDatasetMetadata> meta =
openbis.listImageMetadata(Arrays.asList(imageDatasets.get(0)));
if (meta.isEmpty())
{
return new Object[0][];
}
brinn
committed
Object[][] result = new Object[channels.size()][1];
for (int i = 0; i < result.length; ++i)
{
result[i][0] = channels.get(i);
}
return result;
}
private static List<String> getChannelCodes(final List<ImageDatasetMetadata> meta)
{
return meta.get(0).getChannelCodes();
brinn
committed
/**
* Lists all features computed for <var>experiment</var>.
* <p>
* Matlab example:
*
* <pre>
* % Get the features of experiment MYEXP in project PROJ of space SPACE
* features = OpenBISScreeningML.listFeatures('/SPACE/PROJ/MYEXP');
brinn
committed
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
* % How many features do we have?
* length(features)
* % What is the name of features 1?
* features(1)
* </pre>
*
* @param experiment The augmented code of the experiment to list the features for
* @return Each row contains information about one feature. Currently the only information
* available is the feature name.
*/
public static Object[][] listFeatures(String experiment)
{
checkLoggedIn();
final List<Plate> experimentPlates = experimentToPlateMap.get(experiment);
if (experimentPlates == null)
{
throw new RuntimeException("No experiment with that code found.");
}
if (experimentPlates.isEmpty())
{
return new Object[0][];
}
final List<FeatureVectorDatasetReference> featureDatasets =
openbis.listFeatureVectorDatasets(experimentPlates);
if (featureDatasets.isEmpty())
{
return new Object[0][];
}
final List<String> features = listAvailableFeatureCodes(featureDatasets);
brinn
committed
Object[][] result = new Object[features.size()][1];
for (int i = 0; i < result.length; ++i)
{
result[i][0] = features.get(i);
}
return result;
}
@SuppressWarnings("deprecation")
private static List<String> listAvailableFeatureCodes(
final List<FeatureVectorDatasetReference> featureDatasets)
{
return openbis.listAvailableFeatureNames(Arrays.asList(featureDatasets.get(0)));
}
//
// Data Sets
//
/**
* Loads data sets for specified plate code. For each data set the path to the root of the data
* set is returned. If it is possible the path points directly into the data set store. No data
* is copied. Otherwise the data is retrieved from the data store server.<br>
* If the same dataset is loaded for the second time in one session it will be immediately
* returned from the local cache.
* <p>
* Matlab example:
*
* <pre>
* % Load all data sets of plate P005 in space SPACE
* dsinfo = OpenBISScreeningML.loadDataSets('/SPACE/P005')
* % Get the data set codes
* dsinfo(:,1)
* % Get root path of first data set (assuming there is at least one)
* dsginfo(1,2)
* </pre>
*
* @param augmentedPlateCode The augmented plate code.
* @param datasetTypeCodePattern only datasets of the type which matche the specified pattern
* will be returned. To fetch all datasets specify ".*".
* @param overrideStoreRootPathOrNull A path, in the context of the local file system mounts, to
* the DSS' store root. If null, paths are returned in the context of the DSS' file
* system mounts.
* @return Each row contains information about one data set:
* <p>
* <code>{ data set code, data set root path }</code>
*/
public static Object[][] loadDataSets(String augmentedPlateCode, String datasetTypeCodePattern,
String overrideStoreRootPathOrNull)
checkLoggedIn();
Plate plateIdentifier = getPlate(augmentedPlateCode);
List<IDataSetDss> dataSets = openbis.getDataSets(plateIdentifier, datasetTypeCodePattern);
Object[][] result = new Object[dataSets.size()][];
try
{
for (int i = 0; i < dataSets.size(); i++)
{
IDataSetDss dataSet = dataSets.get(i);
String code = dataSet.getCode();
File file = new File(dataSetsDir, code);
if (file.exists() == false)
{
file =
dataSet.getLinkOrCopyOfContents(overrideStoreRootPathOrNull,
dataSetsDir);
}
result[i] = new Object[]
{ code, file.getPath() };
}
return result;
} catch (Exception ex)
{
throw new RuntimeException("Loading data sets for plate '" + augmentedPlateCode
+ "' failed: " + ex, ex);
}
}
/**
* Uploads specified data set for specified plate. The data set code will be returned.
* <p>
* Matlab example:
*
* <pre>
* % Upload data set /path/to/my-data-set with properties DESCRIPTION and NUMBER for
* % plate P005 in space SPACE
* properties = {'DESCRIPTION' 'hello example'; 'NUMBER' 3.14}
* datasetcode = OpenBISScreeningML.uploadDataSet('/SPACE/P005', '/path/to/my-data-set', 'HCS_IMAGE', properties)
* </pre>
*
* @param augmentedPlateCode The augmented plate code.
* @param dataSetFilePath Path to the data set file/folder to be uploaded.
* @param dataSetType Data set type.
* @param dataSetProperties A two dimensional array where the first column contains the property
* codes and the second column the corresponding property values.
*/
public static Object uploadDataSet(String augmentedPlateCode, String dataSetFilePath,
String dataSetType, Object[][] dataSetProperties)
{
checkLoggedIn();
Plate plateIdentifier = getPlate(augmentedPlateCode);
File dataSetFile = new File(dataSetFilePath);
if (dataSetFile.exists() == false)
{
throw new RuntimeException("Unknown data set file path '" + dataSetFilePath + "'.");
}
try
{
Map<String, String> map = createMap(dataSetProperties);
IDataSetDss dataSet =
openbis.putDataSet(plateIdentifier, dataSetFile, new NewDataSetMetadataDTO(
dataSetType, map));
return dataSet.getCode();
} catch (Exception ex)
{
throw new RuntimeException("Couldn't upload data set for plate '" + augmentedPlateCode
+ "'.", ex);
}
}
private static Map<String, String> createMap(Object[][] properties)
{
Map<String, String> map = new HashMap<String, String>();
for (Object[] objects : properties)
{
if (objects.length == 2)
{
Object value = objects[1];
map.put(objects[0].toString(), value == null ? null : value.toString());
}
}
return map;
}
brinn
committed
//
// Images
//
/**
* Loads the TIFF images for the given well location, all tiles and all channels and stores them
* in temporary files. The temporary files will be removed automatically when the Java Virtual
brinn
committed
* Machine exits.
* <p>
* Matlab example:
*
* <pre>
* % Load the images for all channels of well B10 of plate P005 in space SPACE
* imginfo = OpenBISScreeningML.loadImages('/SPACE/P005', 2, 10)
brinn
committed
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
* % Get the plate-well descriptions of all locations
* imginfo(2,:,3)
* % Show the third image (assuming there are at least three images)
* imtool(imginfo(1,3))
* </pre>
*
* @param plate The augmented plate code
* @param row The row in the plate to get the images for
* @param col The column in the plate to get the images for
* @return <code>{ names of TIFF files, image annotation }</code>
* <p>
* Each of <code>names of TIFF files</code> and <code>image annotation</code> is a
* vector of length of the number of images.
* <p>
* <code>image annotation</code> contains
* <code>{ channel name, tile number, plate well description,
* plate augmented code, plate perm id, plate space code, plate code, row, column,
* experiment augmented code, experiment perm id, experiment space code,
* experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] loadImages(String plate, int row, int col)
{
return loadImages(plate, row, col, (String[]) null);
}
/**
* Loads the TIFF images for the given well location, tile number, and all channels and stores
* them in temporary files. The temporary files will be removed automatically when the Java
* Virtual Machine exits.
* <p>
* Matlab example:
*
* <pre>
* % Load the images for all channels of well B10 and tile 3 of plate P005 in space SPACE
* imginfo = OpenBISScreeningML.loadImages('/SPACE/P005', 2, 10, 3)
* % Get the plate-well descriptions of all locations
* imginfo(2,:,3)
* % Show the third image (assuming there are at least three images)
* imtool(imginfo(1,3))
* </pre>
*
* @param plate The augmented plate code
* @param row The row in the plate to get the images for
* @param col The column in the plate to get the images for
* @param tile The tile number. Starts with 0.
* @return <code>{ names of TIFF files, image annotation }</code>
* <p>
* Each of <code>names of TIFF files</code> and <code>image annotation</code> is a
* vector of length of the number of images.
* <p>
* <code>image annotation</code> contains
* <code>{ channel name, tile number, plate well description,
* plate augmented code, plate perm id, plate space code, plate code, row, column,
* experiment augmented code, experiment perm id, experiment space code,
* experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] loadImages(String plate, int row, int col, int tile)
{
return loadImages(plate, row, col, tile, (String[]) null);
}
/**
* Loads the TIFF images for the given well location, list of channels, and all tiles and stores
* them in temporary files. The temporary files will be removed automatically when the Java
* Virtual Machine exits.
brinn
committed
* <p>
* Matlab example:
*
* <pre>
* % Load the images for channel DAPI of well H10 of plate P005 in space SPACE
* imginfo=OpenBISScreeningML.loadImages('/SPACE/P005', 8, 10, 'DAPI')
brinn
committed
* % Get the channel names and tile numbers of all locations
* imginfo(2,:,1:2)
* % Show the second image (assuming there are at least two images)
* imtool(imginfo(1,2))
* </pre>
*
* @param plate The augmented plate code
* @param row The row in the plate to get the images for
* @param col The column in the plate to get the images for
* @param channels The names of the channels to get the images for
* @return <code>{ names of TIFF files, image annotation }</code>
* <p>
* Each of <code>names of TIFF files</code> and <code>image annotation</code> is a
* vector of length of the number of images.
* <p>
* <code>image annotation</code> contains
* <code>{ channel name, tile number, plate well description,
* plate augmented code, plate perm id, plate space code, plate code, row, column,
* experiment augmented code, experiment perm id, experiment space code,
* experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] loadImages(String plate, int row, int col, String[] channels)
{
return loadImages(plate, row, col, channels, new ITileNumberIterable()
{
private int maximumNumberOfTiles;
public void setMaximumNumberOfTiles(int numberOfTiles)
{
this.maximumNumberOfTiles = numberOfTiles;
}
public int getMaximumNumberOfTiles()
{
return maximumNumberOfTiles;
}
public Iterator<Integer> iterator()
{
return new Iterator<Integer>()
{
private int index;
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
public boolean hasNext()
{
return index < maximumNumberOfTiles;
}
public Integer next()
{
return index++;
}
public void remove()
{
throw new UnsupportedOperationException();
}
};
}
});
}
/**
* Loads the TIFF images for the given well location, tile number, and list of channels and
* stores them in temporary files. The temporary files will be removed automatically when the
* Java Virtual Machine exits.
* <p>
* Matlab example:
*
* <pre>
* % Load the images for channel DAPI of well H10 and tile 3 of plate P005 in space SPACE
* imginfo=OpenBISScreeningML.loadImages('/SPACE/P005', 8, 10, 3, 'DAPI')
* % Get the channel names of all locations
* imginfo(2,:,1)
* % Show the second image (assuming there are at least two images)
* imtool(imginfo(1,2))
* </pre>
*
* @param plate The augmented plate code
* @param row The row in the plate to get the images for
* @param col The column in the plate to get the images for
* @param tile The tile number. Starts with 0.
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1002
1003
1004
1005
1006
1007
* @param channels The names of the channels to get the images for
* @return <code>{ names of TIFF files, image annotation }</code>
* <p>
* Each of <code>names of TIFF files</code> and <code>image annotation</code> is a
* vector of length of the number of images.
* <p>
* <code>image annotation</code> contains
* <code>{ channel name, tile number, plate well description,
* plate augmented code, plate perm id, plate space code, plate code, row, column,
* experiment augmented code, experiment perm id, experiment space code,
* experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] loadImages(String plate, int row, int col, final int tile,
String[] channels)
{
return loadImages(plate, row, col, channels, new ITileNumberIterable()
{
public void setMaximumNumberOfTiles(int numberOfTiles)
{
if (tile >= numberOfTiles)
{
throw new IllegalArgumentException("Tile number " + tile
+ " is not less than number of tiles " + numberOfTiles + ".");
}
}
public int getMaximumNumberOfTiles()
{
return 1;
}
public Iterator<Integer> iterator()
{
return new Iterator<Integer>()
{
private boolean delivered;
public boolean hasNext()
{
return delivered == false;
}
public Integer next()
{
delivered = true;
return tile;
}
public void remove()
{
throw new UnsupportedOperationException();
}
};
}
});
}
private static Object[][][] loadImages(String plate, int row, int col, String[] channels,
ITileNumberIterable tileNumberIterable)
brinn
committed
{
checkLoggedIn();
final Plate plateId = getPlate(plate);
final List<ImageDatasetReference> imageDatasets = listRawImageDatasets(plateId);
final List<ImageDatasetMetadata> meta = openbis.listImageMetadata(imageDatasets);
if (meta.isEmpty())
{
return new Object[][][]
{ new Object[0][], new Object[0][] };
}
brinn
committed
final List<String> imageChannels;
if (channels == null || channels.length == 0)
{
brinn
committed
} else
{
imageChannels = Arrays.asList(channels);
}
final List<ImageReferenceAndFile> imageReferencesAndFiles =
new ArrayList<ImageReferenceAndFile>(imageDatasets.size());
brinn
committed
final Object[][][] result = new Object[2][][];
tileNumberIterable.setMaximumNumberOfTiles(meta.get(0).getNumberOfTiles());
int numberOfTiles = tileNumberIterable.getMaximumNumberOfTiles();
result[0] = new Object[imageDatasets.size() * imageChannels.size() * numberOfTiles][1];
result[1] = new Object[imageDatasets.size() * imageChannels.size() * numberOfTiles][15];
brinn
committed
int dsIdx = 0;
int resultIdx = 0;
for (ImageDatasetReference ds : imageDatasets)
{
for (String channel : imageChannels)
{
for (Integer tile : tileNumberIterable)
brinn
committed
{
final PlateImageReference ref =
new PlateImageReference(row, col, tile, channel, ds);
final File imageFile = createImageFileName(plateId, ref);
imageReferencesAndFiles.add(new ImageReferenceAndFile(ref, imageFile));
brinn
committed
result[0][resultIdx][0] = imageFile.getPath();
PlateIdentifier plateIdentifier = ds.getPlate();
ExperimentIdentifier expIdentifier = ds.getExperimentIdentifier();
brinn
committed
final Object[] annotations =
new Object[]
{ channel, tile,
createPlateWellDescription(plateIdentifier, row, col),
plateIdentifier.getAugmentedCode(),
plateIdentifier.getPermId(),
plateIdentifier.tryGetSpaceCode(),
plateIdentifier.getPlateCode(), row, col,
expIdentifier.getAugmentedCode(),
expIdentifier.getPermId(), expIdentifier.getSpaceCode(),
expIdentifier.getProjectCode(),
expIdentifier.getExperimentCode(), ds.getPermId(), };
brinn
committed
System.arraycopy(annotations, 0, result[1][resultIdx], 0, annotations.length);
resultIdx++;
}
}
dsIdx++;
}
try
{
loadImages(imageReferencesAndFiles);
brinn
committed
} catch (IOException ex)
{
throw new RuntimeException(ex);
}
return result;
}
private static List<ImageDatasetReference> listRawImageDatasets(final Plate plateId)
{
return openbis.listRawImageDatasets(Arrays.asList(plateId));
}
brinn
committed
/**
* Saves images for a given list of image references (given by data set code, well position,
* channel and tile) and files.
brinn
committed
*
* @throws IOException when reading images from the server or writing them to the files fails
*/
private static void loadImages(List<ImageReferenceAndFile> imageReferencesAndFiles)
throws IOException
brinn
committed
{
List<PlateImageReference> imageReferences = new ArrayList<PlateImageReference>();
final Map<PlateImageReference, ImageReferenceAndFile> imageRefToFileMap =
new HashMap<PlateImageReference, ImageReferenceAndFile>();
for (ImageReferenceAndFile imageReferenceAndFile : imageReferencesAndFiles)
{
PlateImageReference imageReference = imageReferenceAndFile.getImageReference();
File file = loadedImages.get(imageReference);
if (file == null)
{
imageReferences.add(imageReference);
imageRefToFileMap.put(imageReference, imageReferenceAndFile);
}
}
brinn
committed
try
{
openbis.loadImages(imageReferences, new IImageOutputStreamProvider()
{
public OutputStream getOutputStream(PlateImageReference imageReference)
throws IOException
{
return imageRefToFileMap.get(imageReference).open();
brinn
committed
}
}, false);
brinn
committed
} finally
{
Collection<ImageReferenceAndFile> values = imageRefToFileMap.values();
for (ImageReferenceAndFile imageReferenceAndFile : values)
{
imageReferenceAndFile.close();
PlateImageReference imageReference = imageReferenceAndFile.getImageReference();
loadedImages.put(imageReference, imageReferenceAndFile.getImageFile());
}
brinn
committed
}
}
brinn
committed
private static File createImageFileName(Plate plate, PlateImageReference image)
{
final WellPosition well = image.getWellPosition();
File imageDir = new File(temporarySessionDir, "images");
imageDir.mkdirs();
final File f =
new File(imageDir, "img_" + plate.getPlateCode() + "_" + image.getDatasetCode()
+ "_row" + well.getWellRow() + "_col" + well.getWellColumn() + "_"
+ image.getChannel() + "_tile" + image.getTile() + ".tiff");
f.deleteOnExit();
return f;
brinn
committed
}
brinn
committed
//
// Feature matrix
//
/**
* Returns the feature matrix of all features for all locations in <var>experiment</var> (a
* location is one well position in one feature vector data set) connected to <var>gene</var> in
* <code>[0]</code>, location annotations in <code>[1]</code> and feature annotation in
* <code>[2]</code>.
* <p>
* One row in the matrix corresponds to one location (i.e. one well and one feature vector
* dataset), one column corresponds to one feature.
* <p>
* Matlab example:
*
* <pre>
* % Get feature matrix for experiment /SPACE/PROJ/MYEXP for locations connected to GENENAME
* fmatrix = OpenBISScreeningML.getFeatureMatrix('/SPACE/PROJ/MYEXP', 'GENENAME');
brinn
committed
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
* % Get the feature vector for the second location (assuming there are at least two locations)
* loc2 = fmatrix(1,2,:)
* % Get the values of the fifth feature for all locations (assuming there are at least 5 features)
* feature5 = fmatrix(1,:,5)
* % What are the features?
* featureNames = fmatrix(3,:)
* % Get the plate-well descriptions of the locations
* locationDescriptions = fmatrix(2,:,1)
* </pre>
*
* @param experiment The augmented experiment code
* @param gene The gene name as stored as material code in openBIS
* @return <code>{ feature matrix, annotations per location, feature names }</code> where
* <code>annotations per location</code> contain:
* <p>
* <code>{ plate well description, plate augmented code, plate perm id,
* plate space code, plate code, row, column, experiment augmented code, experiment perm
* id, experiment space code, experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] getFeatureMatrix(String experiment, String gene)
{
return getFeatureMatrix(experiment, gene, (String[]) null);
}
/**
* Returns the feature matrix of the specified features for all locations in
* <var>experiment</var> (a location is one well position in one feature vector data set) in
* <var>experiment</var> connected to <var>gene</var> in <code>[0]</code>, location annotations
* in <code>[1]</code> and feature annotation in <code>[2]</code>.
* <p>
* One row in the matrix corresponds to one location (i.e. one well and one feature vector
* dataset), one column corresponds to one feature.
* <p>
* Matlab example:
*
* <pre>
* % Get feature matrix for features FEATURE1, FEATURE2 and FEATURE for
* % experiment /SPACE/PROJ/MYEXP for locations connected to GENENAME
* fmatrix = OpenBISScreeningML.getFeatureMatrix('/SPACE/PROJ/MYEXP', 'GENENAME', ('FEATURE1','FEATURE2','FEATURE3'));
brinn
committed
1198
1199
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
1232
1233
* % Get the feature vector for the second location (assuming there are at least two locations)
* loc2 = fmatrix(1,2,:)
* % Get the values of the fourth feature for all locations (assuming there are at least 4 features)
* feature5 = fmatrix(1,:,4)
* % What are the features?
* featureNames = fmatrix(3,:)
* % Get the plate-well descriptions of the locations
* locationDescriptions = fmatrix(2,:,1)
* </pre>
*
* @param experiment The augmented experiment code
* @param gene The gene name as stored as material code
* @param features The names of the features to contain the feature matrix
* @return <code>{ feature matrix, annotations per location, feature names }</code> where
* <code>annotations per location</code> contain:
* <p>
* <code>{ plate well description, plate augmented code, plate perm id,
* plate space code, plate code, row, column, experiment augmented code, experiment perm
* id, experiment space code, experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] getFeatureMatrix(String experiment, String gene, String[] features)
{
checkLoggedIn();
final ExperimentIdentifier experimentId = experimentCodeToExperimentMap.get(experiment);
if (experimentId == null)
{
throw new RuntimeException("No experiment with that code found.");
}
final List<Plate> experimentPlates = experimentToPlateMap.get(experiment);
if (experimentPlates == null || experimentPlates.isEmpty())
{
return new Object[][][]
{ new Object[0][], new Object[0][], new Object[0][] };
}
final List<FeatureVectorWithDescription> featureVectors =
openbis.loadFeaturesForPlateWells(experimentId, new MaterialIdentifier(
MaterialTypeIdentifier.GENE, gene),
(features == null) ? null : Arrays.asList(features));
brinn
committed
1236
1237
1238
1239
1240
1241
1242
1243
1244
1245
1246
1247
1248
1249
1250
1251
1252
1253
1254
1255
1256
1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
1288
1289
1290
1291
final List<String> featureNameList =
featureVectors.get(featureVectors.size() - 1).getFeatureNames();
final Object[][][] result = new Object[3][][];
if (featureVectors.isEmpty())
{
return result;
}
result[0] = new Object[featureVectors.size()][featureNameList.size()];
result[1] = new Object[featureVectors.size()][13];
int resultIdx = 0;
for (FeatureVectorWithDescription f : featureVectors)
{
arraycopy(f.getValues(), result[0][resultIdx]);
final Object[] annotations =
new Object[]
{
createPlateWellDescription(f),
f.getDatasetWellReference().getPlate().getAugmentedCode(),
f.getDatasetWellReference().getPlate().getPermId(),
f.getDatasetWellReference().getPlate().tryGetSpaceCode(),
f.getDatasetWellReference().getPlate().getPlateCode(),
f.getWellPosition().getWellRow(),
f.getWellPosition().getWellColumn(),
f.getDatasetWellReference().getExperimentIdentifier()
.getAugmentedCode(),
f.getDatasetWellReference().getExperimentIdentifier().getPermId(),
f.getDatasetWellReference().getExperimentIdentifier()
.getSpaceCode(),
f.getDatasetWellReference().getExperimentIdentifier()
.getProjectCode(),
f.getDatasetWellReference().getExperimentIdentifier()
.getExperimentCode(),
f.getDatasetWellReference().getDatasetCode(), };
System.arraycopy(annotations, 0, result[1][resultIdx], 0, annotations.length);
resultIdx++;
}
result[2] = new Object[featureNameList.size()][1];
for (int i = 0; i < featureNameList.size(); ++i)
{
result[2][i][0] = featureNameList.get(i);
}
return result;
}
/**
* Returns the feature matrix of all features for all locations (a location is one well position
* in one feature vector data set) connected to <var>gene</var> in <code>[0]</code>, location
* annotations in <code>[1]</code> and feature annotation in <code>[2]</code>.
* <p>
* One row in the matrix corresponds to one location (i.e. one well and one feature vector
* dataset), one column corresponds to one feature.
* <p>
* Matlab example:
*
* <pre>
* % Get feature matrix for GENENAME
* fmatrix = OpenBISScreeningML.getFeatureMatrix('GENENAME');
brinn
committed
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
1304
1305
1306
1307
1308
1309
1310
1311
1312
1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
1325
1326
1327
1328
* % Get the feature vector for the second location (assuming there are at least two locations)
* loc2 = fmatrix(1,2,:)
* % Get the values of the fifth feature for all locations (assuming there are at least 5 features)
* feature5 = fmatrix(1,:,5)
* % What are the features?
* featureNames = fmatrix(3,:)
* % Get the plate-well descriptions of the locations
* locationDescriptions = fmatrix(2,:,1)
* </pre>
*
* @param gene The gene name as stored as material code in openBIS
* @return <code>{ feature matrix, annotations per location, feature names }</code> where
* <code>annotations per location</code> contain:
* <p>
* <code>{ plate well description, plate augmented code, plate perm id,
* plate space code, plate code, row, column, experiment augmented code, experiment perm
* id, experiment space code, experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] getFeatureMatrix(String gene)
{
return getFeatureMatrix(gene, (String[]) null);
}
/**
* Returns the feature matrix of the specified features for all locations (a location is one
* well position in one feature vector data set) in <var>experiment</var> connected to
* <var>gene</var> in <code>[0]</code>, location annotations in <code>[1]</code> and feature
* annotation in <code>[2]</code>.
* <p>
* One row in the matrix corresponds to one location (i.e. one well and one feature vector
* dataset), one column corresponds to one feature.
* <p>
* Matlab example:
*
* <pre>
* % Get feature matrix for features FEATURE1, FEATURE2 and FEATURE for GENENAME
* fmatrix = OpenBISScreeningML.getFeatureMatrix('GENENAME', ('FEATURE1','FEATURE2','FEATURE3'));
brinn
committed
* % Get the feature vector for the second location (assuming there are at least two locations)
* loc2 = fmatrix(1,2,:)
* % Get the values of the second feature ('FEATURE2' here) for all locations
* feature2 = fmatrix(1,:,2)
brinn
committed
* % What are the features?
* featureNames = fmatrix(3,:)
* % Get the plate-well descriptions of the locations
* locationDescriptions = fmatrix(2,:,1)
* </pre>
*
* @param gene The gene name as stored as material code
* @param features The names of the features to contain the feature matrix
* @return <code>{ feature matrix, annotations per location, feature names }</code> where
* <code>annotations per location</code> contain:
* <p>
* <code>{ plate well description, plate augmented code, plate perm id,
* plate space code, plate code, row, column, experiment augmented code, experiment perm
* id, experiment space code, experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] getFeatureMatrix(String gene, String[] features)
{
checkLoggedIn();
final List<FeatureVectorWithDescription> featureVectors =
openbis.loadFeaturesForPlateWells(new MaterialIdentifier(
MaterialTypeIdentifier.GENE, gene),
(features == null) ? null : Arrays.asList(features));
brinn
committed
1356
1357
1358
1359
1360
1361
1362
1363
1364
1365
1366
1367
1368
1369
1370
1371
1372
1373
1374
1375
1376
1377
1378
1379
1380
1381
1382
1383
1384
1385
1386
1387
1388
1389
1390
1391
1392
1393
1394
1395
1396
1397
1398
1399
final List<String> featureNameList =
featureVectors.get(featureVectors.size() - 1).getFeatureNames();
final Object[][][] result = new Object[3][][];
if (featureVectors.isEmpty())
{
return result;
}
result[0] = new Object[featureVectors.size()][featureNameList.size()];
result[1] = new Object[featureVectors.size()][13];
int resultIdx = 0;
for (FeatureVectorWithDescription f : featureVectors)
{
arraycopy(f.getValues(), result[0][resultIdx]);
final Object[] annotations =
new Object[]
{
createPlateWellDescription(f),
f.getDatasetWellReference().getPlate().getAugmentedCode(),
f.getDatasetWellReference().getPlate().getPermId(),
f.getDatasetWellReference().getPlate().tryGetSpaceCode(),
f.getDatasetWellReference().getPlate().getPlateCode(),
f.getWellPosition().getWellRow(),
f.getWellPosition().getWellColumn(),
f.getDatasetWellReference().getExperimentIdentifier()
.getAugmentedCode(),
f.getDatasetWellReference().getExperimentIdentifier().getPermId(),
f.getDatasetWellReference().getExperimentIdentifier()
.getSpaceCode(),
f.getDatasetWellReference().getExperimentIdentifier()
.getProjectCode(),
f.getDatasetWellReference().getExperimentIdentifier()
.getExperimentCode(),
f.getDatasetWellReference().getDatasetCode(), };
System.arraycopy(annotations, 0, result[1][resultIdx], 0, annotations.length);
resultIdx++;
}
result[2] = new Object[featureNameList.size()][1];
for (int i = 0; i < featureNameList.size(); ++i)
{
result[2][i][0] = featureNameList.get(i);
}
return result;
}
/**
* Returns the feature matrix of all available features for all locations (a location is one
* well position in one feature vector data set) of all feature vector data sets of the given
* <var>plate</var> in <code>[0]</code>, location annotations in <code>[1]</code> and feature
* annotation in <code>[2]</code>.
* <p>
* One row in the matrix corresponds to one location (i.e. one well and one feature vector
* dataset), one column corresponds to one feature.
* <p>
* Matlab example:
*
* <pre>
* % Get feature matrix for PLATECODE
* fmatrix = OpenBISScreeningML.getFeatureMatrixForPlate('PLATECODE');
1414
1415
1416
1417
1418
1419
1420
1421
1422
1423
1424
1425
1426
1427
1428
1429
1430
1431
1432
1433
1434
1435
1436
1437
1438
1439
1440
1441
1442
1443
1444
1445
1446
1447
1448
1449
* % Get the feature vector for the second location (assuming there are at least two locations)
* loc2 = fmatrix(1,2,:)
* % Get the values of the fourth feature for all locations (assuming there are at least 4 features)
* feature5 = fmatrix(1,:,4)
* % What are the features?
* featureNames = fmatrix(3,:)
* % Get the plate-well descriptions of the locations
* locationDescriptions = fmatrix(2,:,1)
* </pre>
*
* @param plate The gene name as stored as material code
* @return <code>{ feature matrix, annotations per location, feature names }</code> where
* <code>annotations per location</code> contain:
* <p>
* <code>{ plate well description, plate augmented code, plate perm id,
* plate space code, plate code, row, column, experiment augmented code, experiment perm
* id, experiment space code, experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] getFeatureMatrixForPlate(String plate)
{
return getFeatureMatrixForPlate(plate, (String[]) null);
}
/**
* Returns the feature matrix of the specified features for all locations (a location is one
* well position in one feature vector data set) of all feature vector data sets of the given
* <var>plate</var> in <code>[0]</code>, location annotations in <code>[1]</code> and feature
* annotation in <code>[2]</code>.
* <p>
* One row in the matrix corresponds to one location (i.e. one well and one feature vector
* dataset), one column corresponds to one feature.
* <p>
* Matlab example:
*
* <pre>
* % Get feature matrix for features FEATURE1, FEATURE2 and FEATURE for PLATECODE
* fmatrix = OpenBISScreeningML.getFeatureMatrixForPlate('PLATECODE', ('FEATURE1','FEATURE2','FEATURE3'));
1451
1452
1453
1454
1455
1456
1457
1458
1459
1460
1461
1462
1463
1464
1465
1466
1467
1468
1469
1470
1471
1472
1473
* % Get the feature vector for the second location (assuming there are at least two locations)
* loc2 = fmatrix(1,2,:)
* % Get the values of the second feature for all locations
* feature5 = fmatrix(1,:,2)
* % What are the features?
* featureNames = fmatrix(3,:)
* % Get the plate-well descriptions of the locations
* locationDescriptions = fmatrix(2,:,1)
* </pre>
*
* @param plate The gene name as stored as material code
* @param features The names of the features to contain the feature matrix
* @return <code>{ feature matrix, annotations per location, feature names }</code> where
* <code>annotations per location</code> contain:
* <p>
* <code>{ plate well description, plate augmented code, plate perm id,
* plate space code, plate code, row, column, experiment augmented code, experiment perm
* id, experiment space code, experiment project code, experiment code, data set code }</code>
*/
public static Object[][][] getFeatureMatrixForPlate(String plate, String[] features)
{
checkLoggedIn();
final List<FeatureVectorDataset> featureVectors =
openbis.loadFeaturesForPlates(
Arrays.asList(PlateIdentifier.createFromAugmentedCode(plate)),
(features == null) ? null : Arrays.asList(features));
FeatureVectorDataset last = featureVectors.get(featureVectors.size() - 1);
final List<String> featureCodeList = getFeatureCodes(last);
final Object[][][] result = new Object[3][][];
if (featureVectors.isEmpty())
{
return result;
}
int numberOfRows = 0;
for (FeatureVectorDataset fvds : featureVectors)
{
numberOfRows += fvds.getFeatureVectors().size();
}
result[0] = new Object[numberOfRows][featureCodeList.size()];
1490
1491
1492
1493
1494
1495
1496
1497
1498
1499
1500
1501
1502
1503
1504
1505
1506
1507
1508
1509
1510
1511
1512
1513
1514
1515
1516
result[1] = new Object[numberOfRows][13];
int resultIdx = 0;
for (FeatureVectorDataset fvds : featureVectors)
{
final FeatureVectorDatasetReference datasetRef = fvds.getDataset();
for (FeatureVector f : fvds.getFeatureVectors())
{
arraycopy(f.getValues(), result[0][resultIdx]);
final Object[] annotations =
new Object[]
{ createPlateWellDescription(datasetRef.getPlate(), f),
datasetRef.getPlate().getAugmentedCode(),
datasetRef.getPlate().getPermId(),
datasetRef.getPlate().tryGetSpaceCode(),
datasetRef.getPlate().getPlateCode(),
f.getWellPosition().getWellRow(),
f.getWellPosition().getWellColumn(),
datasetRef.getExperimentIdentifier().getAugmentedCode(),
datasetRef.getExperimentIdentifier().getPermId(),
datasetRef.getExperimentIdentifier().getSpaceCode(),
datasetRef.getExperimentIdentifier().getProjectCode(),
datasetRef.getExperimentIdentifier().getExperimentCode(),
datasetRef.getDatasetCode(), };
System.arraycopy(annotations, 0, result[1][resultIdx], 0, annotations.length);
resultIdx++;
}
}
result[2] = new Object[featureCodeList.size()][1];
for (int i = 0; i < featureCodeList.size(); ++i)
@SuppressWarnings("deprecation")
private static List<String> getFeatureCodes(FeatureVectorDataset last)
{
return last.getFeatureNames();
}
1531
1532
1533
1534
1535
1536
1537
1538
1539
1540
1541
1542
1543
1544
1545
1546
1547
1548
1549
1550
1551
1552
1553
1554
1555
1556
1557
1558
/**
* Returns the gene mapping for the given <var>plateCodes</var> in <code>[0]</code> and location
* annotations in <code>[1]</code>.
* <p>
* One row in the matrix corresponds to one well.
* <p>
* Matlab example:
*
* <pre>
* % Get feature matrix for features FEATURE1, FEATURE2 and FEATURE for PLATECODE
* genes = getGeneMappingForPlate('PLATECODE');
* % Get the plate well location description of the 10th wells
* loc2 = genes(2,10,1)
* % Get the gene ids that are in the 10th well
* geneIds = genes(1,10,:)
* </pre>
*
* @param platesCodes The augmented codes of the plates to get the mapping for
* @return <code>{ gene ids, annotations per well }</code> where <code>gene ids</code> can be 0,
* 1 or more gene ids. <code>annotations per location</code> contain:
* <p>
* <code>{ plate well description, plate augmented code, plate perm id,
* plate space code, plate code, row, column }</code>
*/
public static Object[][][] getGeneMappingForPlates(String[] platesCodes)
{
checkLoggedIn();
final List<PlateWellMaterialMapping> mappingList =
openbis.listPlateMaterialMapping(toPlates(platesCodes), MaterialTypeIdentifier.GENE);
1560
1561
1562
1563
1564
1565
1566
1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
1577
1578
1579
1580
1581
1582
1583
1584
1585
1586
1587
1588
1589
1590
1591
1592
1593
int size = 0;
for (PlateWellMaterialMapping mapping : mappingList)
{
size +=
mapping.getPlateGeometry().getNumberOfRows()
* mapping.getPlateGeometry().getNumberOfColumns();
}
final Object[][][] result = new Object[2][size][];
int resultIdx = 0;
for (PlateWellMaterialMapping mapping : mappingList)
{
for (int row = 1; row <= mapping.getPlateGeometry().getNumberOfRows(); ++row)
{
for (int col = 1; col <= mapping.getPlateGeometry().getNumberOfColumns(); ++col)
{
final List<MaterialIdentifier> genes = mapping.getMaterialsForWell(row, col);
result[0][resultIdx] = new Object[genes.size()];
for (int i = 0; i < genes.size(); ++i)
{
result[0][resultIdx][i] = genes.get(i).getMaterialCode();
}
final PlateIdentifier plate = mapping.getPlateIdentifier();
result[1][resultIdx] =
new Object[]
{ createPlateWellDescription(plate, row, col),
plate.getAugmentedCode(), plate.getPermId(),
plate.tryGetSpaceCode(), plate.getPlateCode(), row, col, };
++resultIdx;
}
}
}
return result;
}
brinn
committed
//
// Helper methods
//
private static List<PlateIdentifier> toPlates(String[] augmentedPlateCodes)
{
final List<PlateIdentifier> result =
new ArrayList<PlateIdentifier>(augmentedPlateCodes.length);
for (String plateCode : augmentedPlateCodes)
{
result.add(PlateIdentifier.createFromAugmentedCode(plateCode));
}
return result;
}
private static Plate getPlate(String augmentedPlateCode)
{
Plate plateIdentifier = plateCodeToPlateMap.get(augmentedPlateCode);
if (plateIdentifier == null)
{
throw new RuntimeException("No plate with that code '" + augmentedPlateCode
+ "' found.");
}
return plateIdentifier;
}
brinn
committed
private static void arraycopy(double[] src, Object[] dest)
{
for (int i = 0; i < dest.length; ++i)
{
dest[i] = src[i];
}
}
private static String createPlateWellDescription(FeatureVectorWithDescription f)
{
return createPlateWellDescription(f.getDatasetWellReference().getPlate(), f
.getWellPosition().getWellRow(), f.getWellPosition().getWellColumn());
}
private static String createPlateWellDescription(PlateIdentifier p, FeatureVector f)
{
return createPlateWellDescription(p, f.getWellPosition().getWellRow(), f.getWellPosition()
.getWellColumn());
}
brinn
committed
1640
1641
1642
1643
1644
1645
1646
1647
1648
1649
1650
1651
1652
1653
1654
1655
1656
1657
1658
1659
1660
1661
1662
1663
1664
private static String createPlateWellDescription(PlateIdentifier p, int row, int col)
{
return p.getPlateCode() + ":" + translateRowNumberIntoLetterCode(row) + col;
}
/**
* Translates a row number into letter code. Thus, 1 -> A, 2 -> B, 26 -> Z, 27 -> AA, 28 -> AB,
* etc.
*/
private static String translateRowNumberIntoLetterCode(int rowNumber)
{
int rowIndex = rowNumber - 1;
String code = "";
while (rowIndex >= 0)
{
code = (char) (rowIndex % 26 + 'A') + code;
rowIndex = rowIndex / 26 - 1;
}
return code;
}
private static void checkLoggedIn()
{
if (openbis == null)
{
if (Login.OPENBIS_TOKEN_FILE.exists())
{
BufferedReader br = null;
try
{
br = new BufferedReader(new FileReader(Login.OPENBIS_TOKEN_FILE));
final String token = br.readLine();
br.close();
br = new BufferedReader(new FileReader(Login.OPENBIS_SERVER_URL_FILE));
final String serverUrl = br.readLine();
br.close();
br = null;
IScreeningOpenbisServiceFacade facade =
facadeFactory.tryToCreate(token, serverUrl);
if (facade == null)
{
throw new RuntimeException("Login failed.");
}
init(facade);
1684
1685
1686
1687
1688
1689
1690
1691
1692
1693
1694
1695
1696
1697
1698
1699
1700
1701
1702
1703
1704
1705
1706
1707
} catch (IOException ex)
{
if (openbis == null)
{
throw new RuntimeException("Login failed.", ex);
}
} finally
{
if (br != null)
{
try
{
br.close();
} catch (IOException ex)
{
// Silence this.
}
}
}
}
if (openbis == null)
{
throw new RuntimeException("Not logged in.");
}