joda::docparsing::JSONStreamParser< Scheduler > Class Template Reference

#include <JSONStreamParser.h>

Inheritance diagram for joda::docparsing::JSONStreamParser< Scheduler >:

Collaboration diagram for joda::docparsing::JSONStreamParser< Scheduler >:

Public Member Functions
	JSONStreamParser (IQueue *iqueue, OQueue *oqueue, size_t sourceSize)
	~JSONStreamParser () override
Public Member Functions inherited from IWorkerThread< JsonTextStreamParserQueue, JsonContainerQueue, size_t >
	IWorkerThread (IQueue *iqueue, OQueue *oqueue, const WConf &conf)
	IWorkerThread (IQueue *iqueue, OQueue *oqueue, WConf &&conf)
	IWorkerThread (IWorkerThread &&)=default
	IWorkerThread (const IWorkerThread &)=delete
IWorkerThread &	operator= (IWorkerThread &&)=default
IWorkerThread &	operator= (const IWorkerThread &)=delete
virtual	~IWorkerThread ()
void	start ()
void	waitFor ()
void	stop ()
bool	requestedToStop () const
bool	isRunning () const

Static Public Member Functions
static const size_t	recommendedThreads ()
Static Public Member Functions inherited from IWorkerThread< JsonTextStreamParserQueue, JsonContainerQueue, size_t >
static constexpr auto	getIQueueFlags ()
static constexpr auto	getOQueueFlags ()
static const size_t	recommendedThreads ()

Protected Member Functions
void	work () override

Additional Inherited Members
Public Types inherited from IWorkerThread< JsonTextStreamParserQueue, JsonContainerQueue, size_t >
typedef IQueueStruct::queue_t	IQueue
typedef OQueueStruct::queue_t	OQueue
typedef IQueueStruct::payload_t	IPayload
typedef OQueueStruct::payload_t	OPayload
typedef size_t	WConf
Protected Attributes inherited from IWorkerThread< JsonTextStreamParserQueue, JsonContainerQueue, size_t >
IQueue *	iqueue
OQueue *	oqueue
WConf	conf
bool	shouldRun

Detailed Description

template<class Scheduler = DefaultContainerScheduler<false>>
class joda::docparsing::JSONStreamParser< Scheduler >

A parser which takes streams containing one or more documents. The stream is read and each document is parsed until the stream ends.

Template Parameters

Scheduler

The document scheduler to use for clustering documents into containers

Constructor & Destructor Documentation

JSONStreamParser()

template<class Scheduler = DefaultContainerScheduler<false>>

joda::docparsing::JSONStreamParser< Scheduler >::JSONStreamParser ( IQueue *  iqueue, OQueue *  oqueue, size_t  sourceSize  )

inline

~JSONStreamParser()

template<class Scheduler = DefaultContainerScheduler<false>>

joda::docparsing::JSONStreamParser< Scheduler >::~JSONStreamParser ( )

inlineoverride

Member Function Documentation

recommendedThreads()

template<class Scheduler = DefaultContainerScheduler<false>>

static const size_t joda::docparsing::JSONStreamParser< Scheduler >::recommendedThreads ( )

inlinestatic

work()

template<class Scheduler = DefaultContainerScheduler<false>>

void joda::docparsing::JSONStreamParser< Scheduler >::work ( )

inlineoverrideprotectedvirtual

Implements IWorkerThread< JsonTextStreamParserQueue, JsonContainerQueue, size_t >.

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• /home/nico/joda_tmp/tmp-joda-dirs/JODA-gh/libs/joda/core/modules/parser/src/parsers/JSONStreamParser.h