| Constructor and Description |
|---|
ArbiterStatusListener(@NonNull StatsStorageRouter statsStorage) |
ArbiterStatusListener(@NonNull String sessionId,
@NonNull StatsStorageRouter statsStorage) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
StatsStorage
A general-purpose stats storage mechanism, for storing stats information (mainly used for iteration listeners).
|
| Modifier and Type | Method and Description |
|---|---|
StatsStorageRouter |
StatsStorageRouterProvider.getRouter() |
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionStatsStorageRouter
A simple StatsStorageRouter that simply stores the metadata, static info and updates in the specified
collections.
|
class |
RemoteUIStatsStorageRouter
Asynchronously post all updates to a remote UI that has remote listening enabled.
|
| Modifier and Type | Method and Description |
|---|---|
StatsStorageRouter |
RoutingIterationListener.getStorageRouter() |
| Modifier and Type | Method and Description |
|---|---|
void |
RoutingIterationListener.setStorageRouter(StatsStorageRouter router) |
| Modifier and Type | Field and Description |
|---|---|
protected StatsStorageRouter |
ParallelWrapper.storageRouter |
| Modifier and Type | Method and Description |
|---|---|
void |
ParallelWrapper.setListeners(StatsStorageRouter statsStorage,
Collection<? extends TrainingListener> listeners)
Set the listeners, along with a StatsStorageRouter that the results will be shuffled to (in the case of any listeners
that implement the
RoutingIterationListener interface) |
void |
ParallelWrapper.setListeners(StatsStorageRouter statsStorage,
TrainingListener... listeners)
Set the listeners, along with a StatsStorageRouter that the results will be shuffled to (in the case of any listeners
that implement the
RoutingIterationListener interface) |
| Modifier and Type | Method and Description |
|---|---|
void |
TrainingMaster.setListeners(StatsStorageRouter router,
Collection<TrainingListener> listeners)
Set the iteration listeners and the StatsStorageRouter.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SparkListenable.setListeners(StatsStorageRouter statsStorage,
Collection<? extends TrainingListener> listeners)
Set the listeners, along with a StatsStorageRouter that the results will be shuffled to (in the
case of any listeners that implement the
RoutingIterationListener interface) |
void |
SparkListenable.setListeners(StatsStorageRouter statsStorage,
TrainingListener... listeners)
Set the listeners, along with a StatsStorageRouter that the results will be shuffled to (in the
case of any listeners that implement the
RoutingIterationListener interface) |
| Modifier and Type | Class and Description |
|---|---|
class |
VanillaStatsStorageRouter
Standard router for use in Spark: simply collect the data for later serialization and passing back to the master.
|
| Modifier and Type | Method and Description |
|---|---|
StatsStorageRouter |
VanillaStatsStorageRouterProvider.getRouter() |
| Modifier and Type | Field and Description |
|---|---|
protected StatsStorageRouter |
BaseTrainingMaster.statsStorage |
| Modifier and Type | Method and Description |
|---|---|
void |
ParameterAveragingTrainingMaster.setListeners(StatsStorageRouter statsStorage,
Collection<TrainingListener> listeners) |
| Modifier and Type | Method and Description |
|---|---|
void |
SharedTrainingMaster.setListeners(StatsStorageRouter router,
Collection<TrainingListener> listeners) |
| Constructor and Description |
|---|
SharedTrainingWorker(long instanceId,
org.apache.spark.broadcast.Broadcast<NetBroadcastTuple> broadcastModel,
org.apache.spark.broadcast.Broadcast<SharedTrainingConfiguration> broadcastConfiguration,
List<TrainingListener> listeners,
StatsStorageRouter router,
Boolean workerTogglePeriodicGC,
Integer workerPeriodicGCFrequency) |
| Modifier and Type | Method and Description |
|---|---|
void |
VertxUIServer.enableRemoteListener(StatsStorageRouter statsStorage,
boolean attach) |
| Modifier and Type | Method and Description |
|---|---|
void |
UIServer.enableRemoteListener(StatsStorageRouter statsStorage,
boolean attach)
Enable the remote listener functionality, storing the received results in the specified StatsStorageRouter.
|
| Modifier and Type | Method and Description |
|---|---|
StatsStorageRouter |
BaseStatsListener.getStorageRouter() |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseStatsListener.setStorageRouter(StatsStorageRouter router) |
| Constructor and Description |
|---|
BaseStatsListener(StatsStorageRouter router)
Create a StatsListener with network information collected at every iteration.
|
BaseStatsListener(StatsStorageRouter router,
int listenerFrequency)
Create a StatsListener with network information collected every n >= 1 time steps
|
BaseStatsListener(StatsStorageRouter router,
StatsInitializationConfiguration initConfig,
StatsUpdateConfiguration updateConfig,
String sessionID,
String workerID) |
J7StatsListener(StatsStorageRouter router)
Create a StatsListener with network information collected at every iteration.
|
J7StatsListener(StatsStorageRouter router,
int listenerFrequency)
Create a StatsListener with network information collected every n >= 1 time steps
|
J7StatsListener(StatsStorageRouter router,
StatsInitializationConfiguration initConfig,
StatsUpdateConfiguration updateConfig,
String sessionID,
String workerID) |
StatsListener(StatsStorageRouter router)
Create a StatsListener with network information collected at every iteration.
|
StatsListener(StatsStorageRouter router,
int listenerFrequency)
Create a StatsListener with network information collected every n >= 1 time steps
|
StatsListener(StatsStorageRouter router,
int listenerFrequency,
String sessionId)
Create a StatsListener with network information collected every n >= 1 time steps
|
StatsListener(StatsStorageRouter router,
StatsInitializationConfiguration initConfig,
StatsUpdateConfiguration updateConfig,
String sessionID,
String workerID) |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseCollectionStatsStorage
An implementation of the
StatsStorage interface, backed by MapDB |
class |
FileStatsStorage
A StatsStorage implementation that stores UI data in a file for persistence.
|
class |
InMemoryStatsStorage
A StatsStorage implementation that stores all data in memory.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MapDBStatsStorage
An implementation of the
StatsStorage interface, backed by MapDB (in-memory or file). |
| Modifier and Type | Class and Description |
|---|---|
class |
J7FileStatsStorage
A Java 7 compatible file-based
StatsStorage implementation, based on SQLite. |
| Modifier and Type | Method and Description |
|---|---|
void |
RemoteReceiverModule.setStatsStorage(StatsStorageRouter statsStorage) |
| Constructor and Description |
|---|
ConvolutionalIterationListener(StatsStorageRouter ssr,
int iterations,
boolean openBrowser) |
ConvolutionalIterationListener(StatsStorageRouter ssr,
int iterations,
boolean openBrowser,
String sessionID,
String workerID) |
Copyright © 2020. All rights reserved.