Examples of BlobException

Examples of com.alexkasko.springjdbc.blob.BlobException

15
16
17
18
19
20
21
22
23
24
25
26
27
    /**
     * {@inheritDoc}
     */
    @Override
    public OutputStream wrapCompress(OutputStream out) {
        if(null == out) throw new BlobException("Provided OutputStream is null");
        try {
            return wrapCompressInternal(out);
        } catch (Exception e) {
            if(e instanceof BlobException) throw (BlobException) e;
            throw new BlobException("Error on compressing", e);
        }
    }
View Full Code Here

Examples of com.alexkasko.springjdbc.blob.BlobException

29
30
31
32
33
34
35
36
37
38
39
40
41
    /**
     * {@inheritDoc}
     */
    @Override
    public InputStream wrapDecompress(InputStream in) {
        if(null == in) throw new BlobException("Provided InputStream is null");
        try {
            return wrapDecompressInternal(in);
        } catch (Exception e) {
            if(e instanceof BlobException) throw (BlobException) e;
            throw new BlobException("Error on decompressing", e);
        }
    }
View Full Code Here

Examples of org.lilyproject.repository.api.BlobException

58
59
60
61
62
63
64
65
66
        blobKey = Bytes.add(blobKey, Bytes.toBytes(uuid.getLeastSignificantBits()));
        FSDataOutputStream fsDataOutputStream;
        try {
            fsDataOutputStream = fileSystem.create(createPath(uuid));
        } catch (IOException e) {
            throw new BlobException("Failed to open an outputstream for blob '" + blob + "' on the DFS blobstore", e);
        }
        return new DFSBlobOutputStream(fsDataOutputStream, blobKey, blob);
    }
View Full Code Here

Examples of org.lilyproject.repository.api.BlobException

70
71
72
73
74
75
76
77
    public InputStream getInputStream(byte[] blobKey) throws BlobException {
        UUID uuid = decode(blobKey);
        try {
            return fileSystem.open(createPath(uuid));
        } catch (IOException e) {
            throw new BlobException("Failed to open an inputstream for blobkey '" + Hex.encodeHexString(blobKey) + "' on the DFS blobstore", e);
        }
    }
View Full Code Here

Examples of org.lilyproject.repository.api.BlobException

90
91
92
93
94
95
96
97
    public void delete(byte[] blobKey) throws BlobException {
        UUID uuid = decode(blobKey);
        try {
            fileSystem.delete(createPath(uuid), false);
        } catch (IOException e) {
            throw new BlobException("Failed to delete blob with key '" + Hex.encodeHexString(blobKey) +"' from the DFS blobstore", e);
        }
    }
View Full Code Here

Examples of org.lilyproject.repository.api.BlobException

74
75
76
77
78
79
80
81
82
        }
        Pair<String, byte[]> decodedKey;
        try {
            decodedKey = decode(blob.getValue());
        } catch (Exception e) {
            throw new BlobException("Failed to decode the blobkey of the blob '" + blob + "'", e);
        }
        return decodedKey;
    }
View Full Code Here

Examples of org.lilyproject.repository.api.BlobException

74
75
76
77
78
79
80
81
82
83
84
    @Override
    public BlobAccess getBlobAccess(Record record, QName fieldName, FieldType fieldType, int...indexes)
            throws BlobException {
        if (!(fieldType.getValueType().getDeepestValueType() instanceof BlobValueType)) {
            throw new BlobException("Cannot read a blob from a non-blob field type: " + fieldType.getName());
        }

        Blob blob = getBlobFromRecord(record, fieldName, fieldType, indexes);
        return registry.getBlobAccess(blob);
    }
View Full Code Here

Examples of org.lilyproject.repository.api.BlobException

87
88
89
90
91
92
93
94
95
96
97
98
99
        get.addColumn(BLOBS_COLUMN_FAMILY_BYTES, BLOB_COLUMN);
        Result result;
        try {
            result = table.get(get);
        } catch (IOException e) {
            throw new BlobException("Failed to open an inputstream for blobkey '" + Hex.encodeHexString(blobKey) + "' on the HBASE blobstore", e);
        }
        byte[] value = result.getValue(BLOBS_COLUMN_FAMILY_BYTES, BLOB_COLUMN);
        if (value == null) {
            throw new BlobException("Failed to open an inputstream for blobkey '" + Hex.encodeHexString(blobKey) + "' since no blob was found on the HBASE blobstore");
        }
        return new ByteArrayInputStream(value);
    }
View Full Code Here

Examples of org.lilyproject.repository.api.BlobException

102
103
104
105
106
107
108
109
    public void delete(byte[] blobKey) throws BlobException {
        Delete delete = new Delete(blobKey);
        try {
            table.delete(delete);
        } catch (IOException e) {
            throw new BlobException("Failed to delete blob with key '" + Hex.encodeHexString(blobKey) + "' from the DFS blobstore", e);
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.