util::stream Namespace Reference

Classes
class	Block
class	ChainConfigException
class	ChainPosition
class	Thread
class	Recycler
class	Chain
class	Link
struct	ChainConfig
struct	SortConfig
class	CountRecords
class	ReadSizeException
class	Read
class	PRead
class	Write
class	WriteAndRecycle
class	PWriteAndRecycle
class	FileBuffer
class	LineInput
class	MultiProgress
class	WorkerProgress
class	ChainPositions
class	Chains
class	GenericStreams
class	RewindableStream
struct	NeverCombine
class	Offsets
class	MergeQueue
class	MergingReader
class	OwningMergingReader
class	BlockSorter
class	BadSortConfig
class	Sort
class	Sorts
class	Stream
Typedefs
typedef GenericStreams< Stream >	Streams
Functions
Chain &	operator>> (Chain &chain, Link &link)
Chains &	operator>> (Chains &chains, ChainPositions &positions)
template<class T >
Chains &	operator>> (Chains &chains, GenericStreams< T > &streams)
Chain &	operator>> (Chain &chain, RewindableStream &stream)
template<class Compare , class Combine >
uint64_t	BlockingSort (Chain &chain, const SortConfig &config, const Compare &compare=Compare(), const Combine &combine=NeverCombine())
Chain &	operator>> (Chain &chain, Stream &stream)
Variables
const Recycler	kRecycle = Recycler()

---

Typedef Documentation

typedef GenericStreams<Stream> util::stream::Streams

Definition at line 121 of file multi_stream.hh.

---

Function Documentation

template<class Compare , class Combine >

uint64_t util::stream::BlockingSort	(	Chain &	chain,
		const SortConfig &	config,
		const Compare &	compare = Compare(),
		const Combine &	combine = NeverCombine()
	)			[inline]

Definition at line 540 of file sort.hh.

References util::stream::Sort< Compare, Combine >::Output(), util::stream::Sort< Compare, Combine >::Size(), sorter, and util::stream::Chain::Wait().

Here is the call graph for this function:

Chain& util::stream::operator>>	(	Chain &	chain,
		Stream &	stream
	)			[inline]

Definition at line 70 of file stream.hh.

References util::stream::Chain::Add(), and util::stream::Stream::Init().

Here is the call graph for this function:

Chain& util::stream::operator>>	(	Chain &	chain,
		RewindableStream &	stream
	)			[inline]

Definition at line 125 of file rewindable_stream.hh.

References util::stream::Chain::Add(), and util::stream::RewindableStream::Init().

Here is the call graph for this function:

template<class T >

Chains& util::stream::operator>>	(	Chains &	chains,
		GenericStreams< T > &	streams
	)			[inline]

Definition at line 114 of file multi_stream.hh.

References util::stream::GenericStreams< T >::Init().

Here is the call graph for this function:

Chains& util::stream::operator>>	(	Chains &	chains,
		ChainPositions &	positions
	)			[inline]

Definition at line 83 of file multi_stream.hh.

References util::stream::ChainPositions::Init().

Here is the call graph for this function:

Chain& util::stream::operator>>	(	Chain &	chain,
		Link &	link
	)			[inline]

Definition at line 339 of file chain.hh.

References util::stream::Chain::Add(), and util::stream::Link::Init().

Here is the call graph for this function:

---

Variable Documentation

const Recycler util::stream::kRecycle = Recycler()

Definition at line 34 of file chain.cc.

Referenced by util::stream::Chain::CompleteLoop(), lm::builder::InitialProbabilities(), and lm::builder::Output::SinkProbs().