Repository: kafka Updated Branches: refs/heads/trunk 7311dcbc5 -> 681c6fc1f
KAFKA-5350: Modify unstable annotations in Streams API Author: Guozhang Wang <[email protected]> Reviewers: Matthias J. Sax <[email protected]>, Jason Gustafson <[email protected]> Closes #3172 from guozhangwang/K5350-compatibility-annotations Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/681c6fc1 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/681c6fc1 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/681c6fc1 Branch: refs/heads/trunk Commit: 681c6fc1fb37c9cfec00df09fdfe5bf1b11f3b4b Parents: 7311dcb Author: Guozhang Wang <[email protected]> Authored: Wed May 31 19:30:43 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Wed May 31 19:30:43 2017 -0700 ---------------------------------------------------------------------- streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java | 2 +- .../src/main/java/org/apache/kafka/streams/StreamsMetrics.java | 2 +- .../org/apache/kafka/streams/errors/BrokerNotFoundException.java | 2 -- .../apache/kafka/streams/errors/InvalidStateStoreException.java | 2 -- .../main/java/org/apache/kafka/streams/errors/LockException.java | 2 -- .../org/apache/kafka/streams/errors/ProcessorStateException.java | 2 -- .../java/org/apache/kafka/streams/errors/StreamsException.java | 2 -- .../org/apache/kafka/streams/errors/TaskIdFormatException.java | 2 -- .../org/apache/kafka/streams/errors/TopologyBuilderException.java | 2 -- .../main/java/org/apache/kafka/streams/kstream/Aggregator.java | 2 -- .../main/java/org/apache/kafka/streams/kstream/ForeachAction.java | 2 -- .../main/java/org/apache/kafka/streams/kstream/GlobalKTable.java | 2 +- .../main/java/org/apache/kafka/streams/kstream/Initializer.java | 2 -- .../main/java/org/apache/kafka/streams/kstream/JoinWindows.java | 2 -- .../java/org/apache/kafka/streams/kstream/KGroupedStream.java | 2 +- .../main/java/org/apache/kafka/streams/kstream/KGroupedTable.java | 2 +- .../src/main/java/org/apache/kafka/streams/kstream/KStream.java | 2 +- .../java/org/apache/kafka/streams/kstream/KStreamBuilder.java | 2 ++ .../src/main/java/org/apache/kafka/streams/kstream/KTable.java | 2 +- .../java/org/apache/kafka/streams/kstream/KeyValueMapper.java | 2 -- .../src/main/java/org/apache/kafka/streams/kstream/Merger.java | 2 -- .../src/main/java/org/apache/kafka/streams/kstream/Predicate.java | 2 -- .../src/main/java/org/apache/kafka/streams/kstream/Reducer.java | 3 +-- .../java/org/apache/kafka/streams/kstream/SessionWindows.java | 2 -- .../main/java/org/apache/kafka/streams/kstream/TimeWindows.java | 2 -- .../main/java/org/apache/kafka/streams/kstream/Transformer.java | 2 -- .../org/apache/kafka/streams/kstream/TransformerSupplier.java | 2 -- .../java/org/apache/kafka/streams/kstream/UnlimitedWindows.java | 2 -- .../main/java/org/apache/kafka/streams/kstream/ValueJoiner.java | 2 -- .../main/java/org/apache/kafka/streams/kstream/ValueMapper.java | 2 -- .../java/org/apache/kafka/streams/kstream/ValueTransformer.java | 2 -- .../apache/kafka/streams/kstream/ValueTransformerSupplier.java | 2 -- .../src/main/java/org/apache/kafka/streams/kstream/Window.java | 2 -- .../src/main/java/org/apache/kafka/streams/kstream/Windowed.java | 2 -- .../src/main/java/org/apache/kafka/streams/kstream/Windows.java | 2 -- .../kafka/streams/processor/ExtractRecordMetadataTimestamp.java | 2 ++ .../apache/kafka/streams/processor/FailOnInvalidTimestamp.java | 2 ++ .../kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java | 2 ++ .../main/java/org/apache/kafka/streams/processor/Processor.java | 3 +++ .../java/org/apache/kafka/streams/processor/ProcessorContext.java | 2 +- .../org/apache/kafka/streams/processor/StateRestoreCallback.java | 3 +++ .../org/apache/kafka/streams/processor/TimestampExtractor.java | 2 ++ .../java/org/apache/kafka/streams/processor/TopologyBuilder.java | 2 ++ .../streams/processor/UsePreviousTimeOnInvalidTimestamp.java | 2 ++ .../kafka/streams/processor/WallclockTimestampExtractor.java | 2 ++ .../main/java/org/apache/kafka/streams/state/KeyValueStore.java | 2 -- .../java/org/apache/kafka/streams/state/QueryableStoreType.java | 2 -- .../org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java | 2 -- .../java/org/apache/kafka/streams/state/ReadOnlySessionStore.java | 2 -- .../java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java | 2 -- streams/src/main/java/org/apache/kafka/streams/state/Stores.java | 2 ++ .../main/java/org/apache/kafka/streams/state/StreamsMetadata.java | 2 ++ .../src/main/java/org/apache/kafka/streams/state/WindowStore.java | 2 -- 53 files changed, 35 insertions(+), 74 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java index 6da22ed..c16f379 100644 --- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java +++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java @@ -115,7 +115,7 @@ import static org.apache.kafka.streams.StreamsConfig.PROCESSING_GUARANTEE_CONFIG * @see KStreamBuilder * @see TopologyBuilder */ [email protected] [email protected] public class KafkaStreams { private static final Logger log = LoggerFactory.getLogger(KafkaStreams.class); http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java b/streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java index 773d023..d4f685b 100644 --- a/streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java +++ b/streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java @@ -26,7 +26,7 @@ import java.util.Map; /** * The Kafka Streams metrics interface for adding metric sensors and collecting metric values. */ [email protected] [email protected] public interface StreamsMetrics { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java b/streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java index 157fbd9..24c5fcb 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.errors; -import org.apache.kafka.common.annotation.InterfaceStability; /** * Indicates that none of the specified {@link org.apache.kafka.streams.StreamsConfig#BOOTSTRAP_SERVERS_CONFIG brokers} @@ -24,7 +23,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * * @see org.apache.kafka.streams.StreamsConfig */ [email protected] public class BrokerNotFoundException extends StreamsException { private final static long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java b/streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java index a6ee1f1..6f77073 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.errors; -import org.apache.kafka.common.annotation.InterfaceStability; /** * Indicates that there was a problem when trying to access a @@ -27,7 +26,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * being (re)-initialized. Once the rebalance has completed the stores will be available again. Hence, it is valid * to backoff and retry when handling this exception. */ [email protected] public class InvalidStateStoreException extends StreamsException { private final static long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/errors/LockException.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/LockException.java b/streams/src/main/java/org/apache/kafka/streams/errors/LockException.java index d5cf858..ddaa69f 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/LockException.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/LockException.java @@ -16,14 +16,12 @@ */ package org.apache.kafka.streams.errors; -import org.apache.kafka.common.annotation.InterfaceStability; /** * Indicates that the state store directory lock could not be acquired because another thread holds the lock. * * @see org.apache.kafka.streams.processor.StateStore */ [email protected] public class LockException extends StreamsException { private final static long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java b/streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java index 1b659bf..8f1f6ac 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java @@ -16,14 +16,12 @@ */ package org.apache.kafka.streams.errors; -import org.apache.kafka.common.annotation.InterfaceStability; /** * Indicates a processor state operation (e.g. put, get) has failed. * * @see org.apache.kafka.streams.processor.StateStore */ [email protected] public class ProcessorStateException extends StreamsException { private final static long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java b/streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java index dc6b1e3..41c3c31 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java @@ -17,12 +17,10 @@ package org.apache.kafka.streams.errors; import org.apache.kafka.common.KafkaException; -import org.apache.kafka.common.annotation.InterfaceStability; /** * {@link StreamsException} is the top-level exception type generated by Kafka Streams. */ [email protected] public class StreamsException extends KafkaException { private final static long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java b/streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java index c177705..6349343 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.errors; -import org.apache.kafka.common.annotation.InterfaceStability; /** * Indicates a run time error incurred while trying parse the {@link org.apache.kafka.streams.processor.TaskId task id} @@ -24,7 +23,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * * @see org.apache.kafka.streams.processor.internals.StreamTask */ [email protected] public class TaskIdFormatException extends StreamsException { private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/errors/TopologyBuilderException.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/TopologyBuilderException.java b/streams/src/main/java/org/apache/kafka/streams/errors/TopologyBuilderException.java index 387ab12..b9c0c3a 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/TopologyBuilderException.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/TopologyBuilderException.java @@ -16,13 +16,11 @@ */ package org.apache.kafka.streams.errors; -import org.apache.kafka.common.annotation.InterfaceStability; /** * Indicates a pre-run time error incurred while parsing the {@link org.apache.kafka.streams.processor.TopologyBuilder * builder} to construct the {@link org.apache.kafka.streams.processor.internals.ProcessorTopology processor topology}. */ [email protected] public class TopologyBuilderException extends StreamsException { private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java index 6121849..4eec4f5 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * The {@code Aggregator} interface for aggregating values of the given key. @@ -38,7 +37,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @see KGroupedStream#aggregate(Initializer, Aggregator, Merger, SessionWindows, org.apache.kafka.common.serialization.Serde, org.apache.kafka.streams.processor.StateStoreSupplier) * @see Reducer */ [email protected] public interface Aggregator<K, V, VA> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java b/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java index 09212a9..3e48d79 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * The {@code ForeachAction} interface for performing an action on a {@link org.apache.kafka.streams.KeyValue key-value @@ -31,7 +30,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @see KStream#foreach(ForeachAction) * @see KTable#foreach(ForeachAction) */ [email protected] public interface ForeachAction<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java b/streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java index d4be415..7266d7d 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java @@ -64,6 +64,6 @@ import org.apache.kafka.streams.state.ReadOnlyKeyValueStore; * @see KStream#join(GlobalKTable, KeyValueMapper, ValueJoiner) * @see KStream#leftJoin(GlobalKTable, KeyValueMapper, ValueJoiner) */ [email protected] [email protected] public interface GlobalKTable<K, V> { } http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java index 423791d..d41c638 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * The {@code Initializer} interface for creating an initial value in aggregations. @@ -31,7 +30,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @see KGroupedStream#aggregate(Initializer, Aggregator, Merger, SessionWindows, org.apache.kafka.common.serialization.Serde, String) * @see KGroupedStream#aggregate(Initializer, Aggregator, Merger, SessionWindows, org.apache.kafka.common.serialization.Serde, org.apache.kafka.streams.processor.StateStoreSupplier) */ [email protected] public interface Initializer<VA> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java index 2f50dc8..9d69738 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.processor.TimestampExtractor; import java.util.Map; @@ -63,7 +62,6 @@ import java.util.Map; * @see KStream#outerJoin(KStream, ValueJoiner, JoinWindows) * @see TimestampExtractor */ [email protected] public final class JoinWindows extends Windows<Window> { /** Maximum time difference for tuples that are before the join tuple. */ http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java index 2cdf047..e02231a 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java @@ -42,7 +42,7 @@ import org.apache.kafka.streams.state.WindowStore; * @param <V> Type of values * @see KStream */ [email protected] [email protected] public interface KGroupedStream<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java index 2079860..5d019c4 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java @@ -38,7 +38,7 @@ import org.apache.kafka.streams.state.QueryableStoreType; * @param <V> Type of values * @see KTable */ [email protected] [email protected] public interface KGroupedTable<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java index bb37af8..c6da8e5 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java @@ -54,7 +54,7 @@ import org.apache.kafka.streams.processor.TopologyBuilder; * @see KStreamBuilder#stream(String...) */ @SuppressWarnings("unused") [email protected] [email protected] public interface KStream<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java index 59b8c6f..b941f78 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java @@ -16,6 +16,7 @@ */ package org.apache.kafka.streams.kstream; +import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.common.serialization.Deserializer; import org.apache.kafka.common.serialization.Serde; import org.apache.kafka.streams.KafkaStreams; @@ -47,6 +48,7 @@ import java.util.regex.Pattern; * @see KTable * @see GlobalKTable */ [email protected] public class KStreamBuilder extends TopologyBuilder { private final AtomicInteger index = new AtomicInteger(0); http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java index e6219c2..7f8ab6a 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java @@ -64,7 +64,7 @@ import org.apache.kafka.streams.state.ReadOnlyKeyValueStore; * @see GlobalKTable * @see KStreamBuilder#table(String, String) */ [email protected] [email protected] public interface KTable<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java index 98ada01..e707fbb 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.KeyValue; /** @@ -45,7 +44,6 @@ import org.apache.kafka.streams.KeyValue; * @see KTable#groupBy(KeyValueMapper, org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serde) * @see KTable#toStream(KeyValueMapper) */ [email protected] public interface KeyValueMapper<K, V, VR> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java index a285945..6e6b01a 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * The interface for merging aggregate values for {@link SessionWindows} with the given key. @@ -24,7 +23,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @param <K> key type * @param <V> aggregate value type */ [email protected] public interface Merger<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java index ac8cd1b..4c7ca05 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.KeyValue; /** @@ -32,7 +31,6 @@ import org.apache.kafka.streams.KeyValue; * @see KTable#filter(Predicate) * @see KTable#filterNot(Predicate) */ [email protected] public interface Predicate<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java index f29b598..e7cc234 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java @@ -16,8 +16,8 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.KeyValue; + /** * The {@code Reducer} interface for combining two values of the same type into a new value. * In contrast to {@link Aggregator} the result type must be the same as the input type. @@ -36,7 +36,6 @@ import org.apache.kafka.streams.KeyValue; * @see KGroupedStream#reduce(Reducer, SessionWindows, org.apache.kafka.streams.processor.StateStoreSupplier) * @see Aggregator */ [email protected] public interface Reducer<V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java index 2033445..6e06461 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.processor.TimestampExtractor; /** @@ -67,7 +66,6 @@ import org.apache.kafka.streams.processor.TimestampExtractor; * @see KGroupedStream#aggregate(Initializer, Aggregator, Merger, SessionWindows, org.apache.kafka.common.serialization.Serde, org.apache.kafka.streams.processor.StateStoreSupplier) * @see TimestampExtractor */ [email protected] public final class SessionWindows { private final long gapMs; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java index 7a2d00e..38362ad 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.kstream.internals.TimeWindow; import org.apache.kafka.streams.processor.TimestampExtractor; @@ -54,7 +53,6 @@ import java.util.Map; * @see KGroupedStream#aggregate(Initializer, Aggregator, Windows, org.apache.kafka.streams.processor.StateStoreSupplier) * @see TimestampExtractor */ [email protected] public final class TimeWindows extends Windows<TimeWindow> { /** The size of the windows in milliseconds. */ http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java index f0a322e..7265a11 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.KeyValue; import org.apache.kafka.streams.processor.ProcessorContext; import org.apache.kafka.streams.processor.StateStore; @@ -45,7 +44,6 @@ import org.apache.kafka.streams.processor.TimestampExtractor; * @see KStream#map(KeyValueMapper) * @see KStream#flatMap(KeyValueMapper) */ [email protected] public interface Transformer<K, V, R> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java b/streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java index ba8aba9..b680347 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * A {@code TransformerSupplier} interface which can create one or more {@link Transformer} instances. @@ -31,7 +30,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @see ValueTransformerSupplier * @see KStream#transformValues(ValueTransformerSupplier, String...) */ [email protected] public interface TransformerSupplier<K, V, R> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java index cf0366d..e116a8b 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.kstream.internals.UnlimitedWindow; import org.apache.kafka.streams.processor.TimestampExtractor; @@ -43,7 +42,6 @@ import java.util.Map; * @see KGroupedStream#aggregate(Initializer, Aggregator, Windows, org.apache.kafka.streams.processor.StateStoreSupplier) * @see TimestampExtractor */ [email protected] public final class UnlimitedWindows extends Windows<UnlimitedWindow> { private static final long DEFAULT_START_TIMESTAMP_MS = 0L; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java index 7392cb0..1ed6003 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * The {@code ValueJoiner} interface for joining two values into a new value of arbitrary type. @@ -41,7 +40,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @see KTable#leftJoin(KTable, ValueJoiner) * @see KTable#outerJoin(KTable, ValueJoiner) */ [email protected] public interface ValueJoiner<V1, V2, VR> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java index 0c1a0c9..51396b5 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * The {@code ValueMapper} interface for mapping a value to a new value of arbitrary type. @@ -34,7 +33,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @see KStream#flatMapValues(ValueMapper) * @see KTable#mapValues(ValueMapper) */ [email protected] public interface ValueMapper<V, VR> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java index 6c6ec50..0936e7a 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.KeyValue; import org.apache.kafka.streams.errors.StreamsException; import org.apache.kafka.streams.processor.ProcessorContext; @@ -42,7 +41,6 @@ import org.apache.kafka.streams.processor.TimestampExtractor; * @see KStream#transformValues(ValueTransformerSupplier, String...) * @see Transformer */ [email protected] public interface ValueTransformer<V, VR> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java index 2adc060..78234ae 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * A {@code ValueTransformerSupplier} interface which can create one or more {@link ValueTransformer} instances. @@ -29,7 +28,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @see TransformerSupplier * @see KStream#transform(TransformerSupplier, String...) */ [email protected] public interface ValueTransformerSupplier<V, VR> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Window.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Window.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Window.java index c342112..08540a1 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Window.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Window.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.processor.TimestampExtractor; /** @@ -33,7 +32,6 @@ import org.apache.kafka.streams.processor.TimestampExtractor; * @see org.apache.kafka.streams.kstream.internals.UnlimitedWindow * @see TimestampExtractor */ [email protected] public abstract class Window { protected final long startMs; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java index 7234797..576706e 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; /** * The result key type of a windowed stream aggregation. @@ -40,7 +39,6 @@ import org.apache.kafka.common.annotation.InterfaceStability; * @see KGroupedStream#aggregate(Initializer, Aggregator, Merger, SessionWindows, org.apache.kafka.common.serialization.Serde, org.apache.kafka.streams.processor.StateStoreSupplier) * @see KGroupedStream#aggregate(Initializer, Aggregator, Merger, SessionWindows, org.apache.kafka.common.serialization.Serde, String) */ [email protected] public class Windowed<K> { private final K key; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java index d44db53..09fdfce 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.kstream; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.processor.TimestampExtractor; import java.util.Map; @@ -35,7 +34,6 @@ import java.util.Map; * @see SessionWindows * @see TimestampExtractor */ [email protected] public abstract class Windows<W extends Window> { private static final int DEFAULT_NUM_SEGMENTS = 3; http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java b/streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java index 59575f5..79c8dd3 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java @@ -17,6 +17,7 @@ package org.apache.kafka.streams.processor; import org.apache.kafka.clients.consumer.ConsumerRecord; +import org.apache.kafka.common.annotation.InterfaceStability; /** * Retrieves embedded metadata timestamps from Kafka messages. @@ -42,6 +43,7 @@ import org.apache.kafka.clients.consumer.ConsumerRecord; * @see UsePreviousTimeOnInvalidTimestamp * @see WallclockTimestampExtractor */ [email protected] abstract class ExtractRecordMetadataTimestamp implements TimestampExtractor { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java b/streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java index 9b90c08..e8fc78c 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java @@ -17,6 +17,7 @@ package org.apache.kafka.streams.processor; import org.apache.kafka.clients.consumer.ConsumerRecord; +import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.errors.StreamsException; /** @@ -42,6 +43,7 @@ import org.apache.kafka.streams.errors.StreamsException; * @see UsePreviousTimeOnInvalidTimestamp * @see WallclockTimestampExtractor */ [email protected] public class FailOnInvalidTimestamp extends ExtractRecordMetadataTimestamp { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java b/streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java index 228f2ee..0561e61 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java @@ -17,6 +17,7 @@ package org.apache.kafka.streams.processor; import org.apache.kafka.clients.consumer.ConsumerRecord; +import org.apache.kafka.common.annotation.InterfaceStability; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -45,6 +46,7 @@ import org.slf4j.LoggerFactory; * @see UsePreviousTimeOnInvalidTimestamp * @see WallclockTimestampExtractor */ [email protected] public class LogAndSkipOnInvalidTimestamp extends ExtractRecordMetadataTimestamp { private static final Logger log = LoggerFactory.getLogger(LogAndSkipOnInvalidTimestamp.class); http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/Processor.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/Processor.java b/streams/src/main/java/org/apache/kafka/streams/processor/Processor.java index b3f40d1..2aaf45e 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/Processor.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/Processor.java @@ -16,12 +16,15 @@ */ package org.apache.kafka.streams.processor; +import org.apache.kafka.common.annotation.InterfaceStability; + /** * A processor of key-value pair records. * * @param <K> the type of keys * @param <V> the type of values */ [email protected] public interface Processor<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java b/streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java index ea50fdc..559e9f7 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java @@ -26,7 +26,7 @@ import java.util.Map; /** * Processor context interface. */ [email protected] [email protected] public interface ProcessorContext { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java b/streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java index 2e896c8..91732c3 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java @@ -16,10 +16,13 @@ */ package org.apache.kafka.streams.processor; +import org.apache.kafka.common.annotation.InterfaceStability; + /** * Restoration logic for log-backed state stores upon restart, * it takes one record at a time from the logs to apply to the restoring state. */ [email protected] public interface StateRestoreCallback { void restore(byte[] key, byte[] value); http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java b/streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java index f5e0e1d..bdd4403 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java @@ -17,12 +17,14 @@ package org.apache.kafka.streams.processor; import org.apache.kafka.clients.consumer.ConsumerRecord; +import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.kstream.KTable; /** * An interface that allows the Kafka Streams framework to extract a timestamp from an instance of {@link ConsumerRecord}. * The extracted timestamp is defined as milliseconds. */ [email protected] public interface TimestampExtractor { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java b/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java index 08839cd..f9a0397 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java @@ -16,6 +16,7 @@ */ package org.apache.kafka.streams.processor; +import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.common.serialization.Deserializer; import org.apache.kafka.common.serialization.Serializer; import org.apache.kafka.common.utils.Utils; @@ -60,6 +61,7 @@ import java.util.regex.Pattern; * to construct an acyclic graph of these nodes, and the builder is then passed into a new {@link org.apache.kafka.streams.KafkaStreams} * instance that will then {@link org.apache.kafka.streams.KafkaStreams#start() begin consuming, processing, and producing records}. */ [email protected] public class TopologyBuilder { private static final Logger log = LoggerFactory.getLogger(TopologyBuilder.class); http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java b/streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java index bc96110..dd952cc 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java @@ -17,6 +17,7 @@ package org.apache.kafka.streams.processor; import org.apache.kafka.clients.consumer.ConsumerRecord; +import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.errors.StreamsException; /** @@ -42,6 +43,7 @@ import org.apache.kafka.streams.errors.StreamsException; * @see LogAndSkipOnInvalidTimestamp * @see WallclockTimestampExtractor */ [email protected] public class UsePreviousTimeOnInvalidTimestamp extends ExtractRecordMetadataTimestamp { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java b/streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java index 555ed10..ad3b3bc 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java @@ -17,6 +17,7 @@ package org.apache.kafka.streams.processor; import org.apache.kafka.clients.consumer.ConsumerRecord; +import org.apache.kafka.common.annotation.InterfaceStability; /** * Retrieves current wall clock timestamps as {@link System#currentTimeMillis()}. @@ -30,6 +31,7 @@ import org.apache.kafka.clients.consumer.ConsumerRecord; * @see LogAndSkipOnInvalidTimestamp * @see UsePreviousTimeOnInvalidTimestamp */ [email protected] public class WallclockTimestampExtractor implements TimestampExtractor { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java b/streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java index a6addba..bd18835 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.state; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.KeyValue; import org.apache.kafka.streams.processor.StateStore; @@ -28,7 +27,6 @@ import java.util.List; * @param <K> The key type * @param <V> The value type */ [email protected] public interface KeyValueStore<K, V> extends StateStore, ReadOnlyKeyValueStore<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java b/streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java index 6383a9c..11b849b 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.state; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.processor.StateStore; import org.apache.kafka.streams.state.internals.StateStoreProvider; @@ -28,7 +27,6 @@ import org.apache.kafka.streams.state.internals.StateStoreProvider; * * @param <T> The store type */ [email protected] public interface QueryableStoreType<T> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java index c638085..76bb47b 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.state; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.errors.InvalidStateStoreException; /** @@ -27,7 +26,6 @@ import org.apache.kafka.streams.errors.InvalidStateStoreException; * @param <K> the key type * @param <V> the value type */ [email protected] public interface ReadOnlyKeyValueStore<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java index 7079769..094e3fc 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java @@ -17,7 +17,6 @@ package org.apache.kafka.streams.state; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.kstream.Windowed; /** @@ -28,7 +27,6 @@ import org.apache.kafka.streams.kstream.Windowed; * @param <K> the key type * @param <AGG> the aggregated value type */ [email protected] public interface ReadOnlySessionStore<K, AGG> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java index 51864e5..b128c58 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.state; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.errors.InvalidStateStoreException; import org.apache.kafka.streams.kstream.Windowed; @@ -27,7 +26,6 @@ import org.apache.kafka.streams.kstream.Windowed; * @param <K> Type of keys * @param <V> Type of values */ [email protected] public interface ReadOnlyWindowStore<K, V> { /** http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/state/Stores.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/Stores.java b/streams/src/main/java/org/apache/kafka/streams/state/Stores.java index bb5abf8..86ee1d2 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/Stores.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/Stores.java @@ -16,6 +16,7 @@ */ package org.apache.kafka.streams.state; +import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.common.serialization.Serde; import org.apache.kafka.common.serialization.Serdes; import org.apache.kafka.streams.processor.StateStoreSupplier; @@ -34,6 +35,7 @@ import java.util.Map; /** * Factory for creating state stores in Kafka Streams. */ [email protected] public class Stores { private static final Logger log = LoggerFactory.getLogger(Stores.class); http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java b/streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java index 198b1b8..025f36c 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java @@ -17,6 +17,7 @@ package org.apache.kafka.streams.state; import org.apache.kafka.common.TopicPartition; +import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.KafkaStreams; import java.util.Collections; @@ -29,6 +30,7 @@ import java.util.Set; * the instance and the Set of {@link TopicPartition}s available on the instance. * NOTE: This is a point in time view. It may change when rebalances happen. */ [email protected] public class StreamsMetadata { /** * Sentinel to indicate that the StreamsMetadata is currently unavailable. This can occur during rebalance http://git-wip-us.apache.org/repos/asf/kafka/blob/681c6fc1/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java index c9d5d71..fc8ca6f 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java @@ -16,7 +16,6 @@ */ package org.apache.kafka.streams.state; -import org.apache.kafka.common.annotation.InterfaceStability; import org.apache.kafka.streams.processor.StateStore; /** @@ -25,7 +24,6 @@ import org.apache.kafka.streams.processor.StateStore; * @param <K> Type of keys * @param <V> Type of values */ [email protected] public interface WindowStore<K, V> extends StateStore, ReadOnlyWindowStore<K, V> { /**
