C G I K M O P S T V

C

com.mapr.streams - package com.mapr.streams

G

getMessageStore(String) - Static method in class com.mapr.streams.Streams

Returns a read-only DocumentStore object representing the stream of the given path

getMessageStore(String, Configuration) - Static method in class com.mapr.streams.Streams

Returns a read-only DocumentStore object representing the stream of the given path

getMessageStore(String, String...) - Static method in class com.mapr.streams.Streams

Returns a read-only DocumentStore object representing the stream of the given path User can also provide only a subset of topics to read messages from

getMessageStore(String, Configuration, String...) - Static method in class com.mapr.streams.Streams

Returns a read-only DocumentStore object representing the stream of the given path User can also provide only a subset of topics to read messages from

getMessageStore(String, Pattern) - Static method in class com.mapr.streams.Streams

Returns a read-only DocumentStore object representing the stream of the given path User can also provide a regex representing all topics to read messages from

getMessageStore(String, Configuration, Pattern) - Static method in class com.mapr.streams.Streams

Returns a read-only DocumentStore object representing the stream of the given path User can also provide a regex representing all topics to read messages from

I

ID - Static variable in class com.mapr.streams.Streams

Field name representing the unique id of the message

K

KEY - Static variable in class com.mapr.streams.Streams

Field name representing the message key

M

MAX_CACHE_MEMORY - Static variable in class com.mapr.streams.Streams

Configuration parameter that controls the maximum cache memory to use while iterating through the scanned documents(default long: 100MB)

MAX_SCANNER_THREADS - Static variable in class com.mapr.streams.Streams

Configuration parameter to set the maximum number of background threads to scan the documents(default int: 16)

O

OFFSET - Static variable in class com.mapr.streams.Streams

Field name representing offset of the message

P

PARTITION - Static variable in class com.mapr.streams.Streams

Field name representing partition id of the message

PRODUCER - Static variable in class com.mapr.streams.Streams

Field name representing producer of the message

S

Streams - Class in com.mapr.streams

This class provides the entry point to accessing MapR streams for analytics purposes.

Streams() - Constructor for class com.mapr.streams.Streams

T

TOPIC - Static variable in class com.mapr.streams.Streams

Field name representing topic of the message

V

VALUE - Static variable in class com.mapr.streams.Streams

Field name representing the message value(user provided message)

C G I K M O P S T V