Index

A B C D E F K N O P R S T V
All Classes and Interfaces|All Packages

A

absolute(long) - Static method in class com.infinyon.fluvio.Offset

Create an Offset at a specific absolute position in the partition.

B

beginning() - Static method in class com.infinyon.fluvio.Offset

Create an Offset pointing to the very first record in the partition.

C

com.infinyon.fluvio - package com.infinyon.fluvio

connect() - Static method in class com.infinyon.fluvio.Fluvio

Connect to a Fluvio cluster and return a Fluvio object on success.

consumer(String, int) - Method in class com.infinyon.fluvio.Fluvio

Create a PartitionConsumer that consumes records from the specified topic and partition.

D

delete() - Method in class com.infinyon.fluvio.Fluvio

delete() - Method in class com.infinyon.fluvio.FluvioError

delete() - Method in class com.infinyon.fluvio.Offset

delete() - Method in class com.infinyon.fluvio.PartitionConsumer

delete() - Method in class com.infinyon.fluvio.PartitionConsumerStream

delete() - Method in class com.infinyon.fluvio.Record

delete() - Method in class com.infinyon.fluvio.TopicProducer

E

end() - Static method in class com.infinyon.fluvio.Offset

Create an Offset pointing to the very last record in the partition.

F

finalize() - Method in class com.infinyon.fluvio.Fluvio

finalize() - Method in class com.infinyon.fluvio.FluvioError

finalize() - Method in class com.infinyon.fluvio.Offset

finalize() - Method in class com.infinyon.fluvio.PartitionConsumer

finalize() - Method in class com.infinyon.fluvio.PartitionConsumerStream

finalize() - Method in class com.infinyon.fluvio.Record

finalize() - Method in class com.infinyon.fluvio.TopicProducer

flush() - Method in class com.infinyon.fluvio.TopicProducer

Fluvio - Class in com.infinyon.fluvio

The Fluvio Java client for interacting with Fluvio streams from Java.

FluvioError - Class in com.infinyon.fluvio

from_beginning(long) - Static method in class com.infinyon.fluvio.Offset

Create an Offset pointing to the record X positions from the beginning of the partition.

from_end(long) - Static method in class com.infinyon.fluvio.Offset

Create an Offset pointing to the record X positions from the end of the partition.

K

key() - Method in class com.infinyon.fluvio.Record

The key of this Record as bytes.

key_string() - Method in class com.infinyon.fluvio.Record

The key of this Record as a String.

N

next() - Method in class com.infinyon.fluvio.PartitionConsumerStream

O

offset() - Method in class com.infinyon.fluvio.Record

The absolute offset in the partition where this Record is located.

Offset - Class in com.infinyon.fluvio

Describes the position of a record in a Fluvio partition.

P

PartitionConsumer - Class in com.infinyon.fluvio

Create streams to read records from specific Fluvio topics and partitions.

PartitionConsumerStream - Class in com.infinyon.fluvio

A stream that yields records from the origin topic and partition, starting at the given offset.

producer(String) - Method in class com.infinyon.fluvio.Fluvio

Create a TopicProducer which produces records to the specified topic.

R

Record - Class in com.infinyon.fluvio

Carries the data (key and value) for a Record in a Fluvio stream.

S

send(byte[], byte[]) - Method in class com.infinyon.fluvio.TopicProducer

Send a key/value record to this topic.

stream(Offset) - Method in class com.infinyon.fluvio.PartitionConsumer

Create a stream to read records beginning at the given Offset.

T

TopicProducer - Class in com.infinyon.fluvio

Sends records to a particular topic.

V

value() - Method in class com.infinyon.fluvio.Record

The value of this Record as bytes.

value_string() - Method in class com.infinyon.fluvio.Record

The contents of this Record as a String.

A B C D E F K N O P R S T V
All Classes and Interfaces|All Packages