annotate rdf/RDFFeatureWriter.cpp @ 504:3376dc26dece

* Add FeatureWriter method to set basic track metadata; write it out from RDFFeatureWriter if present
author Chris Cannam
date Fri, 05 Dec 2008 11:09:44 +0000
parents 83eae5239db6
children 0944d13689b2
rev   line source
Chris@498 1 /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*- vi:set ts=8 sts=4 sw=4: */
Chris@498 2
Chris@498 3 /*
Chris@498 4 Sonic Annotator
Chris@498 5 A utility for batch feature extraction from audio files.
Chris@498 6 Mark Levy, Chris Sutton and Chris Cannam, Queen Mary, University of London.
Chris@498 7 Copyright 2007-2008 QMUL.
Chris@498 8
Chris@498 9 This program is free software; you can redistribute it and/or
Chris@498 10 modify it under the terms of the GNU General Public License as
Chris@498 11 published by the Free Software Foundation; either version 2 of the
Chris@498 12 License, or (at your option) any later version. See the file
Chris@498 13 COPYING included with this distribution for more information.
Chris@498 14 */
Chris@498 15
Chris@498 16 #include <fstream>
Chris@498 17
Chris@498 18 #include "vamp-hostsdk/PluginHostAdapter.h"
Chris@498 19 #include "vamp-hostsdk/PluginLoader.h"
Chris@498 20
Chris@498 21 #include "RDFFeatureWriter.h"
Chris@498 22 #include "RDFTransformFactory.h"
Chris@498 23
Chris@498 24 #include <QTextStream>
Chris@498 25 #include <QUrl>
Chris@498 26 #include <QRegExp>
Chris@498 27
Chris@498 28 using namespace std;
Chris@498 29 using Vamp::Plugin;
Chris@498 30 using Vamp::PluginBase;
Chris@498 31
Chris@498 32 RDFFeatureWriter::RDFFeatureWriter() :
Chris@498 33 FileFeatureWriter(SupportOneFilePerTrackTransform |
Chris@498 34 SupportOneFilePerTrack |
Chris@498 35 SupportOneFileTotal,
Chris@498 36 "n3"),
Chris@498 37 m_plain(false),
Chris@498 38 m_count(0)
Chris@498 39 {
Chris@498 40 }
Chris@498 41
Chris@498 42 RDFFeatureWriter::~RDFFeatureWriter()
Chris@498 43 {
Chris@498 44 }
Chris@498 45
Chris@498 46 RDFFeatureWriter::ParameterList
Chris@498 47 RDFFeatureWriter::getSupportedParameters() const
Chris@498 48 {
Chris@498 49 ParameterList pl = FileFeatureWriter::getSupportedParameters();
Chris@498 50 Parameter p;
Chris@498 51
Chris@498 52 p.name = "plain";
Chris@498 53 p.description = "Use \"plain\" RDF even if transform metadata is available.";
Chris@498 54 p.hasArg = false;
Chris@498 55 pl.push_back(p);
Chris@498 56
Chris@498 57 p.name = "signal-uri";
Chris@498 58 p.description = "Link the output RDF to the given signal URI.";
Chris@498 59 p.hasArg = true;
Chris@498 60 pl.push_back(p);
Chris@498 61
Chris@498 62 return pl;
Chris@498 63 }
Chris@498 64
Chris@498 65 void
Chris@498 66 RDFFeatureWriter::setParameters(map<string, string> &params)
Chris@498 67 {
Chris@498 68 FileFeatureWriter::setParameters(params);
Chris@498 69
Chris@498 70 for (map<string, string>::iterator i = params.begin();
Chris@498 71 i != params.end(); ++i) {
Chris@498 72 if (i->first == "plain") {
Chris@498 73 m_plain = true;
Chris@498 74 }
Chris@498 75 if (i->first == "signal-uri") {
Chris@498 76 m_suri = i->second.c_str();
Chris@498 77 }
Chris@498 78 }
Chris@498 79 }
Chris@498 80
Chris@504 81 void
Chris@504 82 RDFFeatureWriter::setTrackMetadata(QString trackId,
Chris@504 83 TrackMetadata metadata)
Chris@504 84 {
Chris@504 85 std::cerr << "RDFFeatureWriter::setTrackMetadata: \""
Chris@504 86 << trackId.toStdString() << "\" -> \"" << metadata.title.toStdString() << "\",\"" << metadata.maker.toStdString() << "\"" << std::endl;
Chris@504 87 m_metadata[trackId] = metadata;
Chris@504 88 }
Chris@504 89
Chris@504 90 void
Chris@504 91 RDFFeatureWriter::write(QString trackId,
Chris@504 92 const Transform &transform,
Chris@504 93 const Plugin::OutputDescriptor& output,
Chris@504 94 const Plugin::FeatureList& features,
Chris@504 95 std::string summaryType)
Chris@498 96 {
Chris@498 97 QString pluginId = transform.getPluginIdentifier();
Chris@498 98
Chris@498 99 if (m_rdfDescriptions.find(pluginId) == m_rdfDescriptions.end()) {
Chris@498 100
Chris@498 101 m_rdfDescriptions[pluginId] = PluginRDFDescription(pluginId);
Chris@498 102
Chris@498 103 if (m_rdfDescriptions[pluginId].haveDescription()) {
Chris@498 104 cerr << "NOTE: Have RDF description for plugin ID \""
Chris@498 105 << pluginId.toStdString() << "\"" << endl;
Chris@498 106 } else {
Chris@498 107 cerr << "NOTE: Do not have RDF description for plugin ID \""
Chris@498 108 << pluginId.toStdString() << "\"" << endl;
Chris@498 109 }
Chris@498 110 }
Chris@498 111
Chris@498 112 // Need to select appropriate output file for our track/transform
Chris@498 113 // combination
Chris@498 114
Chris@498 115 QTextStream *stream = getOutputStream(trackId, transform.getIdentifier());
Chris@498 116 if (!stream) return; //!!! this is probably better handled with an exception
Chris@498 117
Chris@498 118 if (m_startedStreamTransforms.find(stream) ==
Chris@498 119 m_startedStreamTransforms.end()) {
Chris@498 120 cerr << "This stream is new, writing prefixes" << endl;
Chris@498 121 writePrefixes(stream);
Chris@498 122 if (m_singleFileName == "" && !m_stdout) {
Chris@498 123 writeSignalDescription(stream, trackId);
Chris@498 124 }
Chris@498 125 }
Chris@498 126
Chris@498 127 if (m_startedStreamTransforms[stream].find(transform) ==
Chris@498 128 m_startedStreamTransforms[stream].end()) {
Chris@498 129 m_startedStreamTransforms[stream].insert(transform);
Chris@498 130 writeLocalFeatureTypes
Chris@498 131 (stream, transform, output, m_rdfDescriptions[pluginId]);
Chris@498 132 }
Chris@498 133
Chris@498 134 if (m_singleFileName != "" || m_stdout) {
Chris@498 135 if (m_startedTrackIds.find(trackId) == m_startedTrackIds.end()) {
Chris@498 136 writeSignalDescription(stream, trackId);
Chris@498 137 m_startedTrackIds.insert(trackId);
Chris@498 138 }
Chris@498 139 }
Chris@498 140
Chris@498 141 QString timelineURI = m_trackTimelineURIs[trackId];
Chris@498 142
Chris@498 143 if (timelineURI == "") {
Chris@498 144 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing features without having established a timeline URI!" << endl;
Chris@498 145 exit(1);
Chris@498 146 }
Chris@498 147
Chris@498 148 if (summaryType != "") {
Chris@498 149
Chris@498 150 writeSparseRDF(stream, transform, output, features,
Chris@498 151 m_rdfDescriptions[pluginId], timelineURI);
Chris@498 152
Chris@498 153 } else if (m_rdfDescriptions[pluginId].haveDescription() &&
Chris@498 154 m_rdfDescriptions[pluginId].getOutputDisposition
Chris@498 155 (output.identifier.c_str()) ==
Chris@498 156 PluginRDFDescription::OutputDense) {
Chris@498 157
Chris@498 158 QString signalURI = m_trackSignalURIs[trackId];
Chris@498 159
Chris@498 160 if (signalURI == "") {
Chris@498 161 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing dense features without having established a signal URI!" << endl;
Chris@498 162 exit(1);
Chris@498 163 }
Chris@498 164
Chris@498 165 writeDenseRDF(stream, transform, output, features,
Chris@498 166 m_rdfDescriptions[pluginId], signalURI, timelineURI);
Chris@498 167
Chris@498 168 } else {
Chris@498 169
Chris@498 170 writeSparseRDF(stream, transform, output, features,
Chris@498 171 m_rdfDescriptions[pluginId], timelineURI);
Chris@498 172 }
Chris@498 173 }
Chris@498 174
Chris@498 175 void
Chris@498 176 RDFFeatureWriter::writePrefixes(QTextStream *sptr)
Chris@498 177 {
Chris@498 178 QTextStream &stream = *sptr;
Chris@498 179
Chris@498 180 stream << "@prefix dc: <http://purl.org/dc/elements/1.1/> .\n"
Chris@498 181 << "@prefix mo: <http://purl.org/ontology/mo/> .\n"
Chris@498 182 << "@prefix af: <http://purl.org/ontology/af/> .\n"
Chris@504 183 << "@prefix foaf: <http://xmlns.com/foaf/0.1/> . \n"
Chris@498 184 << "@prefix event: <http://purl.org/NET/c4dm/event.owl#> .\n"
Chris@498 185 << "@prefix rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#> .\n"
Chris@498 186 << "@prefix rdfs: <http://www.w3.org/2000/01/rdf-schema#> .\n"
Chris@498 187 << "@prefix xsd: <http://www.w3.org/2001/XMLSchema#> .\n"
Chris@498 188 << "@prefix tl: <http://purl.org/NET/c4dm/timeline.owl#> .\n"
Chris@498 189 << "@prefix vamp: <http://purl.org/ontology/vamp/> .\n"
Chris@498 190 << "@prefix : <#> .\n\n";
Chris@498 191 }
Chris@498 192
Chris@498 193 void
Chris@498 194 RDFFeatureWriter::writeSignalDescription(QTextStream *sptr,
Chris@498 195 QString trackId)
Chris@498 196 {
Chris@498 197 QTextStream &stream = *sptr;
Chris@498 198
Chris@498 199 /*
Chris@498 200 * Describe signal we're analysing (AudioFile, Signal, TimeLine, etc.)
Chris@498 201 */
Chris@498 202
Chris@498 203 QUrl url(trackId);
Chris@498 204 QString scheme = url.scheme().toLower();
Chris@498 205 bool local = (scheme == "" || scheme == "file" || scheme.length() == 1);
Chris@498 206
Chris@498 207 if (local) {
Chris@498 208 if (scheme == "") {
Chris@498 209 url.setScheme("file");
Chris@498 210 } else if (scheme.length() == 1) { // DOS drive letter!
Chris@498 211 url.setScheme("file");
Chris@498 212 url.setPath(scheme + ":" + url.path());
Chris@498 213 }
Chris@498 214 }
Chris@498 215
Chris@498 216 //!!! FIX: If we are appending, we need to start counting after
Chris@498 217 //all of the existing counts that are already in the file!
Chris@498 218
Chris@498 219 uint64_t signalCount = m_count++;
Chris@498 220
Chris@498 221 if (m_trackSignalURIs.find(trackId) == m_trackSignalURIs.end()) {
Chris@498 222 m_trackSignalURIs[trackId] = QString(":signal_%1").arg(signalCount);
Chris@498 223 }
Chris@498 224
Chris@498 225 if (m_suri != NULL) {
Chris@498 226 m_trackSignalURIs[trackId] = "<" + m_suri + ">";
Chris@498 227 }
Chris@498 228 QString signalURI = m_trackSignalURIs[trackId];
Chris@498 229
Chris@498 230 if (m_trackTimelineURIs.find(trackId) == m_trackTimelineURIs.end()) {
Chris@498 231 m_trackTimelineURIs[trackId] = QString(":signal_timeline_%1").arg(signalCount);
Chris@498 232 }
Chris@498 233 QString timelineURI = m_trackTimelineURIs[trackId];
Chris@498 234
Chris@500 235 if (trackId != "") {
Chris@500 236 stream << "\n<" << url.toEncoded().data() << "> a mo:AudioFile .\n\n";
Chris@500 237 }
Chris@500 238
Chris@500 239 stream << signalURI << " a mo:Signal ;\n";
Chris@500 240
Chris@500 241 if (trackId != "") {
Chris@500 242 stream << " mo:available_as <" << url.toEncoded().data()
Chris@500 243 << "> ;\n";
Chris@500 244 }
Chris@500 245
Chris@504 246 if (m_metadata.find(trackId) != m_metadata.end()) {
Chris@504 247 TrackMetadata tm = m_metadata[trackId];
Chris@504 248 if (tm.title != "") {
Chris@504 249 stream << " dc:title \"\"\"" << tm.title << "\"\"\" ;\n";
Chris@504 250 }
Chris@504 251 if (tm.maker != "") {
Chris@504 252 stream << " dc:creator [ a mo:MusicArtist; foaf:name \"\"\"" << tm.maker << "\"\"\" ] ;\n";
Chris@504 253 }
Chris@504 254 }
Chris@504 255
Chris@500 256 stream << " mo:time [\n"
Chris@498 257 << " a tl:Interval ;\n"
Chris@498 258 << " tl:onTimeLine "
Chris@498 259 << timelineURI << "\n ] .\n\n";
Chris@498 260 }
Chris@498 261
Chris@498 262 void
Chris@498 263 RDFFeatureWriter::writeLocalFeatureTypes(QTextStream *sptr,
Chris@498 264 const Transform &transform,
Chris@498 265 const Plugin::OutputDescriptor &od,
Chris@498 266 PluginRDFDescription &desc)
Chris@498 267 {
Chris@498 268 QString outputId = od.identifier.c_str();
Chris@498 269 QTextStream &stream = *sptr;
Chris@498 270
Chris@498 271 bool needEventType = false;
Chris@498 272 bool needSignalType = false;
Chris@498 273
Chris@498 274 //!!! feature attribute type is not yet supported
Chris@498 275
Chris@498 276 //!!! bin names, extents and so on can be written out using e.g. vamp:bin_names ( "a" "b" "c" )
Chris@498 277
Chris@498 278 if (desc.getOutputDisposition(outputId) ==
Chris@498 279 PluginRDFDescription::OutputDense) {
Chris@498 280
Chris@498 281 // no feature events, so may need signal type but won't need
Chris@498 282 // event type
Chris@498 283
Chris@498 284 if (m_plain) {
Chris@498 285
Chris@498 286 needSignalType = true;
Chris@498 287
Chris@498 288 } else if (desc.getOutputSignalTypeURI(outputId) == "") {
Chris@498 289
Chris@498 290 needSignalType = true;
Chris@498 291 }
Chris@498 292
Chris@498 293 } else {
Chris@498 294
Chris@498 295 // may need event type but won't need signal type
Chris@498 296
Chris@498 297 if (m_plain) {
Chris@498 298
Chris@498 299 needEventType = true;
Chris@498 300
Chris@498 301 } else if (desc.getOutputEventTypeURI(outputId) == "") {
Chris@498 302
Chris@498 303 needEventType = true;
Chris@498 304 }
Chris@498 305 }
Chris@498 306
Chris@498 307 QString transformUri;
Chris@498 308 if (m_transformURIs.find(transform) != m_transformURIs.end()) {
Chris@498 309 transformUri = m_transformURIs[transform];
Chris@498 310 } else {
Chris@498 311 transformUri = QString(":transform_%1_%2").arg(m_count++).arg(outputId);
Chris@498 312 m_transformURIs[transform] = transformUri;
Chris@498 313 }
Chris@498 314
Chris@500 315 if (transform.getIdentifier() != "") {
Chris@500 316 stream << RDFTransformFactory::writeTransformToRDF(transform, transformUri)
Chris@500 317 << endl;
Chris@500 318 }
Chris@498 319
Chris@498 320 if (needEventType) {
Chris@498 321
Chris@498 322 QString uri;
Chris@498 323 if (m_syntheticEventTypeURIs.find(transform) !=
Chris@498 324 m_syntheticEventTypeURIs.end()) {
Chris@498 325 uri = m_syntheticEventTypeURIs[transform];
Chris@498 326 } else {
Chris@498 327 uri = QString(":event_type_%1").arg(m_count++);
Chris@498 328 m_syntheticEventTypeURIs[transform] = uri;
Chris@498 329 }
Chris@498 330
Chris@498 331 stream << uri
Chris@498 332 << " rdfs:subClassOf event:Event ;" << endl
Chris@498 333 << " dc:title \"" << od.name.c_str() << "\" ;" << endl
Chris@498 334 << " dc:format \"" << od.unit.c_str() << "\" ;" << endl
Chris@498 335 << " dc:description \"" << od.description.c_str() << "\" ."
Chris@498 336 << endl << endl;
Chris@498 337 }
Chris@498 338
Chris@498 339 if (needSignalType) {
Chris@498 340
Chris@498 341 QString uri;
Chris@498 342 if (m_syntheticSignalTypeURIs.find(transform) !=
Chris@498 343 m_syntheticSignalTypeURIs.end()) {
Chris@498 344 uri = m_syntheticSignalTypeURIs[transform];
Chris@498 345 } else {
Chris@498 346 uri = QString(":signal_type_%1").arg(m_count++);
Chris@498 347 m_syntheticSignalTypeURIs[transform] = uri;
Chris@498 348 }
Chris@498 349
Chris@498 350 stream << uri
Chris@498 351 << " rdfs:subClassOf af:Signal ;" << endl
Chris@498 352 << " dc:title \"" << od.name.c_str() << "\" ;" << endl
Chris@498 353 << " dc:format \"" << od.unit.c_str() << "\" ;" << endl
Chris@498 354 << " dc:description \"" << od.description.c_str() << "\" ."
Chris@498 355 << endl << endl;
Chris@498 356 }
Chris@498 357 }
Chris@498 358
Chris@498 359 void
Chris@498 360 RDFFeatureWriter::writeSparseRDF(QTextStream *sptr,
Chris@498 361 const Transform &transform,
Chris@498 362 const Plugin::OutputDescriptor& od,
Chris@498 363 const Plugin::FeatureList& featureList,
Chris@498 364 PluginRDFDescription &desc,
Chris@498 365 QString timelineURI)
Chris@498 366 {
Chris@498 367 if (featureList.empty()) return;
Chris@498 368 QTextStream &stream = *sptr;
Chris@498 369
Chris@498 370 bool plain = (m_plain || !desc.haveDescription());
Chris@498 371
Chris@498 372 QString outputId = od.identifier.c_str();
Chris@498 373
Chris@498 374 // iterate through FeatureLists
Chris@498 375
Chris@498 376 for (int i = 0; i < featureList.size(); ++i) {
Chris@498 377
Chris@498 378 const Plugin::Feature &feature = featureList[i];
Chris@498 379 uint64_t featureNumber = m_count++;
Chris@498 380
Chris@498 381 stream << ":event_" << featureNumber << " a ";
Chris@498 382
Chris@498 383 QString eventTypeURI = desc.getOutputEventTypeURI(outputId);
Chris@498 384 if (plain || eventTypeURI == "") {
Chris@498 385 if (m_syntheticEventTypeURIs.find(transform) !=
Chris@498 386 m_syntheticEventTypeURIs.end()) {
Chris@498 387 stream << m_syntheticEventTypeURIs[transform] << " ;\n";
Chris@498 388 } else {
Chris@498 389 stream << ":event_type_" << outputId << " ;\n";
Chris@498 390 }
Chris@498 391 } else {
Chris@498 392 stream << "<" << eventTypeURI << "> ;\n";
Chris@498 393 }
Chris@498 394
Chris@498 395 QString timestamp = feature.timestamp.toString().c_str();
Chris@498 396 timestamp.replace(QRegExp("^ +"), "");
Chris@498 397
Chris@498 398 if (feature.hasDuration && feature.duration > Vamp::RealTime::zeroTime) {
Chris@498 399
Chris@498 400 QString duration = feature.duration.toString().c_str();
Chris@498 401 duration.replace(QRegExp("^ +"), "");
Chris@498 402
Chris@498 403 stream << " event:time [ \n"
Chris@498 404 << " a tl:Interval ;\n"
Chris@498 405 << " tl:onTimeLine " << timelineURI << " ;\n"
Chris@498 406 << " tl:beginsAt \"PT" << timestamp
Chris@498 407 << "S\"^^xsd:duration ;\n"
Chris@498 408 << " tl:duration \"PT" << duration
Chris@498 409 << "S\"^^xsd:duration ;\n"
Chris@498 410 << " ] ";
Chris@498 411
Chris@498 412 } else {
Chris@498 413
Chris@498 414 stream << " event:time [ \n"
Chris@498 415 << " a tl:Instant ;\n" //location of the event in time
Chris@498 416 << " tl:onTimeLine " << timelineURI << " ;\n"
Chris@498 417 << " tl:at \"PT" << timestamp
Chris@498 418 << "S\"^^xsd:duration ;\n ] ";
Chris@498 419 }
Chris@498 420
Chris@500 421 if (transform.getIdentifier() != "") {
Chris@500 422 stream << ";\n";
Chris@500 423 stream << " vamp:computed_by " << m_transformURIs[transform] << " ";
Chris@500 424 }
Chris@498 425
Chris@498 426 if (feature.label.length() > 0) {
Chris@498 427 stream << ";\n";
Chris@498 428 stream << " rdfs:label \"" << feature.label.c_str() << "\" ";
Chris@498 429 }
Chris@498 430
Chris@498 431 if (!feature.values.empty()) {
Chris@498 432 stream << ";\n";
Chris@498 433 //!!! named bins?
Chris@498 434 stream << " af:feature \"" << feature.values[0];
Chris@498 435 for (int j = 1; j < feature.values.size(); ++j) {
Chris@498 436 stream << " " << feature.values[j];
Chris@498 437 }
Chris@498 438 stream << "\" ";
Chris@498 439 }
Chris@498 440
Chris@498 441 stream << ".\n";
Chris@498 442 }
Chris@498 443 }
Chris@498 444
Chris@498 445 void
Chris@498 446 RDFFeatureWriter::writeDenseRDF(QTextStream *sptr,
Chris@498 447 const Transform &transform,
Chris@498 448 const Plugin::OutputDescriptor& od,
Chris@498 449 const Plugin::FeatureList& featureList,
Chris@498 450 PluginRDFDescription &desc,
Chris@498 451 QString signalURI,
Chris@498 452 QString timelineURI)
Chris@498 453 {
Chris@498 454 if (featureList.empty()) return;
Chris@498 455
Chris@498 456 StringTransformPair sp(signalURI, transform);
Chris@498 457
Chris@498 458 if (m_openDenseFeatures.find(sp) == m_openDenseFeatures.end()) {
Chris@498 459
Chris@498 460 StreamBuffer b(sptr, "");
Chris@498 461 m_openDenseFeatures[sp] = b;
Chris@498 462
Chris@498 463 QString &str(m_openDenseFeatures[sp].second);
Chris@498 464 QTextStream stream(&str);
Chris@498 465
Chris@498 466 bool plain = (m_plain || !desc.haveDescription());
Chris@498 467 QString outputId = od.identifier.c_str();
Chris@498 468
Chris@498 469 uint64_t featureNumber = m_count++;
Chris@498 470
Chris@498 471 // need to write out feature timeline map -- for this we need
Chris@498 472 // the sample rate, window length and hop size from the
Chris@498 473 // transform
Chris@498 474
Chris@498 475 stream << "\n:feature_timeline_" << featureNumber << " a tl:DiscreteTimeLine .\n\n";
Chris@498 476
Chris@498 477 size_t stepSize = transform.getStepSize();
Chris@498 478 if (stepSize == 0) {
Chris@498 479 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing dense features without having set the step size properly!" << endl;
Chris@498 480 return;
Chris@498 481 }
Chris@498 482
Chris@498 483 size_t blockSize = transform.getBlockSize();
Chris@498 484 if (blockSize == 0) {
Chris@498 485 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing dense features without having set the block size properly!" << endl;
Chris@498 486 return;
Chris@498 487 }
Chris@498 488
Chris@498 489 float sampleRate = transform.getSampleRate();
Chris@498 490 if (sampleRate == 0.f) {
Chris@498 491 cerr << "RDFFeatureWriter: INTERNAL ERROR: writing dense features without having set the sample rate properly!" << endl;
Chris@498 492 return;
Chris@498 493 }
Chris@498 494
Chris@498 495 stream << ":feature_timeline_map_" << featureNumber
Chris@498 496 << " a tl:UniformSamplingWindowingMap ;\n"
Chris@498 497 << " tl:rangeTimeLine :feature_timeline_" << featureNumber << " ;\n"
Chris@498 498 << " tl:domainTimeLine " << timelineURI << " ;\n"
Chris@498 499 << " tl:sampleRate \"" << int(sampleRate) << "\"^^xsd:int ;\n"
Chris@498 500 << " tl:windowLength \"" << blockSize << "\"^^xsd:int ;\n"
Chris@498 501 << " tl:hopSize \"" << stepSize << "\"^^xsd:int .\n\n";
Chris@498 502
Chris@498 503 stream << signalURI << " af:signal_feature :feature_"
Chris@498 504 << featureNumber << " ." << endl << endl;
Chris@498 505
Chris@498 506 stream << ":feature_" << featureNumber << " a ";
Chris@498 507
Chris@498 508 QString signalTypeURI = desc.getOutputSignalTypeURI(outputId);
Chris@498 509 if (plain || signalTypeURI == "") {
Chris@498 510 if (m_syntheticSignalTypeURIs.find(transform) !=
Chris@498 511 m_syntheticSignalTypeURIs.end()) {
Chris@498 512 stream << m_syntheticSignalTypeURIs[transform] << " ;\n";
Chris@498 513 } else {
Chris@498 514 stream << ":signal_type_" << outputId << " ;\n";
Chris@498 515 }
Chris@498 516 } else {
Chris@498 517 stream << signalTypeURI << " ;\n";
Chris@498 518 }
Chris@498 519
Chris@498 520 stream << " mo:time ["
Chris@498 521 << "\n a tl:Interval ;"
Chris@498 522 << "\n tl:onTimeLine :feature_timeline_" << featureNumber << " ;";
Chris@498 523
Chris@498 524 RealTime startrt = transform.getStartTime();
Chris@498 525 RealTime durationrt = transform.getDuration();
Chris@498 526
Chris@498 527 int start = RealTime::realTime2Frame(startrt, sampleRate) / stepSize;
Chris@498 528 int duration = RealTime::realTime2Frame(durationrt, sampleRate) / stepSize;
Chris@498 529
Chris@498 530 if (start != 0) {
Chris@498 531 stream << "\n tl:start \"" << start << "\"^^xsd:int ;";
Chris@498 532 }
Chris@498 533 if (duration != 0) {
Chris@498 534 stream << "\n tl:duration \"" << duration << "\"^^xsd:int ;";
Chris@498 535 }
Chris@498 536
Chris@498 537 stream << "\n ] ;\n";
Chris@498 538
Chris@498 539 if (od.hasFixedBinCount) {
Chris@498 540 // We only know the height, so write the width as zero
Chris@498 541 stream << " af:dimensions \"" << od.binCount << " 0\" ;\n";
Chris@498 542 }
Chris@498 543
Chris@498 544 stream << " af:value \"";
Chris@498 545 }
Chris@498 546
Chris@498 547 QString &str = m_openDenseFeatures[sp].second;
Chris@498 548 QTextStream stream(&str);
Chris@498 549
Chris@498 550 for (int i = 0; i < featureList.size(); ++i) {
Chris@498 551
Chris@498 552 const Plugin::Feature &feature = featureList[i];
Chris@498 553
Chris@498 554 for (int j = 0; j < feature.values.size(); ++j) {
Chris@498 555 stream << feature.values[j] << " ";
Chris@498 556 }
Chris@498 557 }
Chris@498 558 }
Chris@498 559
Chris@498 560 void RDFFeatureWriter::finish()
Chris@498 561 {
Chris@498 562 // cerr << "RDFFeatureWriter::finish()" << endl;
Chris@498 563
Chris@498 564 // close any open dense feature literals
Chris@498 565
Chris@498 566 for (map<StringTransformPair, StreamBuffer>::iterator i =
Chris@498 567 m_openDenseFeatures.begin();
Chris@498 568 i != m_openDenseFeatures.end(); ++i) {
Chris@498 569 cerr << "closing a stream" << endl;
Chris@498 570 StreamBuffer &b = i->second;
Chris@498 571 *(b.first) << b.second << "\" ." << endl;
Chris@498 572 }
Chris@498 573
Chris@498 574 m_openDenseFeatures.clear();
Chris@498 575 }
Chris@498 576
Chris@498 577