Skip to content
Snippets Groups Projects
Commit 261b99f5 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

fixed all javadoc issues

parent 7aab5edc
No related branches found
No related tags found
No related merge requests found
Showing
with 26 additions and 41 deletions
...@@ -185,9 +185,6 @@ ...@@ -185,9 +185,6 @@
<groupId>org.apache.maven.plugins</groupId> <groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-javadoc-plugin</artifactId> <artifactId>maven-javadoc-plugin</artifactId>
<version>2.10.3</version> <version>2.10.3</version>
<configuration>
<failOnError>false</failOnError>
</configuration>
<executions> <executions>
<execution> <execution>
<id>attach-javadocs</id> <id>attach-javadocs</id>
......
...@@ -146,6 +146,9 @@ public abstract class AbstractStage extends Stage { ...@@ -146,6 +146,9 @@ public abstract class AbstractStage extends Stage {
/** /**
* Creates and adds an InputPort to the stage * Creates and adds an InputPort to the stage
* *
* @param type
* class of elements to be received
*
* @param <T> * @param <T>
* the type of elements to be received * the type of elements to be received
* *
...@@ -176,9 +179,12 @@ public abstract class AbstractStage extends Stage { ...@@ -176,9 +179,12 @@ public abstract class AbstractStage extends Stage {
/** /**
* Creates and adds an OutputPort to the stage * Creates and adds an OutputPort to the stage
* *
* @param type
* class of elements to be sent
*
* @param <T> * @param <T>
* the type of elements to be sent * the type of elements to be sent
* *
* @return Newly added OutputPort * @return Newly added OutputPort
*/ */
protected <T> OutputPort<T> createOutputPort(final Class<T> type) { protected <T> OutputPort<T> createOutputPort(final Class<T> type) {
......
...@@ -32,6 +32,9 @@ public interface IPipeFactory { ...@@ -32,6 +32,9 @@ public interface IPipeFactory {
* OutputPort of the stage, which produces data. * OutputPort of the stage, which produces data.
* @param targetPort * @param targetPort
* Input port of the receiving stage. * Input port of the receiving stage.
* @param <T>
* type of elements which traverse this pipe
*
* @return The connecting pipe. * @return The connecting pipe.
*/ */
<T> IPipe create(OutputPort<? extends T> sourcePort, InputPort<T> targetPort); <T> IPipe create(OutputPort<? extends T> sourcePort, InputPort<T> targetPort);
...@@ -45,6 +48,8 @@ public interface IPipeFactory { ...@@ -45,6 +48,8 @@ public interface IPipeFactory {
* Input port of the receiving stage. * Input port of the receiving stage.
* @param capacity * @param capacity
* Number of elements the pipe can carry. * Number of elements the pipe can carry.
* @param <T>
* type of elements which traverse this pipe
* @return The connecting pipe. * @return The connecting pipe.
*/ */
<T> IPipe create(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity); <T> IPipe create(OutputPort<? extends T> sourcePort, InputPort<T> targetPort, int capacity);
...@@ -60,7 +65,7 @@ public interface IPipeFactory { ...@@ -60,7 +65,7 @@ public interface IPipeFactory {
PipeOrdering getOrdering(); PipeOrdering getOrdering();
/** /**
* @return Wether or not the created pipes are growable * @return Whether or not the created pipes are growable
*/ */
boolean isGrowable(); boolean isGrowable();
......
...@@ -93,7 +93,7 @@ public final class PipeFactoryRegistry { ...@@ -93,7 +93,7 @@ public final class PipeFactoryRegistry {
} }
/** /**
* Adds a new PipeFactory to the registry.<br /> * Adds a new PipeFactory to the registry.
* The new PipeFactory will be automatically selected by the Registry, if it is the most suitable Factory * The new PipeFactory will be automatically selected by the Registry, if it is the most suitable Factory
* corresponding to the requirements. * corresponding to the requirements.
* *
......
...@@ -24,13 +24,6 @@ public interface ISignal { ...@@ -24,13 +24,6 @@ public interface ISignal {
void trigger(Stage stage); void trigger(Stage stage);
/** // Only used by the merger so far
* Used by the merger only (so far)
*
* @param receivedInputPorts
* @param allInputPorts
* @param stageState
* @return <code>true</code> iff the signal may be triggered, <code>false</code> otherwise.
*/
boolean mayBeTriggered(Set<InputPort<?>> receivedInputPorts, InputPort<?>[] allInputPorts); boolean mayBeTriggered(Set<InputPort<?>> receivedInputPorts, InputPort<?>[] allInputPorts);
} }
...@@ -33,6 +33,8 @@ public final class Counter<T> extends AbstractConsumerStage<T> { ...@@ -33,6 +33,8 @@ public final class Counter<T> extends AbstractConsumerStage<T> {
/** /**
* <i>Hint:</i> This method may not be invoked by another thread since it is not thread-safe. * <i>Hint:</i> This method may not be invoked by another thread since it is not thread-safe.
*
* @return the number of passed elements
*/ */
public int getNumElementsPassed() { public int getNumElementsPassed() {
return this.numElementsPassed; return this.numElementsPassed;
......
...@@ -29,6 +29,10 @@ public final class ObjectProducer<T> extends AbstractProducerStage<T> { ...@@ -29,6 +29,10 @@ public final class ObjectProducer<T> extends AbstractProducerStage<T> {
private ConstructorClosure<T> inputObjectCreator; private ConstructorClosure<T> inputObjectCreator;
/** /**
* @param numInputObjects
* number of objects which should be instantiated and sent
* @param inputObjectCreator
* a {@link ConstructorClosure} which creates the new instances
* @since 1.0 * @since 1.0
*/ */
public ObjectProducer(final long numInputObjects, final ConstructorClosure<T> inputObjectCreator) { public ObjectProducer(final long numInputObjects, final ConstructorClosure<T> inputObjectCreator) {
......
...@@ -93,6 +93,7 @@ public abstract class AbstractTcpReader<T> extends AbstractProducerStage<T> { ...@@ -93,6 +93,7 @@ public abstract class AbstractTcpReader<T> extends AbstractProducerStage<T> {
* @return <ul> * @return <ul>
* <li><code>true</code> when there were enough bytes to perform the read operation * <li><code>true</code> when there were enough bytes to perform the read operation
* <li><code>false</code> otherwise. In this case, the buffer is reset, compacted, and filled with new content. * <li><code>false</code> otherwise. In this case, the buffer is reset, compacted, and filled with new content.
* </ul>
*/ */
protected abstract boolean read(final ByteBuffer buffer); protected abstract boolean read(final ByteBuffer buffer);
......
...@@ -23,11 +23,6 @@ import java.util.Comparator; ...@@ -23,11 +23,6 @@ import java.util.Comparator;
import teetime.framework.AbstractConsumerStage; import teetime.framework.AbstractConsumerStage;
import teetime.framework.OutputPort; import teetime.framework.OutputPort;
/**
* @author Christian Wulf
*
* @since 1.10
*/
public final class Directory2FilesFilter extends AbstractConsumerStage<File> { public final class Directory2FilesFilter extends AbstractConsumerStage<File> {
private final OutputPort<File> outputPort = this.createOutputPort(); private final OutputPort<File> outputPort = this.createOutputPort();
...@@ -35,31 +30,19 @@ public final class Directory2FilesFilter extends AbstractConsumerStage<File> { ...@@ -35,31 +30,19 @@ public final class Directory2FilesFilter extends AbstractConsumerStage<File> {
private FileFilter filter; private FileFilter filter;
private Comparator<File> fileComparator; private Comparator<File> fileComparator;
/**
* @since 1.10
*/
public Directory2FilesFilter(final FileFilter fileFilter) { public Directory2FilesFilter(final FileFilter fileFilter) {
this.setFilter(fileFilter); this.setFilter(fileFilter);
} }
/**
* @since 1.10
*/
public Directory2FilesFilter(final Comparator<File> fileComparator) { public Directory2FilesFilter(final Comparator<File> fileComparator) {
this.setFileComparator(fileComparator); this.setFileComparator(fileComparator);
} }
/**
* @since 1.10
*/
public Directory2FilesFilter(final FileFilter fileFilter, final Comparator<File> fileComparator) { public Directory2FilesFilter(final FileFilter fileFilter, final Comparator<File> fileComparator) {
this.setFilter(fileFilter); this.setFilter(fileFilter);
this.setFileComparator(fileComparator); this.setFileComparator(fileComparator);
} }
/**
* @since 1.10
*/
public Directory2FilesFilter() { public Directory2FilesFilter() {
super(); super();
} }
......
...@@ -19,17 +19,12 @@ import java.io.File; ...@@ -19,17 +19,12 @@ import java.io.File;
/** /**
* @author Christian Wulf * @author Christian Wulf
*
* @since 1.10
*/ */
public final class TextLine { public final class TextLine {
private final File textFile; private final File textFile;
private final String textLine; private final String textLine;
/**
* @since 1.10
*/
public TextLine(final File textFile, final String textLine) { public TextLine(final File textFile, final String textLine) {
this.textFile = textFile; this.textFile = textFile;
this.textLine = textLine; this.textLine = textLine;
......
...@@ -24,6 +24,7 @@ import java.util.List; ...@@ -24,6 +24,7 @@ import java.util.List;
* @author Christian Wulf * @author Christian Wulf
* *
* @param <T> * @param <T>
* type of the elements contained in the list
*/ */
public final class CyclicListIterator<T> implements Iterator<T> { public final class CyclicListIterator<T> implements Iterator<T> {
......
...@@ -16,10 +16,6 @@ ...@@ -16,10 +16,6 @@
package teetime.util; package teetime.util;
/** /**
*
* @param <F>
* @param <S>
*
* @deprecated since 1.2 * @deprecated since 1.2
*/ */
@Deprecated @Deprecated
......
...@@ -23,7 +23,6 @@ import java.util.concurrent.ConcurrentMap; ...@@ -23,7 +23,6 @@ import java.util.concurrent.ConcurrentMap;
* the type that is used to cast a type that was found in the class path * the type that is used to cast a type that was found in the class path
* *
* @author Christian Wulf * @author Christian Wulf
* @since 1.11
*/ */
public final class CachedClassForNameResolver<T> { public final class CachedClassForNameResolver<T> {
...@@ -43,6 +42,7 @@ public final class CachedClassForNameResolver<T> { ...@@ -43,6 +42,7 @@ public final class CachedClassForNameResolver<T> {
* @return A {@link Class} instance corresponding to the given name, if it exists. * @return A {@link Class} instance corresponding to the given name, if it exists.
* *
* @throws ClassNotFoundException * @throws ClassNotFoundException
* thrown iff no class was found for the given <b>classname</b>
*/ */
public final Class<? extends T> classForName(final String classname) throws ClassNotFoundException { public final Class<? extends T> classForName(final String classname) throws ClassNotFoundException {
Class<? extends T> clazz = this.cachedClasses.get(classname); Class<? extends T> clazz = this.cachedClasses.get(classname);
......
...@@ -38,6 +38,7 @@ public final class ClassForNameResolver<T> { ...@@ -38,6 +38,7 @@ public final class ClassForNameResolver<T> {
* *
* @return A {@link Class} instance corresponding to the given name, if it exists. * @return A {@link Class} instance corresponding to the given name, if it exists.
* @throws ClassNotFoundException * @throws ClassNotFoundException
* thrown iff no class was found for the given <b>classname</b>
* *
*/ */
public final Class<? extends T> classForName(final String classname) throws ClassNotFoundException { public final Class<? extends T> classForName(final String classname) throws ClassNotFoundException {
......
...@@ -98,6 +98,7 @@ public abstract class AbstractTcpReader implements Runnable { ...@@ -98,6 +98,7 @@ public abstract class AbstractTcpReader implements Runnable {
* @return <ul> * @return <ul>
* <li><code>true</code> when there were enough bytes to perform the read operation * <li><code>true</code> when there were enough bytes to perform the read operation
* <li><code>false</code> otherwise. In this case, the buffer is reset, compacted, and filled with new content. * <li><code>false</code> otherwise. In this case, the buffer is reset, compacted, and filled with new content.
* </ul>
*/ */
protected abstract boolean onBufferReceived(final ByteBuffer buffer); protected abstract boolean onBufferReceived(final ByteBuffer buffer);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment