Get the parameters

Create a config directly from the command line arguments

@param fromAddress The address to connect from. @param toSocket The socket address to connect to. @param timeout The timeout fr the connection. @param

This utility method tries to connect to the JobManager using the InetAddress returned by InetAddress.getLocalHost(). The purpose of the utility is to

Try to find a local address which allows as to connect to the targetAddress using the given strategy @param strategy Depending on the strategy, the m

Finds the local network address from which this machine can connect to the target address. This method tries to establish a proper network connection

Flatten into just ads

Generate a random list of ads and campaigns

Subclasses must override this to generate a data element

Checks if two addresses have a common prefix (first 2 bytes). Example: 192.168.???.??? Works also with ipv6, but accepts probably too many addresses

The identity selector

Configure Kafka source

Create Kafka Source

Create a Kafka source

Setup kafka source

Given a desired load figure out how many elements to generate in each timeslice before yielding for the rest of that timeslice

Prepare Redis for test

Setup Flink environment

Do some Flink Configuration

Choose either Kafka or data generator as source

Choose source - either Kafka or data generator