java.lang.Object
swim.system.AbstractWarpRef
swim.system.AbstractTierBinding
swim.system.LaneModel<View,U>
swim.system.warp.WarpLaneModel<JoinValueLaneView<?,?>,JoinValueLaneUplink>
swim.system.lane.JoinValueLaneModel
- All Implemented Interfaces:
DownlinkFactory
,WarpRef
,CellBinding
,CellContext
,LaneBinding
,TierBinding
,Log
-
Field Summary
Modifier and TypeFieldDescriptionprotected HashTrieMap<Value,
JoinValueLaneDownlink<?>> protected int
Fields inherited from class swim.system.warp.WarpLaneModel
EXEC_DELTA, EXEC_TIME
Fields inherited from class swim.system.AbstractTierBinding
CLOSED_PHASE, CLOSED_STATE, CLOSING_STATE, FAILED_STATE, FAILING_STATE, LOADED_PHASE, LOADED_STATE, LOADING_STATE, OPENED_PHASE, OPENED_STATE, OPENING_STATE, PHASE_MASK, PHASE_SHIFT, RECOVERING_STATE, STARTED_PHASE, STARTED_STATE, STARTING_STATE, STATE_MASK, status, STATUS, STOPPING_STATE, UNLOADING_STATE
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
clear
(JoinValueLaneView<?, ?> view) protected void
closeDownlinkKey
(Value key) protected void
protected JoinValueLaneUplink
createWarpUplink
(WarpBinding link) protected void
cueDownKey
(Value key) protected void
didOpenLaneView
(JoinValueLaneView<?, ?> view) protected void
downlink
(Value key, JoinValueLaneDownlink<?> downlink) entrySet()
getDownlink
(Object key) final boolean
isResident
(boolean isResident) final boolean
isTransient
(boolean isTransient) iterator()
keySet()
laneType()
void
onCommand
(Push<CommandMessage> push) protected void
openDownlink
(Value key, JoinValueLaneDownlink<?> downlink) protected void
protected void
void
put
(JoinValueLaneDownlink<?> downlink, Value key, Value newValue) <K,
V> V put
(JoinValueLaneView<K, V> view, K keyObject, V newObject) <K,
V> V remove
(JoinValueLaneView<K, V> view, K keyObject) values()
protected void
willLoad()
protected void
Methods inherited from class swim.system.warp.WarpLaneModel
accumulateExecTime, accumulateWarpDownlinkProfile, accumulateWarpUplinkProfile, collectProfile, createUplink, cueDown, didClose, didCloseUplink, didEnter, didLeave, didOpenUplink, didUpdateMetrics, flushMetrics, pushUp, pushUpCommand, reportDown, reportMetrics, sendDown
Methods inherited from class swim.system.LaneModel
bindDownlink, bottomLane, cellAddress, closeDownlink, closeLaneView, closeUplink, createUplinkAddress, debug, didCloseLaneView, didFail, edgeName, error, fail, getLaneView, getUplink, hostUri, info, isLinked, laneContext, laneUri, laneWrapper, meshUri, node, nodeUri, openDownlink, openLaneView, openMetaDownlink, openMetaLane, openMetaLanes, openMetaUplink, openReflectLanes, openUplink, partKey, policy, pushDown, schedule, setLaneContext, stage, store, tierContext, trace, unwrapLane, uplinks, warn, willClose, willOpen, willStop, willUnload
Methods inherited from class swim.system.AbstractTierBinding
activate, awaitStart, close, didLoad, didOpen, didStart, didStop, didUnload, isClosed, isLoaded, isOpened, isStarted, load, open, start, stop, unload
Methods inherited from class swim.system.AbstractWarpRef
command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, command, downlink, downlinkHttp, downlinkList, downlinkMap, downlinkValue, downlinkWs, hostRef, hostRef, laneRef, laneRef, laneRef, laneRef, nodeRef, nodeRef, nodeRef, nodeRef
-
Field Details
-
flags
protected int flags -
data
-
downlinks
-
-
Constructor Details
-
JoinValueLaneModel
public JoinValueLaneModel()
-
-
Method Details
-
laneType
-
createWarpUplink
- Specified by:
createWarpUplink
in classWarpLaneModel<JoinValueLaneView<?,
?>, JoinValueLaneUplink>
-
openDownlinks
protected void openDownlinks() -
downlink
-
openDownlink
-
closeDownlinks
protected void closeDownlinks() -
closeDownlinkKey
-
didOpenLaneView
- Specified by:
didOpenLaneView
in classLaneModel<JoinValueLaneView<?,
?>, JoinValueLaneUplink>
-
onCommand
- Overrides:
onCommand
in classWarpLaneModel<JoinValueLaneView<?,
?>, JoinValueLaneUplink>
-
cueDownKey
-
isResident
public final boolean isResident() -
isResident
-
isTransient
public final boolean isTransient() -
isTransient
-
get
-
getDownlink
-
put
-
put
-
remove
-
clear
-
iterator
-
keyIterator
-
valueIterator
-
entrySet
-
keySet
-
values
-
openStore
protected void openStore() -
willLoad
protected void willLoad()- Overrides:
willLoad
in classLaneModel<JoinValueLaneView<?,
?>, JoinValueLaneUplink>
-
willStart
protected void willStart()- Overrides:
willStart
in classLaneModel<JoinValueLaneView<?,
?>, JoinValueLaneUplink>
-