public class AnalysisJet
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
EVENTS_BY_NAME |
static java.util.function.Function<Event,Horse> |
FIRST_PAST_THE_POST |
static java.lang.String |
HISTORICAL |
static java.lang.String |
MULTIPLE |
Constructor and Description |
---|
AnalysisJet() |
Modifier and Type | Method and Description |
---|---|
static Pipeline |
buildPipeline()
Helper method to construct the pipeline for the job
|
java.util.Map<Horse,java.lang.Long> |
getResults() |
void |
go() |
static void |
main(java.lang.String[] args) |
void |
setup() |
public static final java.lang.String EVENTS_BY_NAME
public static final java.lang.String MULTIPLE
public static final java.lang.String HISTORICAL
public static final java.util.function.Function<Event,Horse> FIRST_PAST_THE_POST
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public void setup()
public java.util.Map<Horse,java.lang.Long> getResults()
public void go() throws java.lang.Exception
java.lang.Exception
public static Pipeline buildPipeline()