void function ( long arg0 , Triggerable arg1 ) { container . registerTimer ( arg0 , arg1 ) ; }
register a timer callback . at the specified time the triggerable will be invoked.this call is guaranteed to not happen concurrently with method calls on the operator . concode_field_sep boolean inputCopyDisabled concode_elem_sep StreamTask<?,?> container concode_elem_sep KvState<?,?,?>[] keyValueStates concode_elem_sep Logger LOG concode_elem_sep KeySelector<?,?> stateKeySelector concode_elem_sep ChainingStrategy chainingStrategy concode_elem_sep long serialVersionUID concode_elem_sep TypeSerializer<?> keySerializer concode_elem_sep Output<StreamRecord<OUT>> output concode_elem_sep HashMap<String,KvState<?,?,?>> keyValueStatesByName concode_elem_sep StreamingRuntimeContext runtimeContext concode_elem_sep HashMap<String,KvStateSnapshot<?,?,?>> keyValueStateSnapshots concode_elem_sep long recoveryTimestamp concode_elem_sep StreamConfig config concode_field_sep void notifyOfCompletedCheckpoint concode_elem_sep void restoreState concode_elem_sep ExecutionConfig getExecutionConfig concode_elem_sep void setKeyContextElement concode_elem_sep ChainingStrategy getChainingStrategy concode_elem_sep ClassLoader getUserCodeClassloader concode_elem_sep void setKeyContext concode_elem_sep void disableInputCopy concode_elem_sep boolean isInputCopyingDisabled concode_elem_sep StateBackend<?> getStateBackend concode_elem_sep StreamTaskState snapshotOperatorState concode_elem_sep StreamingRuntimeContext getRuntimeContext concode_elem_sep StreamTask<?,?> getContainingTask concode_elem_sep OperatorState<V> createKeyValueState concode_elem_sep OperatorState<V> createKeyValueState concode_elem_sep void setup concode_elem_sep void dispose concode_elem_sep StreamConfig getOperatorConfig concode_elem_sep void close concode_elem_sep void setChainingStrategy concode_elem_sep void open