mirror of https://github.com/apache/kafka.git
KAFKA-2906: Fix Connect javadocs, restrict only to api subproject, and clean up javadoc warnings.
Author: Ewen Cheslack-Postava <me@ewencp.org> Reviewers: Gwen Shapira Closes #599 from ewencp/kafka-2906-connect-javadocs
This commit is contained in:
parent
4a8acdf9d7
commit
75c7abd826
|
@ -667,7 +667,7 @@ project(':connect:api') {
|
|||
}
|
||||
|
||||
javadoc {
|
||||
include "**/org/apache/kafka/connect/*"
|
||||
options.links "http://docs.oracle.com/javase/7/docs/api/"
|
||||
}
|
||||
|
||||
tasks.create(name: "copyDependantLibs", type: Copy) {
|
||||
|
@ -728,7 +728,7 @@ project(':connect:json') {
|
|||
}
|
||||
|
||||
javadoc {
|
||||
include "**/org/apache/kafka/connect/*"
|
||||
enabled = false
|
||||
}
|
||||
|
||||
tasks.create(name: "copyDependantLibs", type: Copy) {
|
||||
|
@ -797,7 +797,7 @@ project(':connect:runtime') {
|
|||
}
|
||||
|
||||
javadoc {
|
||||
include "**/org/apache/kafka/connect/*"
|
||||
enabled = false
|
||||
}
|
||||
|
||||
tasks.create(name: "copyDependantLibs", type: Copy) {
|
||||
|
@ -863,7 +863,7 @@ project(':connect:file') {
|
|||
}
|
||||
|
||||
javadoc {
|
||||
include "**/org/apache/kafka/connect/*"
|
||||
enabled = false
|
||||
}
|
||||
|
||||
tasks.create(name: "copyDependantLibs", type: Copy) {
|
||||
|
|
|
@ -295,7 +295,7 @@ public class ConnectSchema implements Schema {
|
|||
|
||||
|
||||
/**
|
||||
* Get the {@link Type} associated with the the given class.
|
||||
* Get the {@link Schema.Type} associated with the the given class.
|
||||
*
|
||||
* @param klass the Class to
|
||||
* @return the corresponding type, nor null if there is no matching type
|
||||
|
|
|
@ -236,63 +236,63 @@ public class SchemaBuilder implements Schema {
|
|||
// Primitive types
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#INT8} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#INT8} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder int8() {
|
||||
return new SchemaBuilder(Type.INT8);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#INT16} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#INT16} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder int16() {
|
||||
return new SchemaBuilder(Type.INT16);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#INT32} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#INT32} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder int32() {
|
||||
return new SchemaBuilder(Type.INT32);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#INT64} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#INT64} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder int64() {
|
||||
return new SchemaBuilder(Type.INT64);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#FLOAT32} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#FLOAT32} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder float32() {
|
||||
return new SchemaBuilder(Type.FLOAT32);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#FLOAT64} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#FLOAT64} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder float64() {
|
||||
return new SchemaBuilder(Type.FLOAT64);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#BOOLEAN} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#BOOLEAN} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder bool() {
|
||||
return new SchemaBuilder(Type.BOOLEAN);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#STRING} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#STRING} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder string() {
|
||||
return new SchemaBuilder(Type.STRING);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#BYTES} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#BYTES} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder bytes() {
|
||||
return new SchemaBuilder(Type.BYTES);
|
||||
|
@ -302,7 +302,7 @@ public class SchemaBuilder implements Schema {
|
|||
// Structs
|
||||
|
||||
/**
|
||||
* @return a new {@link Type#STRUCT} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#STRUCT} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder struct() {
|
||||
return new SchemaBuilder(Type.STRUCT);
|
||||
|
@ -349,7 +349,7 @@ public class SchemaBuilder implements Schema {
|
|||
|
||||
/**
|
||||
* @param valueSchema the schema for elements of the array
|
||||
* @return a new {@link Type#ARRAY} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#ARRAY} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder array(Schema valueSchema) {
|
||||
SchemaBuilder builder = new SchemaBuilder(Type.ARRAY);
|
||||
|
@ -360,7 +360,7 @@ public class SchemaBuilder implements Schema {
|
|||
/**
|
||||
* @param keySchema the schema for keys in the map
|
||||
* @param valueSchema the schema for values in the map
|
||||
* @return a new {@link Type#MAP} SchemaBuilder
|
||||
* @return a new {@link Schema.Type#MAP} SchemaBuilder
|
||||
*/
|
||||
public static SchemaBuilder map(Schema keySchema, Schema valueSchema) {
|
||||
SchemaBuilder builder = new SchemaBuilder(Type.MAP);
|
||||
|
|
|
@ -76,7 +76,7 @@ public abstract class SourceTask implements Task {
|
|||
*
|
||||
* For example, if a task uses a {@link java.nio.channels.Selector} to receive data over the network, this method
|
||||
* could set a flag that will force {@link #poll()} to exit immediately and invoke
|
||||
* {@link java.nio.channels.Selector#wakeup()} to interrupt any ongoing requests.
|
||||
* {@link java.nio.channels.Selector#wakeup() wakeup()} to interrupt any ongoing requests.
|
||||
*/
|
||||
public abstract void stop();
|
||||
}
|
||||
|
|
|
@ -43,7 +43,7 @@ public interface Converter {
|
|||
* @param topic the topic associated with the data
|
||||
* @param schema the schema for the value
|
||||
* @param value the value to convert
|
||||
* @return
|
||||
* @return the serialized value
|
||||
*/
|
||||
byte[] fromConnectData(String topic, Schema schema, Object value);
|
||||
|
||||
|
|
Loading…
Reference in New Issue