Package org.texttechnologylab.DockerUnifiedUIMAInterface.io.reader

Class DUUIYouTubeReader

java.lang.Object

org.texttechnologylab.DockerUnifiedUIMAInterface.io.reader.DUUIYouTubeReader

All Implemented Interfaces:

DUUICollectionReader

public class DUUIYouTubeReader
extends Object
implements DUUICollectionReader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	DUUIYouTubeReader.DUUI_ASYNC_COLLECTION_READER_SAMPLE_MODE

Constructor Summary

Constructors

Constructor	Description
DUUIYouTubeReader(String youtubeLink, String apiKey)
DUUIYouTubeReader(String youtubeLink, String apiKey, String viewName)
DUUIYouTubeReader(String youtubeLink, String apiKey, String viewName, int debugCount, int iRandom, boolean bAddMetadata, String language)

Method Summary

Modifier and Type	Method	Description
static void	addFilesToConcurrentList(File folder, String ending, ConcurrentLinkedQueue<String> paths)
String	formatSize(long lSize)
long	getDone()	How many JCas have already been processed?
void	getNextCas(org.apache.uima.jcas.JCas empty)	Fill and get the next JCas
AdvancedProgressMeter	getProgress()	Get the Progress
long	getSize()	Get size of Collection
boolean	hasNext()	Are there still cas to be processed?
static int	parseToSeconds(String input)
static ConcurrentLinkedQueue<org.texttechnologylab.DockerUnifiedUIMAInterface.io.reader.DUUIYouTubeReader.YouTubeVideo>	random(ConcurrentLinkedQueue<org.texttechnologylab.DockerUnifiedUIMAInterface.io.reader.DUUIYouTubeReader.YouTubeVideo> videos, int iRandom)
void	reset()
static ConcurrentLinkedQueue<String>	skipBySize(ConcurrentLinkedQueue<String> paths, int skipSmallerFiles)	Skips files smaller than skipSmallerFiles
static ConcurrentLinkedQueue<String>	sortBySize(ConcurrentLinkedQueue<String> paths)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DUUIYouTubeReader

public DUUIYouTubeReader(String youtubeLink,
 String apiKey)
                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

DUUIYouTubeReader

public DUUIYouTubeReader(String youtubeLink,
 String apiKey,
 String viewName)
                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

DUUIYouTubeReader

public DUUIYouTubeReader(String youtubeLink,
 String apiKey,
 String viewName,
 int debugCount,
 int iRandom,
 boolean bAddMetadata,
 String language)
                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

Method Details

addFilesToConcurrentList

public static void addFilesToConcurrentList(File folder,
 String ending,
 ConcurrentLinkedQueue<String> paths)

sortBySize

public static ConcurrentLinkedQueue<String> sortBySize(ConcurrentLinkedQueue<String> paths)

skipBySize

public static ConcurrentLinkedQueue<String> skipBySize(ConcurrentLinkedQueue<String> paths,
 int skipSmallerFiles)

Skips files smaller than skipSmallerFiles

Parameters:

paths - paths to files

skipSmallerFiles - skip files smaller than this value in bytes

Returns:

filtered paths to files

random

public static ConcurrentLinkedQueue<org.texttechnologylab.DockerUnifiedUIMAInterface.io.reader.DUUIYouTubeReader.YouTubeVideo> random(ConcurrentLinkedQueue<org.texttechnologylab.DockerUnifiedUIMAInterface.io.reader.DUUIYouTubeReader.YouTubeVideo> videos,
 int iRandom)

getProgress

public AdvancedProgressMeter getProgress()

Description copied from interface: DUUICollectionReader

Get the Progress

Specified by:

getProgress in interface DUUICollectionReader

Returns:

getNextCas

public void getNextCas(org.apache.uima.jcas.JCas empty)

Description copied from interface: DUUICollectionReader

Fill and get the next JCas

Specified by:

getNextCas in interface DUUICollectionReader

Parameters:

empty -

reset

public void reset()

hasNext

public boolean hasNext()

Description copied from interface: DUUICollectionReader

Are there still cas to be processed?

Specified by:

hasNext in interface DUUICollectionReader

Returns:

getSize

public long getSize()

Description copied from interface: DUUICollectionReader

Get size of Collection

Specified by:

getSize in interface DUUICollectionReader

Returns:

getDone

public long getDone()

Description copied from interface: DUUICollectionReader

How many JCas have already been processed?

Specified by:

getDone in interface DUUICollectionReader

Returns:

formatSize

public String formatSize(long lSize)

parseToSeconds

public static int parseToSeconds(String input)