Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/dmlc/dmlc-core
/ functions
Functions
1,057 in github.com/dmlc/dmlc-core
⨍
Functions
1,057
◇
Types & classes
297
Method
onContainersCompleted
(List<ContainerStatus> status)
tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ApplicationMaster.java:630
Method
onError
(Throwable ex)
tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ApplicationMaster.java:635
Method
onGetContainerStatusError
(ContainerId cid, Throwable ex)
tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ApplicationMaster.java:670
Method
onNodesUpdated
(List<NodeReport> nodereport)
tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ApplicationMaster.java:641
Method
onShutdownRequest
()
tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ApplicationMaster.java:645
Method
onStartContainerError
free the containers that have not yet been launched @param containers
tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ApplicationMaster.java:460
Method
onStartContainerError
(ContainerId cid, Throwable ex)
tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ApplicationMaster.java:677
Method
onStopContainerError
(ContainerId cid, Throwable ex)
tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ApplicationMaster.java:684
Method
operator *
src/config.cc:258
Method
operator!=
src/config.cc:254
Method
operator&
include/dmlc/logging.h:483
Method
operator()
! * \brief returns hash of the optional value. * \param val value. * \return hash code. */
include/dmlc/optional.h:260
Method
operator()
include/dmlc/lua.h:450
Method
operator()
include/dmlc/lua.h:674
Method
operator*
! \return dereference pointer */
include/dmlc/memory.h:211
Method
operator++
src/config.cc:244
Method
operator->
! \return dereference pointer */
include/dmlc/memory.h:215
Method
operator<
include/dmlc/concurrency.h:128
Method
operator==
test/unittest/unittest_json.cc:56
Method
operator==
test/unittest/unittest_serializer.cc:42
Method
operator==
src/config.cc:250
Method
operator==
! \brief equal comparison */
include/dmlc/optional.h:112
Method
operator==
! \brief check if nullptr */
include/dmlc/memory.h:188
Method
operator[]
include/dmlc/lua.h:545
Method
operator[]
include/dmlc/concurrentqueue.h:1593
Method
operator[]
include/dmlc/data.h:366
Method
optional
! \brief construct an optional object that contains no value */
include/dmlc/optional.h:46
Method
ostream
! * \brief construct std::ostream type * \param stream the Stream output to be used * \param buffer_size internal streambuf size */
include/dmlc/io.h:325
Method
overflow
include/dmlc/io.h:489
Method
prehash
include/dmlc/concurrentqueue.h:85
Method
prehash
include/dmlc/concurrentqueue.h:130
Method
request_shutdown
! * \brief Signal the thread that a shutdown is desired * \note Since consumer doesn't necessarily get items in order, we must wait for *
include/dmlc/thread_group.h:562
Function
requisition_block
include/dmlc/concurrentqueue.h:3082
Method
reset_empty
include/dmlc/concurrentqueue.h:1581
Function
run
run the program
tracker/dmlc_tracker/slurm.py:24
Function
run
run the program
tracker/dmlc_tracker/mpi.py:43
Function
run
internal running function.
tracker/dmlc_tracker/yarn.py:112
Method
run
()
tracker/dmlc_tracker/tracker.py:323
Method
run
include/dmlc/thread_group.h:614
Method
run
include/dmlc/lua.h:655
Method
run
include/dmlc/lua.h:663
Method
set_all_empty
include/dmlc/concurrentqueue.h:1568
Method
set_empty
include/dmlc/concurrentqueue.h:1527
Method
set_many_empty
include/dmlc/concurrentqueue.h:1548
Function
setup
(app)
doc/conf.py:159
Function
sge_submit
Internal submission function.
tracker/dmlc_tracker/sge.py:30
Method
signal
include/dmlc/blockingconcurrentqueue.h:402
Method
size_approx
Returns an estimate of the total number of elements currently in the queue. This estimate is only accurate if the queue has completely stabilized befo
include/dmlc/blockingconcurrentqueue.h:936
Method
size_approx
include/dmlc/concurrentqueue.h:1678
Function
ssh_submit
customized submit script
tracker/dmlc_tracker/ssh.py:63
Method
start
include/dmlc/thread_group.h:693
Function
submit
Submit function of local jobs.
tracker/dmlc_tracker/local.py:52
Function
submit
Submission script with SLURM.
tracker/dmlc_tracker/slurm.py:20
Function
submit
(args)
tracker/dmlc_tracker/ssh.py:38
Function
submit
(args)
tracker/dmlc_tracker/mesos.py:66
Function
submit
Submission script with MPI.
tracker/dmlc_tracker/mpi.py:39
Function
submit
Job submission script for SGE.
tracker/dmlc_tracker/sge.py:9
Function
submit
(nworker, nserver, fun_submit, hostIP='auto', pscmd=None)
tracker/dmlc_tracker/tracker.py:410
Function
submit
(args)
tracker/dmlc_tracker/yarn.py:122
Function
submit
(args)
tracker/dmlc_tracker/kubernetes.py:102
Method
subscribe
include/dmlc/concurrentqueue.h:515
Function
swap
include/dmlc/blockingconcurrentqueue.h:982
Method
swap
include/dmlc/concurrentqueue.h:658
Method
swap
Swaps this queue's state with the other's. Not thread-safe. Swapping two queues does not invalidate their tokens, however the tokens that were created
include/dmlc/concurrentqueue.h:890
Method
swap
include/dmlc/concurrentqueue.h:1382
Method
swap
include/dmlc/concurrentqueue.h:3305
Method
sync
include/dmlc/io.h:481
Function
sync_dir
sync the working directory from root node into slave node
tracker/dmlc_tracker/ssh.py:14
Function
this_is_thread_func
test/unittest/unittest_thread_group.cc:47
Method
thread_by_name
! * \brief Lookup Thread object by name * \param name Name of the thread to look up * \return A shared pointer to the Thread object */
include/dmlc/thread_group.h:499
Method
try_dequeue_bulk
include/dmlc/blockingconcurrentqueue.h:729
Method
try_dequeue_bulk
include/dmlc/concurrentqueue.h:1153
Method
try_dequeue_bulk_from_producer
include/dmlc/concurrentqueue.h:1235
Method
try_dequeue_from_producer
include/dmlc/concurrentqueue.h:1223
Method
try_dequeue_non_interleaved
include/dmlc/concurrentqueue.h:1089
Method
try_enqueue
Enqueues a single item (by copying it). Does not allocate memory. Fails if not enough room to enqueue (or implicit production is disabled because Trai
include/dmlc/blockingconcurrentqueue.h:611
Method
try_enqueue
Enqueues a single item (by copying it). Does not allocate memory. Fails if not enough room to enqueue (or implicit production is disabled because Trai
include/dmlc/concurrentqueue.h:987
Method
try_enqueue_bulk
include/dmlc/blockingconcurrentqueue.h:666
Method
try_enqueue_bulk
include/dmlc/concurrentqueue.h:1024
Function
type_name
include/dmlc/type_traits.h:101
Method
underflow
include/dmlc/io.h:508
Method
unsubscribe
include/dmlc/concurrentqueue.h:522
Method
update_current_producer_after_rotation
include/dmlc/concurrentqueue.h:1316
Method
valid
A token is always valid unless: 1) Memory allocation failed during construction 2) It was moved via the move constructor (Note: assignment does a swap
include/dmlc/concurrentqueue.h:616
Method
void (free)
include/dmlc/concurrentqueue.h:336
Method
wait
include/dmlc/blockingconcurrentqueue.h:360
Method
waitManyWithPartialSpinning
include/dmlc/blockingconcurrentqueue.h:305
Method
waitWithPartialSpinning
include/dmlc/blockingconcurrentqueue.h:266
Method
wait_dequeue_bulk
include/dmlc/blockingconcurrentqueue.h:845
Method
wait_dequeue_bulk_timed
include/dmlc/blockingconcurrentqueue.h:863
Method
wait_dequeue_timed
include/dmlc/blockingconcurrentqueue.h:777
Function
yarn_submit_pass
(nworker, nserver, pass_env)
tracker/dmlc_tracker/yarn.py:124
Method
~AzureFileSystem
src/io/azure_filesys.h:20
Method
~BasicRowIter
src/data/basic_row_iter.h:31
Method
~BlockingQueueThread
! * \brief Destructor */
include/dmlc/thread_group.h:549
Method
~CURLGlobal
src/io/s3_filesys.cc:656
Method
~CURLReadStreamBase
src/io/s3_filesys.cc:424
Method
~CachedInputSplit
destructor
src/io/cached_input_split.h:53
Method
~ConcurrentBlockingQueue
include/dmlc/concurrency.h:76
Method
~ConcurrentQueue
Note: The queue should not be accessed concurrently while it's being deleted. It's up to the user to synchronize this. This method is not thread safe.
include/dmlc/concurrentqueue.h:795
← previous
next →
901–1,000 of 1,057, ranked by callers