MCPcopy Create free account

hub / github.com/beyondj2ee/flumeng-kafka-plugin / functions

Functions24 in github.com/beyondj2ee/flumeng-kafka-plugin

⨍ Functions 24◇ Types & classes 10
↓ 4 callersMethodconfigure
Configure void. @param context the context
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSink.java:76
↓ 4 callersMethodstart
Start void.
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSink.java:91
↓ 3 callersMethodstop
Stop void.
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSink.java:160
↓ 1 callersMethodconsumeLog
Gets consume count. @return the consume count
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/ConsumerChecker.java:87
↓ 1 callersMethodprocess
Process status. @return the status @throws EventDeliveryException the event delivery exception
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSink.java:105
↓ 1 callersMethodsendMessageToKafka
Send message to kafka.
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSourceTest.java:146
↓ 1 callersMethodshutdown
Shutdown void.
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/ConsumerChecker.java:72
↓ 1 callersMethodshutdown
shutdown consumer threads. @throws Exception the exception
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java:175
MethodConsumerChecker
Instantiates a new Consumer checker. @param zookeeper the zookeeper @param groupId the group id @param topic the top
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/ConsumerChecker.java:54
MethodConsumerWorker
Instantiates a new Consumer test. @param kafkaStream the kafka stream @param threadNumber the thread number
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/ConsumerChecker.java:137
MethodConsumerWorker
Instantiates a new Consumer test. @param kafkaStream the kafka stream @param threadNumber the thread number
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java:212
MethodSinglePartition
Instantiates a new Single partition. @param props the props
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/SinglePartition.java:33
Methodconfigure
Configure void. @param context the context
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java:88
Methodpartition
choose only one partition. @param key partition key @param numberOfPartions number of partitions @return the int
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/SinglePartition.java:45
Methodrun
Run void.
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/ConsumerChecker.java:145
Methodrun
Run void.
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java:221
MethodsetUp
Sets up. @throws Exception the exception
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSinkTest.java:71
MethodsetUp
Sets up. @throws Exception the exception
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSourceTest.java:75
Methodstart
Start void.
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java:108
Methodstop
Stop void.
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java:145
MethodtestAppend
Test produce & consume. @throws InterruptedException the interrupted exception
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSinkTest.java:120
MethodtestAppend
Test append. @throws Exception the exception
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSourceTest.java:117
MethodtestLifecycle
Test Sink lifecycle. @throws InterruptedException the interrupted exception @throws InterruptedException the interrupted exce
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSinkTest.java:108
MethodtestLifecycle
Test lifecycle. @throws InterruptedException the interrupted exception @throws InterruptedException the interrupted excepti
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSourceTest.java:105