A C D E F G I K L M N O P S T U V

A

Admin - Interface in com.mapr.streams

C

close() - Method in interface com.mapr.streams.Admin

Override AutoCloseable.close() to avoid declaring a checked exception.

close(long, TimeUnit) - Method in interface com.mapr.streams.Admin

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

compactTopicNow(String, String) - Method in interface com.mapr.streams.Admin

countTopics(String) - Method in interface com.mapr.streams.Admin

Count the number of topics in a stream.

createStream(String, StreamDescriptor) - Method in interface com.mapr.streams.Admin

Create a stream.

createTopic(String, String) - Method in interface com.mapr.streams.Admin

Create a topic with the default number of partitions.

createTopic(String, String, int) - Method in interface com.mapr.streams.Admin

Create a topic with the specified number of partitions.

createTopic(String, String, TopicDescriptor) - Method in interface com.mapr.streams.Admin

Create a topic with the default number of partitions.

D

deleteStream(String) - Method in interface com.mapr.streams.Admin

Delete a stream.

deleteTopic(String, String) - Method in interface com.mapr.streams.Admin

Delete a topic.

E

editStream(String, StreamDescriptor) - Method in interface com.mapr.streams.Admin

Modify the attributes of a stream.

editTopic(String, String, int) - Method in interface com.mapr.streams.Admin

Modify the number of partitions for a topic.

editTopic(String, String, TopicDescriptor) - Method in interface com.mapr.streams.Admin

Create a topic with the default number of partitions.

F

forName(String) - Static method in enum com.mapr.streams.TimestampType

G

getAdminPerms() - Method in interface com.mapr.streams.StreamDescriptor

getAutoCreateTopics() - Method in interface com.mapr.streams.StreamDescriptor

getCompact() - Method in interface com.mapr.streams.StreamDescriptor

Gets log compaction on a stream.

getCompactionThrottleFactor() - Method in interface com.mapr.streams.StreamDescriptor

getCompressionAlgo() - Method in interface com.mapr.streams.StreamDescriptor

getConsumePerms() - Method in interface com.mapr.streams.StreamDescriptor

getCopyPerms() - Method in interface com.mapr.streams.StreamDescriptor

getDefaultPartitions() - Method in interface com.mapr.streams.StreamDescriptor

getDefaultTimestampType() - Method in interface com.mapr.streams.StreamDescriptor

getDeleteRetentionMS() - Method in interface com.mapr.streams.StreamDescriptor

Applies only if log compaction is enabled on the stream.

getForce() - Method in interface com.mapr.streams.StreamDescriptor

getIsChangelog() - Method in interface com.mapr.streams.StreamDescriptor

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

getMinCompactionLagMS() - Method in interface com.mapr.streams.StreamDescriptor

Applies only if log compaction is enabled on the stream.

getOpenFormatType() - Method in interface com.mapr.streams.MapRCDCDeserializer

getPartitions() - Method in interface com.mapr.streams.TopicDescriptor

getProducePerms() - Method in interface com.mapr.streams.StreamDescriptor

getProducerIdExpirySecs() - Method in interface com.mapr.streams.StreamDescriptor

getStreamDescriptor(String) - Method in interface com.mapr.streams.Admin

Get the StreamDescriptor for a stream.

getTimestampType() - Method in interface com.mapr.streams.TopicDescriptor

getTimeToLiveSec() - Method in interface com.mapr.streams.StreamDescriptor

getTopicDescriptor(String, String) - Method in interface com.mapr.streams.Admin

getTopicPerms() - Method in interface com.mapr.streams.StreamDescriptor

I

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

Field name representing the unique id of the message

id - Variable in enum com.mapr.streams.TimestampType

K

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

Field name representing the message key

L

listTopics(String) - Method in interface com.mapr.streams.Admin

List all the topics within a stream.

M

MapRCDCDeserializer - Interface in com.mapr.streams

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)

N

name - Variable in enum com.mapr.streams.TimestampType

newAdmin(Configuration) - Static method in class com.mapr.streams.Streams

Creates and returns an Admin instance with specified configuration.

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

Creates and returns a StreamDescriptor instance.

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

Creates and returns a TopicDescriptor instance.

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

setAdminPerms(String) - Method in interface com.mapr.streams.StreamDescriptor

Sets the admin permission ace.

setAutoCreateTopics(boolean) - Method in interface com.mapr.streams.StreamDescriptor

Sets if topics should be auto-created when a message is produced.

setCompact(boolean) - Method in interface com.mapr.streams.StreamDescriptor

Sets the log compaction on stream.

setCompactionThrottleFactor(long) - Method in interface com.mapr.streams.StreamDescriptor

setCompressionAlgo(String) - Method in interface com.mapr.streams.StreamDescriptor

Sets the compression algo.

setConsumePerms(String) - Method in interface com.mapr.streams.StreamDescriptor

Sets the consume permission ace.

setCopyPerms(String) - Method in interface com.mapr.streams.StreamDescriptor

Sets the copy permission ace.

setDefaultPartitions(int) - Method in interface com.mapr.streams.StreamDescriptor

Sets the default number of partitions per topic.

setDefaultTimestampType(TimestampType) - Method in interface com.mapr.streams.StreamDescriptor

Sets timestamp type

setDeleteRetentionMS(long) - Method in interface com.mapr.streams.StreamDescriptor

Set the time in millisecond for which delete records are retained.

setForce() - Method in interface com.mapr.streams.StreamDescriptor

setIsChangelog(boolean) - Method in interface com.mapr.streams.StreamDescriptor

Sets the type of the stream to be Changelog.

setMinCompactionLagMS(long) - Method in interface com.mapr.streams.StreamDescriptor

Set time in millisecond a message should remain uncompacted in the topic-partition.Applies only if log compaction is enabled on the stream.

setPartitions(int) - Method in interface com.mapr.streams.TopicDescriptor

Sets the number of partitions for the topic.

setProducePerms(String) - Method in interface com.mapr.streams.StreamDescriptor

Sets the producer permission ace.

setProducerIdExpirySecs(long) - Method in interface com.mapr.streams.StreamDescriptor

Sets the producer id expiry

setTimestampType(TimestampType) - Method in interface com.mapr.streams.TopicDescriptor

Sets timestamp type

setTimeToLiveSec(long) - Method in interface com.mapr.streams.StreamDescriptor

Sets the time-to-live for messages.

setTopicPerms(String) - Method in interface com.mapr.streams.StreamDescriptor

Sets the topic permission ace.

StreamDescriptor - Interface in com.mapr.streams

A StreamDescriptor contains the details about a stream such as the ttl, compression algo, default number of partitions per topic and so on.

streamExists(String) - Method in interface com.mapr.streams.Admin

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

TimestampType - Enum in com.mapr.streams

The timestamp type of the records

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

Field name representing topic of the message

TopicDescriptor - Interface in com.mapr.streams

A TopicDescriptor contains the details about a topic such as the number of partitions, the timestamptype, log compaction settingetc.

TopicRefreshListListener - Interface in com.mapr.streams

TopicRefreshRegexListener - Interface in com.mapr.streams

toString() - Method in enum com.mapr.streams.TimestampType

U

updatedTopics(Set<TopicPartition>) - Method in interface com.mapr.streams.TopicRefreshListListener

updatedTopics(Set<String>) - Method in interface com.mapr.streams.TopicRefreshRegexListener

V

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

Field name representing the message value(user provided message)

valueOf(String) - Static method in enum com.mapr.streams.TimestampType

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.mapr.streams.TimestampType

Returns an array containing the constants of this enum type, in the order they are declared.

A C D E F G I K L M N O P S T U V