mirror of https://github.com/apache/nifi.git
NIFI-584 remove javadoc author tags.
Signed-off-by: Aldrin Piri <aldrin@apache.org>
This commit is contained in:
Sean Busbey
Aldrin Piri
parent
e1aa4890a0
commit
c12778f17f
|
|
@ -38,7 +38,6 @@ import java.lang.annotation.Target;
|
|||
* eligible to be scheduled in Event-Driven mode.
|
||||
* </p>
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.TYPE})
|
||||
|
|
|
|||
|
|
@ -36,7 +36,6 @@ import java.lang.annotation.Target;
|
|||
* effects on external services which could not be rolled back and thus all the
|
||||
* processes could be safely repeated (implied idempotent behavior).
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.TYPE})
|
||||
|
|
|
|||
|
|
@ -41,7 +41,6 @@ import java.lang.annotation.Target;
|
|||
* ProcessSession.commit() to ensure data is persisted before deleting the data
|
||||
* from a remote source.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.TYPE})
|
||||
|
|
|
|||
|
|
@ -29,7 +29,6 @@ import java.lang.annotation.Target;
|
|||
* concurrent execution of its onTrigger() method. By default, Processors are
|
||||
* assumed to be safe for concurrent execution.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.TYPE})
|
||||
|
|
|
|||
|
|
@ -30,7 +30,6 @@ import java.lang.annotation.Target;
|
|||
* default, Processors are triggered only when all destinations report that they
|
||||
* have available space (i.e., none of the outgoing Connections is full).
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.TYPE})
|
||||
|
|
|
|||
|
|
@ -32,7 +32,6 @@ import java.lang.annotation.Target;
|
|||
* only be triggered if they have work in their queue or they present this
|
||||
* annotation.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.TYPE})
|
||||
|
|
|
|||
|
|
@ -30,7 +30,6 @@ import java.lang.annotation.Target;
|
|||
* description to be provided. This description can be provided to a user in
|
||||
* logs, UI, etc.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.TYPE})
|
||||
|
|
|
|||
|
|
@ -43,7 +43,6 @@ import java.lang.annotation.Target;
|
|||
* component will not be added to the flow.
|
||||
* </p>
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.METHOD})
|
||||
|
|
|
|||
|
|
@ -46,7 +46,6 @@ import org.apache.nifi.processor.ProcessContext;
|
|||
* of type {@link ProcessContext}.
|
||||
* </p>
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.METHOD})
|
||||
|
|
|
|||
|
|
@ -58,7 +58,6 @@ import java.lang.annotation.Target;
|
|||
* will continue until the method succeeds, and the component will then be
|
||||
* scheduled to run after this method return successfully.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.METHOD})
|
||||
|
|
|
|||
|
|
@ -44,7 +44,6 @@ import org.apache.nifi.processor.ProcessContext;
|
|||
* {@link ProcessContext} if the component is a Processor.
|
||||
* </p>
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.METHOD})
|
||||
|
|
|
|||
|
|
@ -57,7 +57,6 @@ import org.apache.nifi.processor.ProcessContext;
|
|||
* component is a Processor.
|
||||
* </p>
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.METHOD})
|
||||
|
|
|
|||
|
|
@ -26,7 +26,6 @@ import java.lang.annotation.Target;
|
|||
/**
|
||||
*
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
@Documented
|
||||
@Target({ElementType.FIELD, ElementType.METHOD})
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ package org.apache.nifi.authorization.exception;
|
|||
/**
|
||||
* Represents the exceptional case when an AuthorityProvider fails instantiated.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ProviderCreationException extends RuntimeException {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ package org.apache.nifi.authorization.exception;
|
|||
/**
|
||||
* Represents the exceptional case when an AuthorityProvider fails destruction.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ProviderDestructionException extends RuntimeException {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,7 +22,6 @@ import java.util.Objects;
|
|||
*
|
||||
* Immutable - thread safe
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ValidationResult {
|
||||
|
||||
|
|
|
|||
|
|
@ -18,7 +18,6 @@ package org.apache.nifi.components;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface Validator {
|
||||
|
||||
|
|
|
|||
|
|
@ -30,7 +30,6 @@ import java.lang.annotation.Target;
|
|||
* arguments or a single argument of type
|
||||
* {@link nifi.controller.ConfigurationContext ConfigurationContext}.
|
||||
*
|
||||
* @author none
|
||||
*
|
||||
* @deprecated This annotation has been replaced by those in the
|
||||
* {@link org.apache.nifi.annotation.lifecycle} package.
|
||||
|
|
|
|||
|
|
@ -18,7 +18,6 @@ package org.apache.nifi.controller.repository;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public enum RepositoryRecordType {
|
||||
|
||||
|
|
|
|||
|
|
@ -25,7 +25,6 @@ package org.apache.nifi.controller.repository.claim;
|
|||
* <p>
|
||||
* Must be thread safe</p>
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public interface ContentClaim extends Comparable<ContentClaim> {
|
||||
|
||||
|
|
|
|||
|
|
@ -17,7 +17,6 @@
|
|||
package org.apache.nifi.controller.status;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ConnectionStatus implements Cloneable {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import java.util.List;
|
|||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ProcessGroupStatus implements Cloneable {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ package org.apache.nifi.controller.status;
|
|||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ProcessorStatus implements Cloneable {
|
||||
|
||||
|
|
|
|||
|
|
@ -24,7 +24,6 @@ import java.util.Comparator;
|
|||
* so if features of that content are necessary for prioritization it should be
|
||||
* extracted to be used as an attribute of the flow file.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public interface FlowFilePrioritizer extends Comparator<FlowFile> {
|
||||
}
|
||||
|
|
|
|||
|
|
@ -46,7 +46,6 @@ import org.apache.nifi.processor.exception.ProcessException;
|
|||
* default no-args constructor to facilitate the java service loader
|
||||
* mechanism.</p>
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public interface Processor extends ConfigurableComponent {
|
||||
|
||||
|
|
|
|||
|
|
@ -18,7 +18,6 @@ package org.apache.nifi.processor;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author
|
||||
*/
|
||||
public class QueueSize {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ package org.apache.nifi.processor;
|
|||
/**
|
||||
* An immutable object for holding information about a type of relationship.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public final class Relationship implements Comparable<Relationship> {
|
||||
|
||||
|
|
|
|||
|
|
@ -27,7 +27,6 @@ import java.lang.annotation.Target;
|
|||
* Annotation that may be placed on a processor allowing for a description to be
|
||||
* provided. This description can be provided to a user in logs, UI, etc.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.documentation.CapabilityDescription}
|
||||
* annotation.
|
||||
|
|
|
|||
|
|
@ -38,7 +38,6 @@ import java.lang.annotation.Target;
|
|||
* eligible to be scheduled in Event-Driven mode.
|
||||
* </p>
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.behavior.EventDriven} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -31,7 +31,6 @@ import java.lang.annotation.Target;
|
|||
* If any method annotated with this annotation throws, the processor will not
|
||||
* be added to the graph.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.lifecycle.OnAdded} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -32,7 +32,6 @@ import java.lang.annotation.Target;
|
|||
* If any method annotated with this annotation throws, the processor will not
|
||||
* be removed from the graph.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.lifecycle.OnRemoved} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -34,7 +34,6 @@ import java.lang.annotation.Target;
|
|||
* If any method annotated with this annotation throws, the processor will not
|
||||
* be scheduled to run.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.lifecycle.OnScheduled} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -28,7 +28,6 @@ import java.lang.annotation.Target;
|
|||
* should be called whenever the flow is being shutdown. This will be called at
|
||||
* most once for each processor instance in a process lifetime.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.lifecycle.OnShutdown} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -45,7 +45,6 @@ import java.lang.annotation.Target;
|
|||
* longer scheduled to run, see the {@link OnUnscheduled} annotation.
|
||||
* </p>
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.lifecycle.OnStopped} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -36,7 +36,6 @@ import java.lang.annotation.Target;
|
|||
* If any method annotated with this annotation throws, the processor will not
|
||||
* be scheduled to run.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.lifecycle.OnUnscheduled} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -35,7 +35,6 @@ import java.lang.annotation.Target;
|
|||
* which could not be rolled back and thus all the processes could be safely
|
||||
* repeated (implied idempotent behavior).
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.behavior.SideEffectFree} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -40,7 +40,6 @@ import java.lang.annotation.Target;
|
|||
* ProcessSession.commit() to ensure data is persisted before deleting the data
|
||||
* from a remote source.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.behavior.SupportsBatching} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -29,7 +29,6 @@ import java.lang.annotation.Target;
|
|||
* method. By default processors are assumed to be thread safe for concurrent
|
||||
* execution.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.behavior.TriggerSerially} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -29,7 +29,6 @@ import java.lang.annotation.Target;
|
|||
* for incoming FlowFiles. By default processors are triggered only when all
|
||||
* destinations report that they have available space.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.behavior.TriggerWhenAnyDestinationAvailable}
|
||||
* annotation.
|
||||
|
|
|
|||
|
|
@ -31,7 +31,6 @@ import java.lang.annotation.Target;
|
|||
* have non-self incoming edges will only be triggered if they have work in
|
||||
* their queue or they present this annotation.
|
||||
*
|
||||
* @author none
|
||||
* @deprecated This Annotation has been replaced by the
|
||||
* {@link org.apache.nifi.annotation.behavior.TriggerWhenEmpty} annotation.
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ package org.apache.nifi.processor.exception;
|
|||
* Indicates an issue occurred while accessing the content of a FlowFile, such
|
||||
* as an IOException.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public class FlowFileAccessException extends RuntimeException {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,7 +22,6 @@ package org.apache.nifi.processor.exception;
|
|||
* session. In any event this exception indicates a logic or programming error
|
||||
* within the processor interacting with the offending session.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public class FlowFileHandlingException extends ProcessException {
|
||||
|
||||
|
|
|
|||
|
|
@ -24,7 +24,6 @@ package org.apache.nifi.processor.exception;
|
|||
* framework and it is not something any processor or the framework can recover
|
||||
* so it must discard the object.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public class MissingFlowFileException extends RuntimeException {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ package org.apache.nifi.processor.exception;
|
|||
/**
|
||||
* Indicates an issue occurred in user code while processing a FlowFile.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public class ProcessException extends RuntimeException {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,7 +21,6 @@ import java.io.InputStream;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface InputStreamCallback {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,7 +21,6 @@ import java.io.OutputStream;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface OutputStreamCallback {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,7 +22,6 @@ import java.io.Serializable;
|
|||
* A model object representing a revision. Equality is defined as either a
|
||||
* matching version number or matching non-empty client IDs.
|
||||
*
|
||||
* @author unattributed
|
||||
* @Immutable
|
||||
* @Threadsafe
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -32,7 +32,6 @@ import org.apache.nifi.processor.Relationship;
|
|||
/**
|
||||
* Holder for provenance relevant information
|
||||
* <p/>
|
||||
* @author none
|
||||
*/
|
||||
public final class StandardProvenanceEventRecord implements ProvenanceEventRecord {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,7 +21,6 @@ import org.slf4j.Marker;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class NiFiLog implements Logger {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import org.apache.commons.lang3.builder.ToStringStyle;
|
|||
* Enumeration capturing essential information about the various encryption
|
||||
* methods that might be supported.
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public enum EncryptionMethod {
|
||||
|
||||
|
|
|
|||
|
|
@ -37,7 +37,6 @@ import javax.net.ssl.TrustManagerFactory;
|
|||
* A factory for creating SSL contexts using the application's security
|
||||
* properties.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public final class SslContextFactory {
|
||||
|
||||
|
|
|
|||
|
|
@ -29,7 +29,6 @@ import org.apache.commons.lang3.builder.ToStringStyle;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public abstract class AbstractStreamConsumer implements StreamConsumer {
|
||||
|
||||
|
|
|
|||
|
|
@ -18,7 +18,6 @@ package org.apache.nifi.io.nio.consumer;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public interface StreamConsumerFactory {
|
||||
|
||||
|
|
|
|||
|
|
@ -41,7 +41,6 @@ import org.slf4j.LoggerFactory;
|
|||
/**
|
||||
* Implements a listener for TCP/IP messages sent over unicast socket.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public abstract class SocketListener {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import java.net.InetSocketAddress;
|
|||
* unique case-sensitive service name and a socket address where it is
|
||||
* available.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface DiscoverableService {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import org.apache.commons.lang3.StringUtils;
|
|||
* A basic implementation of the DiscoverableService interface. To services are
|
||||
* considered equal if they have the same case-sensitive service name.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class DiscoverableServiceImpl implements DiscoverableService {
|
||||
|
||||
|
|
|
|||
|
|
@ -17,7 +17,6 @@
|
|||
package org.apache.nifi.io.socket.multicast;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public final class MulticastConfiguration {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,7 +22,6 @@ import java.net.InetSocketAddress;
|
|||
* Defines the interface for discovering services based on name. Services are
|
||||
* expected to be exposed via socket address and port.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface MulticastServiceDiscovery extends ServiceDiscovery {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,7 +21,6 @@ import java.net.InetSocketAddress;
|
|||
/**
|
||||
* Defines the interface for broadcasting a service via multicast.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface MulticastServicesBroadcaster extends ServicesBroadcaster {
|
||||
|
||||
|
|
|
|||
|
|
@ -17,7 +17,6 @@
|
|||
package org.apache.nifi.io.socket.multicast;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public enum MulticastTimeToLive {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import org.slf4j.Logger;
|
|||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public final class MulticastUtils {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ package org.apache.nifi.io.socket.multicast;
|
|||
/**
|
||||
* Defines a generic interface for discovering services.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface ServiceDiscovery {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,7 +22,6 @@ import java.util.Set;
|
|||
* Defines the interface for broadcasting a collection of services for client
|
||||
* discovery.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface ServicesBroadcaster {
|
||||
|
||||
|
|
|
|||
|
|
@ -37,7 +37,6 @@ import org.slf4j.LoggerFactory;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public final class ServerMain {
|
||||
|
||||
|
|
|
|||
|
|
@ -24,7 +24,6 @@ import org.slf4j.Logger;
|
|||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author none
|
||||
*/
|
||||
public class TCPClient {
|
||||
|
||||
|
|
|
|||
|
|
@ -24,7 +24,6 @@ import org.slf4j.Logger;
|
|||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* @author none
|
||||
*/
|
||||
public class UDPClient {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import org.apache.nifi.io.nio.consumer.AbstractStreamConsumer;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author none
|
||||
*/
|
||||
public class UselessStreamConsumer extends AbstractStreamConsumer {
|
||||
|
||||
|
|
|
|||
|
|
@ -41,7 +41,6 @@ import org.slf4j.Logger;
|
|||
/**
|
||||
* A utility class containing a few useful static methods to do typical IO operations.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class FileUtils {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import org.apache.nifi.util.search.SearchTerm;
|
|||
|
||||
/**
|
||||
*
|
||||
* @author
|
||||
*/
|
||||
public class Node {
|
||||
|
||||
|
|
|
|||
|
|
@ -51,7 +51,6 @@ import com.sun.jersey.client.urlconnection.HTTPSProperties;
|
|||
/**
|
||||
* Common utilities related to web development.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public final class WebUtils {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.annotation.XmlRootElement;
|
|||
import org.apache.nifi.cluster.authorization.protocol.message.ProtocolMessage.MessageType;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
@XmlRootElement(name = "doesDnExistMessage")
|
||||
public class DoesDnExistMessage extends ProtocolMessage {
|
||||
|
|
|
|||
|
|
@ -22,7 +22,6 @@ import javax.xml.bind.annotation.XmlRootElement;
|
|||
import org.apache.nifi.authorization.Authority;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
@XmlRootElement(name = "getAuthoritiesMessage")
|
||||
public class GetAuthoritiesMessage extends ProtocolMessage {
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ package org.apache.nifi.cluster.authorization.protocol.message;
|
|||
import javax.xml.bind.annotation.XmlRootElement;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
@XmlRootElement(name = "getGroupForUserMessage")
|
||||
public class GetGroupForUserMessage extends ProtocolMessage {
|
||||
|
|
|
|||
|
|
@ -17,7 +17,6 @@
|
|||
package org.apache.nifi.cluster.authorization.protocol.message;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public abstract class ProtocolMessage {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.JAXBContext;
|
|||
import javax.xml.bind.JAXBException;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public final class JaxbProtocolUtils {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,7 +22,6 @@ import org.apache.nifi.cluster.authorization.protocol.message.GetAuthoritiesMess
|
|||
import org.apache.nifi.cluster.authorization.protocol.message.GetGroupForUserMessage;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
@XmlRegistry
|
||||
public class ObjectFactory {
|
||||
|
|
|
|||
|
|
@ -23,7 +23,6 @@ import org.apache.nifi.cluster.protocol.jaxb.message.ConnectionRequestAdapter;
|
|||
* A node's request to connect to the cluster. The request contains a proposed
|
||||
* identifier.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
@XmlJavaTypeAdapter(ConnectionRequestAdapter.class)
|
||||
public class ConnectionRequest {
|
||||
|
|
|
|||
|
|
@ -24,7 +24,6 @@ import org.apache.nifi.cluster.protocol.jaxb.message.HeartbeatAdapter;
|
|||
/**
|
||||
* A heartbeat for indicating the status of a node to the cluster.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
@XmlJavaTypeAdapter(HeartbeatAdapter.class)
|
||||
public class Heartbeat {
|
||||
|
|
|
|||
|
|
@ -29,7 +29,6 @@ import org.apache.commons.lang3.StringUtils;
|
|||
* This class overrides hashCode and equals and considers two instances to be
|
||||
* equal if they have the equal IDs.
|
||||
*
|
||||
* @author unattributed
|
||||
* @Immutable
|
||||
* @Threadsafe
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -21,7 +21,6 @@ package org.apache.nifi.cluster.protocol;
|
|||
*
|
||||
* @param <T> The type of protocol message.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface ProtocolContext<T> {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ package org.apache.nifi.cluster.protocol;
|
|||
* The base exception for problems encountered while communicating within the
|
||||
* cluster.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ProtocolException extends RuntimeException {
|
||||
|
||||
|
|
|
|||
|
|
@ -24,7 +24,6 @@ import java.io.OutputStream;
|
|||
*
|
||||
* @param <T> The type of protocol message.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public interface ProtocolMessageMarshaller<T> {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,7 +19,6 @@ package org.apache.nifi.cluster.protocol;
|
|||
/**
|
||||
* Represents the exceptional case when a service's address is not known.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class UnknownServiceAddressException extends RuntimeException {
|
||||
|
||||
|
|
|
|||
|
|
@ -35,7 +35,6 @@ import org.apache.nifi.reporting.BulletinRepository;
|
|||
* A wrapper class for consolidating a protocol sender and listener for the
|
||||
* cluster manager.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ClusterManagerProtocolSenderListener implements ClusterManagerProtocolSender, ProtocolListener {
|
||||
|
||||
|
|
|
|||
|
|
@ -40,7 +40,6 @@ import org.slf4j.LoggerFactory;
|
|||
* which case, no service discovery occurs and the caller will always receive
|
||||
* the configured service.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ClusterServiceLocator implements ServiceDiscovery {
|
||||
|
||||
|
|
|
|||
|
|
@ -50,7 +50,6 @@ import org.slf4j.LoggerFactory;
|
|||
* The instance must be stopped before termination of the JVM to ensure proper
|
||||
* resource clean-up.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ClusterServicesBroadcaster implements MulticastServicesBroadcaster {
|
||||
|
||||
|
|
|
|||
|
|
@ -55,7 +55,6 @@ import org.slf4j.LoggerFactory;
|
|||
* instance must be stopped before termination of the JVM to ensure proper
|
||||
* resource clean-up.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class MulticastProtocolListener extends MulticastListener implements ProtocolListener {
|
||||
|
||||
|
|
|
|||
|
|
@ -49,7 +49,6 @@ import org.slf4j.LoggerFactory;
|
|||
/**
|
||||
* Implements a listener for protocol messages sent over unicast socket.
|
||||
*
|
||||
* @author unattributed
|
||||
*/
|
||||
public class SocketProtocolListener extends SocketListener implements ProtocolListener {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
|
|||
import org.apache.nifi.cluster.protocol.NodeIdentifier;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class AdaptedConnectionRequest {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,7 +22,6 @@ import org.apache.nifi.cluster.protocol.NodeIdentifier;
|
|||
import org.apache.nifi.cluster.protocol.StandardDataFlow;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class AdaptedConnectionResponse {
|
||||
|
||||
|
|
|
|||
|
|
@ -17,7 +17,6 @@
|
|||
package org.apache.nifi.cluster.protocol.jaxb.message;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class AdaptedCounter {
|
||||
|
||||
|
|
|
|||
|
|
@ -17,7 +17,6 @@
|
|||
package org.apache.nifi.cluster.protocol.jaxb.message;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class AdaptedDataFlow {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
|
|||
import org.apache.nifi.cluster.protocol.NodeIdentifier;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class AdaptedHeartbeat {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
|
|||
import org.apache.nifi.cluster.protocol.NodeIdentifier;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class AdaptedNodeBulletins {
|
||||
|
||||
|
|
|
|||
|
|
@ -17,7 +17,6 @@
|
|||
package org.apache.nifi.cluster.protocol.jaxb.message;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class AdaptedNodeIdentifier {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.annotation.adapters.XmlAdapter;
|
|||
import org.apache.nifi.cluster.protocol.ConnectionRequest;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ConnectionRequestAdapter extends XmlAdapter<AdaptedConnectionRequest, ConnectionRequest> {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.annotation.adapters.XmlAdapter;
|
|||
import org.apache.nifi.cluster.protocol.ConnectionResponse;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class ConnectionResponseAdapter extends XmlAdapter<AdaptedConnectionResponse, ConnectionResponse> {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,7 +21,6 @@ import javax.xml.bind.annotation.adapters.XmlAdapter;
|
|||
import org.apache.nifi.cluster.protocol.StandardDataFlow;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class DataFlowAdapter extends XmlAdapter<AdaptedDataFlow, StandardDataFlow> {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.annotation.adapters.XmlAdapter;
|
|||
import org.apache.nifi.cluster.protocol.Heartbeat;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public class HeartbeatAdapter extends XmlAdapter<AdaptedHeartbeat, Heartbeat> {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,7 +20,6 @@ import javax.xml.bind.JAXBContext;
|
|||
import javax.xml.bind.JAXBException;
|
||||
|
||||
/**
|
||||
* @author unattributed
|
||||
*/
|
||||
public final class JaxbProtocolUtils {
|
||||
|
||||
|
|
|
|||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue