AtlasStreamProcessing> sp.proc1.stats({options: {verbose: true}})
|
{
|
ok: 1,
|
ns: '658dbd7477a8e02a0205c7e0.65094f059e0776665611598b.proc1',
|
stats: {
|
name: 'proc1',
|
status: 'running',
|
scaleFactor: Long('1'),
|
inputMessageCount: Long('50720'),
|
inputMessageSize: 19785934,
|
outputMessageCount: Long('50720'),
|
outputMessageSize: 19785934,
|
dlqMessageCount: Long('0'),
|
dlqMessageSize: Long('0'),
|
stateSize: Long('0'),
|
operatorStats: [
|
{
|
name: 'SampleDataSourceOperator',
|
inputMessageCount: Long('50720'),
|
inputMessageSize: Long('19785934'),
|
outputMessageCount: Long('50720'),
|
outputMessageSize: Long('0'),
|
dlqMessageCount: Long('0'),
|
dlqMessageSize: Long('0'),
|
stateSize: Long('0'),
|
maxMemoryUsage: Long('0'),
|
executionTime: Long('0')
|
},
|
{
|
name: 'MergeOperator',
|
inputMessageCount: Long('50720'),
|
inputMessageSize: Long('19785934'),
|
outputMessageCount: Long('0'),
|
outputMessageSize: Long('0'),
|
dlqMessageCount: Long('0'),
|
dlqMessageSize: Long('0'),
|
stateSize: Long('0'),
|
maxMemoryUsage: Long('0'),
|
executionTime: Long('0')
|
}
|
],
|
ok: 1
|
},
|
pipeline: [
|
{ '$source': { connectionName: 'sample_stream_solar' } },
|
{
|
'$merge': { into: { connectionName: 'atlas', db: 'test', coll: 'proc1' } }
|
}
|
]
|
}
|