Class | Description |
---|---|
DriverInCell |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.DriverInCell |
DriverInCell.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.DriverInCell |
DriverJoinsRide |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.DriverJoinsRide |
DriverJoinsRide.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.DriverJoinsRide |
DriverRejectsPickup |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.DriverRejectsPickup |
DriverRejectsPickup.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.DriverRejectsPickup |
GeoCellState |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.GeoCellState |
GeoCellState.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.GeoCellState |
GetDriver |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.GetDriver |
GetDriver.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.GetDriver |
InboundDriverMessage |
the messages that corresponds to the FROM_DRIVER_INGRESS
|
InboundDriverMessage.Builder |
the messages that corresponds to the FROM_DRIVER_INGRESS
|
InboundDriverMessage.LocationUpdate |
A periodic location update message
|
InboundDriverMessage.LocationUpdate.Builder |
A periodic location update message
|
InboundDriverMessage.RideEnded |
A message the driver sends when they drop off the passenger.
|
InboundDriverMessage.RideEnded.Builder |
A message the driver sends when they drop off the passenger.
|
InboundDriverMessage.RideStarted |
A message the driver sends once they pickup the passenger
|
InboundDriverMessage.RideStarted.Builder |
A message the driver sends once they pickup the passenger
|
InboundPassengerMessage |
the messages that corresponds to the FROM_PASSENGER_INGRESS
|
InboundPassengerMessage.Builder |
the messages that corresponds to the FROM_PASSENGER_INGRESS
|
InboundPassengerMessage.RequestRide |
A message sent by the physical driver to the ridesharing statefun job, indicating that the user
would like to be picked up from start_geo_cell and dropped off at end_geo_cell
|
InboundPassengerMessage.RequestRide.Builder |
A message sent by the physical driver to the ridesharing statefun job, indicating that the user
would like to be picked up from start_geo_cell and dropped off at end_geo_cell
|
JoinCell |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.JoinCell |
JoinCell.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.JoinCell |
LeaveCell |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.LeaveCell |
LeaveCell.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.LeaveCell |
OutboundDriverMessage |
the messages that corresponds to the TO_DRIVER_EGRESS
|
OutboundDriverMessage.Builder |
the messages that corresponds to the TO_DRIVER_EGRESS
|
OutboundDriverMessage.PickupPassenger |
A message that is sent to the physical driver to indicate that
a pickup is needed.
|
OutboundDriverMessage.PickupPassenger.Builder |
A message that is sent to the physical driver to indicate that
a pickup is needed.
|
OutboundPassengerMessage |
the messages that corresponds to the TO_PASSENGER_EGRESS
|
OutboundPassengerMessage.Builder |
the messages that corresponds to the TO_PASSENGER_EGRESS
|
OutboundPassengerMessage.DriverHasBeenFound |
A message that is sent to the passenger, when there is a driver that
is ready to pick them up.
|
OutboundPassengerMessage.DriverHasBeenFound.Builder |
A message that is sent to the passenger, when there is a driver that
is ready to pick them up.
|
OutboundPassengerMessage.RideEnded |
A notification that is sent to the passenger indicating that the ride has end.
|
OutboundPassengerMessage.RideEnded.Builder |
A notification that is sent to the passenger indicating that the ride has end.
|
OutboundPassengerMessage.RideFailed |
A message that is sent to the passenger when the system couldn't find in reasonable time
a driver to pickup the passenger.
|
OutboundPassengerMessage.RideFailed.Builder |
A message that is sent to the passenger when the system couldn't find in reasonable time
a driver to pickup the passenger.
|
OutboundPassengerMessage.RideStarted |
A notification that is sent to the passenger indicating that the ride has started.
|
OutboundPassengerMessage.RideStarted.Builder |
A notification that is sent to the passenger indicating that the ride has started.
|
PassengerJoinsRide |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.PassengerJoinsRide |
PassengerJoinsRide.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.PassengerJoinsRide |
PickupPassenger |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.PickupPassenger |
PickupPassenger.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.PickupPassenger |
RideEnded |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.RideEnded |
RideEnded.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.RideEnded |
RideFailed |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.RideFailed |
RideFailed.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.RideFailed |
Ridesharing | |
RideStarted |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.RideStarted |
RideStarted.Builder |
Protobuf type
org.apache.flink.statefun.examples.ridesharing.RideStarted |
Enum | Description |
---|---|
InboundDriverMessage.MessageCase | |
InboundPassengerMessage.MessageCase | |
OutboundDriverMessage.MessageCase | |
OutboundPassengerMessage.MessageCase |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.