KafkaPersistReaderTask (streams-persist-kafka 0.2-incubating API)

java.lang.Object
+
- org.apache.streams.kafka.KafkaPersistReaderTask
+

All Implemented Interfaces:: Runnable

+
+

public class KafkaPersistReaderTask
+extends Object
+implements Runnable

+ +
- + + +
  Constructor Summary
  + + + + + + + + +
  Constructors
  Constructor and Description
  KafkaPersistReaderTask(KafkaPersistReader reader, + kafka.consumer.KafkaStream<String,String> stream)
  +
+ +
- + + +
  Method Summary
  + + + + + + + + + + +
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method and Description
  void run()
  +
  - + + +
    Methods inherited from class java.lang.Object
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  +
+

Constructors
Constructor and Description
`KafkaPersistReaderTask(KafkaPersistReader reader, + kafka.consumer.KafkaStream<String,String> stream)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`run()`

+ +

+ + +

Constructor Detail

+ + + +

KafkaPersistReaderTask

public KafkaPersistReaderTask(KafkaPersistReader reader,
+                              kafka.consumer.KafkaStream<String,String> stream)

+ +

+ + +
Method Detail
+ + + +
- +
  run
  +
```
public void run()
```
  +
  +
  Specified by:
  +
  run in interface Runnable
  +
  +
+

java.lang.Object
+
- org.apache.streams.kafka.KafkaPersistWriter
+

+
+
All Implemented Interfaces:
+
Serializable, Runnable, StreamsOperation, StreamsPersistWriter
+
+
+
+
```
public class KafkaPersistWriter
+extends Object
+implements StreamsPersistWriter, Serializable, Runnable
```
+
+
See Also:
+
Serialized Form
+
+

+ +

+ + +
Field Summary
+ + + + + + + + + + +
Fields
Modifier and Type Field and Description
protected Queue<StreamsDatum> persistQueue
+

Fields
Modifier and Type	Field and Description
`protected Queue<StreamsDatum>`	`persistQueue`

+ +

+ + +
Constructor Summary
+ + + + + + + + + + + +
Constructors
Constructor and Description
KafkaPersistWriter()
KafkaPersistWriter(Queue<StreamsDatum> persistQueue)
+

Constructors
Constructor and Description
`KafkaPersistWriter()`
`KafkaPersistWriter(Queue<StreamsDatum> persistQueue)`

+ +

+ + +

Method Summary

+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`cleanUp()`
`Queue<StreamsDatum>`	`getPersistQueue()`
`void`	`prepare(Object configurationObject)`
`void`	`run()`
`void`	`setConfig(KafkaConfiguration config)`
`void`	`setPersistQueue(Queue<StreamsDatum> persistQueue)`
`void`	`start()`
`void`	`stop()`
`void`	`write(StreamsDatum entry)`

+ + +
Methods inherited from class java.lang.Object
+clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

+ +
- + + +
  Field Detail
  + + + +
  - +
    persistQueue
    +
```
protected volatile Queue<StreamsDatum> persistQueue
```
    +
  +
+ +
- + + +
  Constructor Detail
  + + + +
  - +
    KafkaPersistWriter
    +
```
public KafkaPersistWriter()
```
    +
  + + + +
  - +
    KafkaPersistWriter
    +
```
public KafkaPersistWriter(Queue<StreamsDatum> persistQueue)
```
    +
  +
+ +
- + + +
  Method Detail
  + + + +
  - +
    setConfig
    +
```
public void setConfig(KafkaConfiguration config)
```
    +
  + + + +
  - +
    start
    +
```
public void start()
```
    +
  + + + +
  - +
    stop
    +
```
public void stop()
```
    +
  + + + +
  - +
    setPersistQueue
    +
```
public void setPersistQueue(Queue<StreamsDatum> persistQueue)
```
    +
  + + + +
  - +
    getPersistQueue
    +
```
public Queue<StreamsDatum> getPersistQueue()
```
    +
  + + + +
  - +
    write
    +
```
public void write(StreamsDatum entry)
```
    +
    +
    Specified by:
    +
    write in interface StreamsPersistWriter
    +
    +
  + + + +
  - +
    run
    +
```
public void run()
```
    +
    +
    Specified by:
    +
    run in interface Runnable
    +
    +
  + + + +
  - +
    prepare
    +
```
public void prepare(Object configurationObject)
```
    +
    +
    Specified by:
    +
    prepare in interface StreamsOperation
    +
    +
  + + + +
  - +
    cleanUp
    +
```
public void cleanUp()
```
    +
    +
    Specified by:
    +
    cleanUp in interface StreamsOperation
    +
    +
  +
+

java.lang.Object
+
- org.apache.streams.kafka.KafkaPersistWriterTask
+

All Implemented Interfaces:: Runnable

+
+

public class KafkaPersistWriterTask
+extends Object
+implements Runnable

+ +
- + + +
  Constructor Summary
  + + + + + + + + +
  Constructors
  Constructor and Description
  KafkaPersistWriterTask(KafkaPersistWriter writer)
  +
+ +
- + + +
  Method Summary
  + + + + + + + + + + +
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method and Description
  void run()
  +
  - + + +
    Methods inherited from class java.lang.Object
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  +
+

Constructors
Constructor and Description
`KafkaPersistWriterTask(KafkaPersistWriter writer)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`run()`

