public final class JetBetMain
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
EVENT_ID |
static java.lang.String |
USER_ID |
static java.lang.String |
WORST_ID |
Constructor and Description |
---|
JetBetMain() |
Modifier and Type | Method and Description |
---|---|
static Pipeline |
buildPipeline()
Helper method to construct the pipeline for the job
|
HazelcastInstance |
getClient() |
static <any> |
getMaxExposureAsTuple(java.util.Map<Horse,java.lang.Double> exposures)
Pick the largest exposure from a input map.
|
void |
loadHistoricalRaces()
Loads in historical data and stores in Hazelcast IMDG.
|
static void |
main(java.lang.String[] args) |
void |
outputPossibleLosses()
Helper method that calculates largest possible loss and the results that
caused that outcome.
|
void |
run()
Main run loop
|
void |
stop() |
public static final java.lang.String USER_ID
public static final java.lang.String EVENT_ID
public static final java.lang.String WORST_ID
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public HazelcastInstance getClient()
public void stop() throws java.io.IOException
java.io.IOException
public void run()
public static Pipeline buildPipeline()
public static final <any> getMaxExposureAsTuple(java.util.Map<Horse,java.lang.Double> exposures)
exposures
- exposed amount per horsepublic void outputPossibleLosses()
public void loadHistoricalRaces() throws java.io.IOException
java.io.IOException
- some form of IO problem was encountered when opening the historical data