Skip to content

State commit / cleanup #12

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
Guozhang Wang (guozhangwang) wants to merge 8 commits into from
Closed

State commit / cleanup #12

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
0a6a3af
wip: commit task states
guozhangwang Aug 26, 2015
5794daf
Fix fetch / commit / clean logic
guozhangwang Aug 27, 2015
36cfc6b
kstream refactored
Aug 27, 2015
a8859ab
remove ProcessorMetadata
Aug 27, 2015
ab971a8
adress comments
Aug 27, 2015
22f944e
comment
Aug 27, 2015
e7b6b91
rename factory to def, move some unit test files
guozhangwang Aug 27, 2015
8e9988f
rename define() to instance()
guozhangwang Aug 27, 2015
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions stream/src/main/java/org/apache/kafka/streaming/kstream/KStream.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

import org.apache.kafka.common.serialization.Deserializer;
import org.apache.kafka.common.serialization.Serializer;
import org.apache.kafka.streaming.processor.Processor;
import org.apache.kafka.streaming.processor.ProcessorDef;

/**
* KStream is an abstraction of a stream of key-value pairs.
Expand Down Expand Up @@ -83,10 +83,10 @@ public interface KStream<K, V> {
/**
* Creates a new windowed stream using a specified window instance.
*
* @param window the instance of Window
* @param windowDef the instance of Window
* @return KStream
*/
KStreamWindowed<K, V> with(Window<K, V> window);
KStreamWindowed<K, V> with(WindowDef<K, V> windowDef);

/**
* Creates an array of streams from this stream. Each stream in the array coresponds to a predicate in
Expand Down Expand Up @@ -133,7 +133,7 @@ public interface KStream<K, V> {
/**
* Processes all elements in this stream by applying a processor.
*
* @param processor the class of Processor
* @param processorDef the class of ProcessorDef
*/
<K1, V1> KStream<K1, V1> process(Processor<K, V> processor);
<K1, V1> KStream<K1, V1> process(ProcessorDef processorDef);
}
251 changes: 0 additions & 251 deletions stream/src/main/java/org/apache/kafka/streaming/kstream/SlidingWindow.java
View file
Open in desktop

This file was deleted.

Loading