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' } }
    }
  ]
}