JoinBolt |
JoinBolt.join(String newStream,
String field,
String priorStream)
Performs inner Join with the newStream.
|
JoinBolt |
JoinBolt.leftJoin(String newStream,
String field,
String priorStream)
Performs left Join with the newStream.
|
JoinBolt |
JoinBolt.select(String commaSeparatedKeys)
Specify projection fields.
|
JoinBolt |
JoinBolt.withLateTupleStream(String streamId) |
JoinBolt |
JoinBolt.withOutputStream(String streamName)
Optional.
|
JoinBolt |
JoinBolt.withTimestampExtractor(TimestampExtractor timestampExtractor) |
JoinBolt |
JoinBolt.withTimestampField(String fieldName) |
JoinBolt |
JoinBolt.withTumblingWindow(BaseWindowedBolt.Count count) |
JoinBolt |
JoinBolt.withTumblingWindow(BaseWindowedBolt.Duration duration) |
JoinBolt |
JoinBolt.withWindow(BaseWindowedBolt.Count windowLength) |
JoinBolt |
JoinBolt.withWindow(BaseWindowedBolt.Count windowLength,
BaseWindowedBolt.Count slidingInterval) |
JoinBolt |
JoinBolt.withWindow(BaseWindowedBolt.Count windowLength,
BaseWindowedBolt.Duration slidingInterval) |
JoinBolt |
JoinBolt.withWindow(BaseWindowedBolt.Duration windowLength) |
JoinBolt |
JoinBolt.withWindow(BaseWindowedBolt.Duration windowLength,
BaseWindowedBolt.Count slidingInterval) |
JoinBolt |
JoinBolt.withWindow(BaseWindowedBolt.Duration windowLength,
BaseWindowedBolt.Duration slidingInterval) |