com.ibm.streamsx.topology.file

Class DirectoryWatcher

java.lang.Object

com.ibm.streams.operator.AbstractOperator

com.ibm.streams.operator.samples.patterns.TupleProducer

com.ibm.streams.operator.samples.patterns.ProcessTupleProducer

com.ibm.streamsx.topology.file.DirectoryWatcher

All Implemented Interfaces:

com.ibm.streams.operator.Operator, java.io.FileFilter

@PrimitiveOperator
 @OutputPortSet(cardinality=1)
public class DirectoryWatcher
extends com.ibm.streams.operator.samples.patterns.ProcessTupleProducer
implements java.io.FileFilter

Nested Class Summary

Nested classes/interfaces inherited from interface com.ibm.streams.operator.Operator

com.ibm.streams.operator.Operator.TagNames

Field Summary

Fields inherited from class com.ibm.streams.operator.samples.patterns.TupleProducer

IBM_COPYRIGHT

Constructor Summary

Constructors

Constructor and Description
DirectoryWatcher()

Method Summary

Modifier and Type	Method and Description
boolean	accept(java.io.File pathname)
protected java.lang.String	getDirectory()
void	initialize(com.ibm.streams.operator.OperatorContext context) Create the non-daemon thread used to call the process() method.
protected void	process() Sub-classes provide a process() method that submits tuples on the operator's output ports.
void	setDirectory(java.lang.String directory)
protected void	sortAndSubmit(java.util.List<java.io.File> files)

Methods inherited from class com.ibm.streams.operator.samples.patterns.ProcessTupleProducer

producerInitialize, shutdown, startProcessing

Methods inherited from class com.ibm.streams.operator.samples.patterns.TupleProducer

allPortsReady, getInitialDelay, getInitialDelayUnit, setInitDelay, setInitDelay, setInitialDelay

Methods inherited from class com.ibm.streams.operator.AbstractOperator

checkPorts, createAvoidCompletionThread, createAvoidCompletionThread, createAvoidCompletionThreadIfNoInputs, getControlPlaneContext, getInput, getOperatorContext, getOutput, process, processPunctuation, setLoggerAspects, setTagData

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectoryWatcher

public DirectoryWatcher()

Method Detail

getDirectory

protected java.lang.String getDirectory()

initialize

public void initialize(com.ibm.streams.operator.OperatorContext context)
                throws java.lang.Exception

Description copied from class: com.ibm.streams.operator.samples.patterns.ProcessTupleProducer

Create the non-daemon thread used to call the process() method. The thread is created during initialization to ensure that the SPL runtime will wait upon its completion before completing the operator. The thread is started by startProcessing which means the initial delay support provided by the super-class TupleProducer is honored.

Specified by:

initialize in interface com.ibm.streams.operator.Operator

Overrides:

initialize in class com.ibm.streams.operator.samples.patterns.ProcessTupleProducer

Throws:

java.lang.Exception

setDirectory

@Parameter
public void setDirectory(java.lang.String directory)

sortAndSubmit

protected void sortAndSubmit(java.util.List<java.io.File> files)
                      throws java.lang.Exception

Throws:

java.lang.Exception

process

protected void process()
                throws java.lang.Exception

Description copied from class: com.ibm.streams.operator.samples.patterns.ProcessTupleProducer

Sub-classes provide a process() method that submits tuples on the operator's output ports.
When this method returns the the operator will complete.

It is guaranteed that the initialize() method happens-before the process() method for purposes of memory visibility.

Specified by:

process in class com.ibm.streams.operator.samples.patterns.ProcessTupleProducer

Throws:

java.lang.Exception - Exception is sub-class processing

accept

public boolean accept(java.io.File pathname)

Specified by:

accept in interface java.io.FileFilter