java.lang.Object
- All Implemented Interfaces:
Comparable<Item>
,Iterable<Item>
,Collection<Item>
,List<Item>
,Debug
,Display
,GenericStreamlet<Value,
,Value> Streamlet<Value,
,Value> StreamletScope<Value>
,Builder<Item,
,Record> PairBuilder<Value,
Value, Record>
-
Field Summary
Modifier and TypeFieldDescriptionprotected Downlink
protected DownlinkRecord
protected Value
protected String
protected String
protected String
protected float
protected float
protected String
protected final WarpRef
Fields inherited from class swim.dataflow.AbstractRecordStreamlet
context, scope, version
-
Constructor Summary
ConstructorDescriptionDownlinkStreamlet
(WarpRef warp) DownlinkStreamlet
(WarpRef warp, StreamletScope<? extends Value> scope) -
Method Summary
Methods inherited from class swim.dataflow.AbstractRecordStreamlet
add, add, bindInput, castInput, castInput, castInput, castInput, clear, coerceInput, coerceInput, coerceInput, coerceInput, compileInlets, containsKey, containsKey, decohere, didDecohere, didDecohereInlet, didDecohereOutlet, didRecohere, didRecohereInlet, didRecohereOutlet, disconnectInputs, disconnectOutputs, get, get, get, getAttr, getAttr, getField, getField, getInput, getInput, getInput, getInput, getItem, getOutput, getSlot, getSlot, inlet, inlet, inoutlet, isEmpty, onDecohere, onDecohereOutlets, onRecohereInlets, onRecohereOutlets, outlet, outlet, put, put, putAttr, putAttr, putSlot, putSlot, recohere, remove, removeKey, removeKey, setItem, setStreamletContext, setStreamletScope, size, streamletContext, streamletScope, unbindInput, willDecohere, willDecohereInlet, willDecohereOutlet, willRecohere, willRecohereInlet, willRecohereOutlet
Methods inherited from class swim.dataflow.RecordStreamlet
compile, compileInlet, isConstant
Methods inherited from class swim.structure.Record
add, add, add, add, add, add, add, add, add, add, add, add, add, addAll, addAll, alias, appended, appended, asMutable, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, attr, bind, body, branch, commit, compareTo, compareTo, concat, contains, contains, containsAll, containsValue, create, create, debug, empty, entrySet, equals, evaluate, fieldCount, fieldIterator, fieldSet, flattened, hashCode, head, header, headers, indexOf, isAliased, isArray, isDefinite, isMutable, isObject, item, item, item, item, item, item, item, iterator, keyIterator, keySet, lastIndexOf, length, listIterator, listIterator, of, of, of, prepended, prepended, put, put, put, put, put, put, put, put, put, put, put, put, putAll, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putAttr, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, putSlot, remove, removeAll, removed, removed, retainAll, set, setItem, setItem, setItem, setItem, setItem, setItem, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, slot, stringValue, stringValue, subList, substitute, tag, tail, target, toArray, toArray, typeOrder, unflattened, updated, updated, updatedAttr, updatedAttr, updatedSlot, updatedSlot, valueCount, valueIterator, values
Methods inherited from class swim.structure.Value
absent, and, and, bitwiseAnd, bitwiseAnd, bitwiseNot, bitwiseOr, bitwiseOr, bitwiseXor, bitwiseXor, booleanValue, booleanValue, builder, byteValue, byteValue, charValue, charValue, conditional, conditional, divide, divide, doubleValue, doubleValue, eq, eq, extant, floatValue, floatValue, fromObject, ge, ge, gt, gt, integerValue, integerValue, intValue, intValue, inverse, isDefined, isDistinct, key, keyEquals, lambda, le, le, longValue, longValue, lt, lt, minus, minus, modulo, modulo, ne, ne, negative, not, numberValue, numberValue, or, or, plus, plus, positive, shortValue, shortValue, times, times, toValue
Methods inherited from class swim.structure.Item
appended, appended, appended, appended, appended, appended, cast, cast, coerce, coerce, display, evaluate, filter, filter, globalScope, invoke, max, min, precedence, prepended, prepended, prepended, prepended, prepended, prepended, substitute, toString, updated, updated, updated, updated, updated, updated, updated, updated, updated, updated, updated, updated, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedAttr, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot, updatedSlot
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
Methods inherited from interface java.util.Collection
parallelStream, removeIf, stream, toArray
Methods inherited from interface java.util.List
replaceAll, sort, spliterator
-
Field Details
-
hostUri
-
nodeUri
-
laneUri
-
prio
-
rate
-
body
-
type
-
warp
-
state
-
downlink
-
downlinkRecord
-
inputHostUri
-
inputNodeUri
-
inputLaneUri
-
inputPrio
protected float inputPrio -
inputRate
protected float inputRate -
inputBody
-
inputType
-
-
Constructor Details
-
DownlinkStreamlet
-
DownlinkStreamlet
-
-
Method Details
-
getOutput
- Specified by:
getOutput
in interfaceGenericStreamlet<Value,
Value> - Overrides:
getOutput
in classAbstractRecordStreamlet<Value,
Value>
-
onRecohere
protected void onRecohere(int version) - Overrides:
onRecohere
in classAbstractRecordStreamlet<Value,
Value>
-
reifier
-