+ +
- + + +
  Constructor Detail
  + + + +
  - +
    KafkaPersistWriterTask
    +
```
public KafkaPersistWriterTask(KafkaPersistWriter writer)
```
    +
  +
+ +
- + + +
  Method Detail
  + + + +
  - +
    run
    +
```
public void run()
```
    +
    +
    Specified by:
    +
    run in interface Runnable
    +
    +
  +
+

java.lang.Object
+
- org.apache.streams.kafka.StreamsPartitioner
+

All Implemented Interfaces:: kafka.producer.Partitioner<String>

+
+

public class StreamsPartitioner
+extends Object
+implements kafka.producer.Partitioner<String>

+ +
- + + +
  Constructor Summary
  + + + + + + + + +
  Constructors
  Constructor and Description
  StreamsPartitioner(kafka.utils.VerifiableProperties props)
  +
+ +
- + + +
  Method Summary
  + + + + + + + + + + +
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method and Description
  int partition(String key, + int a_numPartitions)
  +
  - + + +
    Methods inherited from class java.lang.Object
    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  +
+

Constructors
Constructor and Description
`StreamsPartitioner(kafka.utils.VerifiableProperties props)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`int`	`partition(String key, + int a_numPartitions)`

+ +
- + + +
  Constructor Detail
  + + + +
  - +
    StreamsPartitioner
    +
```
public StreamsPartitioner(kafka.utils.VerifiableProperties props)
```
    +
  +
+ +
- + + +
  Method Detail
  + + + +
  - +
    partition
    +
```
public int partition(String key,
+                     int a_numPartitions)
```
    +
    +
    Specified by:
    +
    partition in interface kafka.producer.Partitioner<String>
    +
    +
  +
+

+ + +

Uses of KafkaConfiguration in org.apache.streams.kafka

+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +

Methods in org.apache.streams.kafka that return KafkaConfiguration
Modifier and Type	Method and Description
`static KafkaConfiguration`	KafkaConfigurator.`detectConfiguration(com.typesafe.config.Config kafka)`
`KafkaConfiguration`	KafkaConfiguration.`withAdditionalProperty(String name, + Object value)`
`KafkaConfiguration`	KafkaConfiguration.`withBrokerlist(String brokerlist)`
`KafkaConfiguration`	KafkaConfiguration.`withGroupId(String groupId)`
`KafkaConfiguration`	KafkaConfiguration.`withTopic(String topic)`
`KafkaConfiguration`	KafkaConfiguration.`withZkconnect(String zkconnect)`

+ + + + + + + + + + + + + + + + +

Methods in org.apache.streams.kafka with parameters of type KafkaConfiguration
Modifier and Type	Method and Description
`void`	KafkaPersistWriter.`setConfig(KafkaConfiguration config)`
`void`	KafkaPersistReader.`setConfig(KafkaConfiguration config)`

Class KafkaPersistReaderTask

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

KafkaPersistReaderTask

Method Detail

run

Class KafkaPersistWriter

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

persistQueue

Constructor Detail

KafkaPersistWriter

KafkaPersistWriter

Method Detail

setConfig

start

stop

setPersistQueue

getPersistQueue

write

run

prepare

cleanUp

Class KafkaPersistWriterTask

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

KafkaPersistWriterTask

Method Detail

run

Class StreamsPartitioner

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

StreamsPartitioner

Method Detail

partition

Uses of Classorg.apache.streams.kafka.KafkaConfiguration

Uses of KafkaConfiguration in org.apache.streams.kafka

Uses of Classorg.apache.streams.kafka.KafkaConfigurator

Uses of Class
org.apache.streams.kafka.KafkaConfiguration

Uses of Class
org.apache.streams.kafka.KafkaConfigurator