org.apache.storm.kafka.trident

Class DrpcResultsPrinter

java.lang.Object

org.apache.storm.kafka.trident.DrpcResultsPrinter

public class DrpcResultsPrinter
extends Object

Constructor Summary

Constructors

Constructor and Description
DrpcResultsPrinter(DistributedRPC.Iface drpcClient)

Method Summary

Modifier and Type	Method and Description
static DrpcResultsPrinter	localClient()
static void	main(String[] args)
void	printResults(int num, int sleepTime, TimeUnit sleepUnit) Prints the DRPC results for the number of times specified, sleeping the specified time in between prints
static DrpcResultsPrinter	remoteClient()
static DrpcResultsPrinter	remoteClient(Map<String,Object> config, String host, int port)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DrpcResultsPrinter

public DrpcResultsPrinter(DistributedRPC.Iface drpcClient)

Method Detail

localClient

public static DrpcResultsPrinter localClient()

Returns:

local DRPC client running on the same JVML

remoteClient

public static DrpcResultsPrinter remoteClient()

Returns:

remote DRPC client running on local host, on port 3772, with defaults.yaml config

remoteClient

public static DrpcResultsPrinter remoteClient(Map<String,Object> config,
                                              String host,
                                              int port)

Returns:

remote DRPC client running on the specified host, port, with the provided config

printResults

public void printResults(int num,
                         int sleepTime,
                         TimeUnit sleepUnit)

Prints the DRPC results for the number of times specified, sleeping the specified time in between prints

main

public static void main(String[] args)