A B C D E F G H I K L M N O P Q R S T U V W

A

add(TransactionBase, K, V) - Method in class org.apache.fluo.recipes.core.export.ExportQueue

add(LogEntry) - Method in class org.apache.fluo.recipes.core.transaction.TxLog

Adds LogEntry to TxLog

addAll(TransactionBase, Map<K, V>) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue

Queues updates for this combine queue.

addAll(TransactionBase, Iterator<Export<K, V>>) - Method in class org.apache.fluo.recipes.core.export.ExportQueue

addHash(String) - Method in class org.apache.fluo.recipes.core.data.RowHasher

addHash(Bytes) - Method in class org.apache.fluo.recipes.core.data.RowHasher

addTransientRange(String, RowRange) - Method in class org.apache.fluo.recipes.core.common.TransientRegistry

This method is expected to be called before Fluo is initialized to register transient ranges.

andThen(Exporter<K, V>) - Method in interface org.apache.fluo.recipes.core.export.function.Exporter

Returns a composed Exporter that exports, in sequence, to this then to after.

B

bc() - Method in class org.apache.fluo.recipes.core.types.TypeLayer

Initiates the chain of calls needed to build a column.

buckets(int) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.FluentArg3

buckets(int) - Method in interface org.apache.fluo.recipes.core.export.ExportQueue.FluentArg3

bucketsPerTablet(int) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.FluentOptions

Sets the number of buckets per tablet to generate.

bucketsPerTablet(int) - Method in interface org.apache.fluo.recipes.core.export.ExportQueue.FluentOptions

Sets the number of buckets per tablet to generate.

bufferSize(long) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.FluentOptions

Sets a limit on the amount of serialized updates to read into memory.

bufferSize(long) - Method in interface org.apache.fluo.recipes.core.export.ExportQueue.FluentOptions

Sets a limit on the amount of serialized updates to read into memory.

C

ChangeObserver<K,V> - Interface in org.apache.fluo.recipes.core.combine

CombineQueue uses this interface to notify of changes to a keys value.

ChangeObserver.Change<K2,V2> - Interface in org.apache.fluo.recipes.core.combine

close() - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransaction

close() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshot

close() - Method in class org.apache.fluo.recipes.core.types.TypedTransaction

col(Column) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.FamilyMethods

CollisionFreeMap<K,V> - Class in org.apache.fluo.recipes.core.map

Deprecated.

since 1.1.0 use CombineQueue

CollisionFreeMap.Initializer<K2,V2> - Class in org.apache.fluo.recipes.core.map

Deprecated.

since 1.1.0

CollisionFreeMap.Optimizer - Class in org.apache.fluo.recipes.core.map

Deprecated.

since 1.1.0 use CombineQueue.Optimizer

CollisionFreeMap.Options - Class in org.apache.fluo.recipes.core.map

Deprecated.

since 1.1.0

CollisionFreeMapObserver - Class in org.apache.fluo.recipes.core.map

Deprecated.

since 1.1.0

CollisionFreeMapObserver() - Constructor for class org.apache.fluo.recipes.core.map.CollisionFreeMapObserver

Deprecated.

columns(Set<Column>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ColumnsMethods

columns(Column...) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ColumnsMethods

columns(Set<Column>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueFamilyMethods

columns(Column...) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueFamilyMethods

ColumnsMethods(Collection<Bytes>) - Constructor for class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ColumnsMethods

combine(Combiner.Input<K, V>) - Method in interface org.apache.fluo.recipes.core.combine.Combiner

This function is called to combine the current value of a key with updates that were queued for the key.

combine(Combiner.Input<K, Long>) - Method in class org.apache.fluo.recipes.core.combine.SummingCombiner

combine(K, Iterator<V>) - Method in interface org.apache.fluo.recipes.core.map.Combiner

Deprecated.

This function is called to combine the current value of a key with updates that were queued for the key.

CombineQueue<K,V> - Interface in org.apache.fluo.recipes.core.combine

See the project level documentation for information about this recipe.

CombineQueue.FluentArg1 - Interface in org.apache.fluo.recipes.core.combine

Part of a fluent API for configuring a combine queue.

CombineQueue.FluentArg2 - Interface in org.apache.fluo.recipes.core.combine

Part of a fluent API for configuring a combine queue.

CombineQueue.FluentArg3 - Interface in org.apache.fluo.recipes.core.combine

Part of a fluent API for configuring a combine queue.

CombineQueue.FluentOptions - Interface in org.apache.fluo.recipes.core.combine

Part of a fluent API for configuring a combine queue.

CombineQueue.Initializer<K2,V2> - Interface in org.apache.fluo.recipes.core.combine

CombineQueue.Optimizer - Class in org.apache.fluo.recipes.core.combine

Combiner<K,V> - Interface in org.apache.fluo.recipes.core.combine

This class was created as an alternative to Combiner.

Combiner<K,V> - Interface in org.apache.fluo.recipes.core.map

Deprecated.

since 1.1.0 use Combiner and CombineQueue

Combiner.Input<KI,VI> - Interface in org.apache.fluo.recipes.core.combine

commit() - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransaction

commit() - Method in class org.apache.fluo.recipes.core.types.TypedTransaction

configure(String) - Static method in interface org.apache.fluo.recipes.core.combine.CombineQueue

Call this method before initializing Fluo to configure a combine queue.

configure(FluoConfiguration, String, int) - Static method in class org.apache.fluo.recipes.core.data.RowHasher

This method can be called to register table optimizations before initializing Fluo.

configure(String) - Static method in class org.apache.fluo.recipes.core.export.ExportQueue

A Fluent API for configuring an Export Queue.

configure(FluoConfiguration, ExportQueue.Options) - Static method in class org.apache.fluo.recipes.core.export.ExportQueue

Deprecated.

since 1.1.0 use ExportQueue.configure(String) and ExportQueue.registerObserver(ObserverProvider.Registry, org.apache.fluo.recipes.core.export.function.Exporter) instead.

configure(FluoConfiguration, CollisionFreeMap.Options) - Static method in class org.apache.fluo.recipes.core.map.CollisionFreeMap

Deprecated.

This method configures a collision free map for use.

convert(K2, V2) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.Initializer

convert(K2, V2) - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMap.Initializer

Deprecated.

D

decodeBoolean(Bytes) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Decodes a boolean from Bytes

decodeBoolean(Bytes) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

decodeDouble(Bytes) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Decodes a double from Bytes

decodeDouble(Bytes) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

decodeFloat(Bytes) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Decodes a float from Bytes

decodeFloat(Bytes) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

decodeInteger(Bytes) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Decodes an integer from Bytes

decodeInteger(Bytes) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

decodeLong(Bytes) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Decodes a long from Bytes

decodeLong(Bytes) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

decodeString(Bytes) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Decodes a String from Bytes

decodeString(Bytes) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

delete(Bytes, Column) - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

delete(Bytes, Column) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase

delete(CharSequence, Column) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase

delete() - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

deserialize(byte[], Class<T>) - Method in interface org.apache.fluo.recipes.core.serialization.SimpleSerializer

E

encode(int) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Encodes an integer to Bytes

encode(long) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Encodes a long to Bytes

encode(String) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Encodes a String to Bytes

encode(float) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Encodes a float to Bytes

encode(double) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Encodes a double to Bytes

encode(boolean) - Method in interface org.apache.fluo.recipes.core.types.Encoder

Encodes a boolean to Bytes

encode(int) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

encode(long) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

encode(String) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

encode(float) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

encode(double) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

encode(boolean) - Method in class org.apache.fluo.recipes.core.types.StringEncoder

Encoder - Interface in org.apache.fluo.recipes.core.types

Transforms Java primitives to and from bytes using desired encoding

equals(Object) - Method in class org.apache.fluo.recipes.core.common.RowRange

equals(Object) - Method in class org.apache.fluo.recipes.core.transaction.LogEntry

equals(Object) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

Export<K,V> - Class in org.apache.fluo.recipes.core.export

Export(K, V) - Constructor for class org.apache.fluo.recipes.core.export.Export

export(Iterator<SequencedExport<K, V>>) - Method in interface org.apache.fluo.recipes.core.export.function.Exporter

Performs this export operation.

Exporter<K,V> - Class in org.apache.fluo.recipes.core.export

Deprecated.

since 1.1.0 replaced by Exporter

Exporter() - Constructor for class org.apache.fluo.recipes.core.export.Exporter

Deprecated.

Exporter<K,V> - Interface in org.apache.fluo.recipes.core.export.function

Must be able to handle same key being exported multiple times and keys being exported out of order.

Exporter.Context - Interface in org.apache.fluo.recipes.core.export

Deprecated.

ExportObserver<K,V> - Class in org.apache.fluo.recipes.core.export

Deprecated.

since 1.1.0

ExportObserver() - Constructor for class org.apache.fluo.recipes.core.export.ExportObserver

Deprecated.

ExportQueue<K,V> - Class in org.apache.fluo.recipes.core.export

ExportQueue.FluentArg1 - Interface in org.apache.fluo.recipes.core.export

Part of a fluent API for configuring a export queue.

ExportQueue.FluentArg2 - Interface in org.apache.fluo.recipes.core.export

Part of a fluent API for configuring a export queue.

ExportQueue.FluentArg3 - Interface in org.apache.fluo.recipes.core.export

Part of a fluent API for configuring a export queue.

ExportQueue.FluentOptions - Interface in org.apache.fluo.recipes.core.export

Part of a fluent API for configuring a export queue.

ExportQueue.Optimizer - Class in org.apache.fluo.recipes.core.export

ExportQueue.Options - Class in org.apache.fluo.recipes.core.export

Deprecated.

since 1.1.0 use ExportQueue.configure(String)

F

fam(String) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.SimpleFamilyMethods

fam(int) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.SimpleFamilyMethods

fam(long) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.SimpleFamilyMethods

fam(byte[]) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.SimpleFamilyMethods

fam(ByteBuffer) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.SimpleFamilyMethods

fam(Bytes) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.SimpleFamilyMethods

filteredAdd(LogEntry, Predicate<LogEntry>) - Method in class org.apache.fluo.recipes.core.transaction.TxLog

Adds LogEntry to TxLog if it passes filter

G

get(SnapshotBase, K) - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMap

Deprecated.

This method will retrieve the current value for key and any outstanding updates and combine them using the configured Combiner.

get(Bytes, Column) - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

Logs GETs for returned Row/Columns.

get(Bytes, Set<Column>) - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

Logs GETs for returned Row/Columns.

get(Collection<Bytes>, Set<Column>) - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

Logs GETs for returned Row/Columns.

get(Collection<RowColumn>) - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

get(Bytes, Column) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

get(Bytes, Set<Column>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

get(Collection<RowColumn>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

get(Collection<Bytes>, Set<Column>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

get() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

getBytes() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

getColumn() - Method in class org.apache.fluo.recipes.core.transaction.LogEntry

getConfiguredOptimizations(FluoConfiguration) - Static method in class org.apache.fluo.recipes.core.common.TableOptimizations

A utility method to get all registered table optimizations.

getEnd() - Method in class org.apache.fluo.recipes.core.common.RowRange

getExporterConfiguration() - Method in interface org.apache.fluo.recipes.core.export.Exporter.Context

Deprecated.

getExporterConfiguration() - Method in class org.apache.fluo.recipes.core.export.ExportQueue.Options

Deprecated.

getInitializer(String, int, SimpleSerializer) - Static method in interface org.apache.fluo.recipes.core.combine.CombineQueue

A CombineQueue stores data in its own data format in the Fluo table.

getInitializer(String, int, SimpleSerializer) - Static method in class org.apache.fluo.recipes.core.map.CollisionFreeMap

Deprecated.

A CollisionFreeMap stores data in its own data format in the Fluo table.

getInstance(String, SimpleConfiguration) - Static method in interface org.apache.fluo.recipes.core.combine.CombineQueue

Get a combiner queue instance.

getInstance(String, SimpleConfiguration) - Static method in class org.apache.fluo.recipes.core.export.ExportQueue

getInstance(String, SimpleConfiguration) - Static method in class org.apache.fluo.recipes.core.map.CollisionFreeMap

Deprecated.

getInstance(SimpleConfiguration) - Static method in interface org.apache.fluo.recipes.core.serialization.SimpleSerializer

getKey() - Method in interface org.apache.fluo.recipes.core.combine.ChangeObserver.Change

getKey() - Method in interface org.apache.fluo.recipes.core.combine.Combiner.Input

getKey() - Method in class org.apache.fluo.recipes.core.export.Export

getKey() - Method in class org.apache.fluo.recipes.core.map.Update

Deprecated.

getLogEntries() - Method in class org.apache.fluo.recipes.core.transaction.TxLog

Returns all LogEntry in TxLog

getNewValue() - Method in interface org.apache.fluo.recipes.core.combine.ChangeObserver.Change

getNewValue() - Method in class org.apache.fluo.recipes.core.map.Update

Deprecated.

getObservedColumn() - Method in class org.apache.fluo.recipes.core.export.ExportObserver

Deprecated.

getObservedColumn() - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMapObserver

Deprecated.

getObserverContext() - Method in interface org.apache.fluo.recipes.core.export.Exporter.Context

Deprecated.

getOldValue() - Method in interface org.apache.fluo.recipes.core.combine.ChangeObserver.Change

getOldValue() - Method in class org.apache.fluo.recipes.core.map.Update

Deprecated.

getOp() - Method in class org.apache.fluo.recipes.core.transaction.LogEntry

getOperationMap(LogEntry.Operation) - Method in class org.apache.fluo.recipes.core.transaction.TxLog

Returns a map of RowColumn changes given an operation

getPrefix() - Method in class org.apache.fluo.recipes.core.data.RowHasher

getQueueId() - Method in interface org.apache.fluo.recipes.core.export.Exporter.Context

Deprecated.

getQueueId() - Method in class org.apache.fluo.recipes.core.export.ExportObserver

Deprecated.

getQueueId() - Method in class org.apache.fluo.recipes.core.export.ExportQueue.Options

Deprecated.

getRow() - Method in class org.apache.fluo.recipes.core.transaction.LogEntry

gets(CharSequence, Column) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

gets(CharSequence, Set<Column>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

gets(Collection<? extends CharSequence>, Set<Column>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

gets(Collection<RowColumn>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

getSequence() - Method in class org.apache.fluo.recipes.core.export.SequencedExport

getSplits() - Method in class org.apache.fluo.recipes.core.common.TableOptimizations

getStart() - Method in class org.apache.fluo.recipes.core.common.RowRange

getStartTimestamp() - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

getStartTimestamp() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

getTableOptimizations(String, SimpleConfiguration) - Method in class org.apache.fluo.recipes.core.combine.CombineQueue.Optimizer

Return suggested Fluo table optimizations for the specified combine queue.

getTableOptimizations(String, SimpleConfiguration) - Method in interface org.apache.fluo.recipes.core.common.TableOptimizations.TableOptimizationsFactory

getTableOptimizations(String, SimpleConfiguration) - Method in class org.apache.fluo.recipes.core.data.RowHasher.Optimizer

getTableOptimizations(String, SimpleConfiguration) - Method in class org.apache.fluo.recipes.core.export.ExportQueue.Optimizer

Return suggested Fluo table optimizations for the specified export queue.

getTableOptimizations(String, SimpleConfiguration) - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMap.Optimizer

Deprecated.

Return suggested Fluo table optimizations for the specified collisiong free map.

getTabletGroupingRegex() - Method in class org.apache.fluo.recipes.core.common.TableOptimizations

getTransientRanges() - Method in class org.apache.fluo.recipes.core.common.TransientRegistry

This method is expected to be called after Fluo is initialized to get the ranges that were registered before initialization.

getTxLog() - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

getValue() - Method in class org.apache.fluo.recipes.core.export.Export

getValue() - Method in class org.apache.fluo.recipes.core.transaction.LogEntry

H

hashCode() - Method in class org.apache.fluo.recipes.core.common.RowRange

hashCode() - Method in class org.apache.fluo.recipes.core.transaction.LogEntry

hashCode() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

I

increment(int) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

Reads the current value of the row/column, adds i, sets the sum.

increment(long) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

Reads the current value of the row/column, adds l, sets the sum.

init(Exporter.Context) - Method in class org.apache.fluo.recipes.core.export.Exporter

Deprecated.

init(Observer.Context) - Method in class org.apache.fluo.recipes.core.export.ExportObserver

Deprecated.

init(Observer.Context) - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMapObserver

Deprecated.

init(String, Observer.Context) - Method in class org.apache.fluo.recipes.core.map.UpdateObserver

Deprecated.

init(SimpleConfiguration) - Method in interface org.apache.fluo.recipes.core.serialization.SimpleSerializer

Called immediately after construction and passed Fluo application configuration.

isEmpty() - Method in class org.apache.fluo.recipes.core.transaction.TxLog

Returns true if TxLog is empty

iterator() - Method in interface org.apache.fluo.recipes.core.combine.Combiner.Input

K

keyType(String) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.FluentArg1

keyType(Class<?>) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.FluentArg1

keyType(String) - Method in interface org.apache.fluo.recipes.core.export.ExportQueue.FluentArg1

keyType(Class<?>) - Method in interface org.apache.fluo.recipes.core.export.ExportQueue.FluentArg1

L

load(TransactionBase, Loader.Context) - Method in class org.apache.fluo.recipes.core.types.TypedLoader

load(TypedTransactionBase, Loader.Context) - Method in class org.apache.fluo.recipes.core.types.TypedLoader

LogEntry - Class in org.apache.fluo.recipes.core.transaction

Logs an operation (i.e GET, SET, or DELETE) in a Transaction.

LogEntry.Operation - Enum in org.apache.fluo.recipes.core.transaction

M

MapConverter(Collection<Bytes>, Set<Column>) - Constructor for class org.apache.fluo.recipes.core.types.TypedSnapshotBase.MapConverter

merge(TableOptimizations) - Method in class org.apache.fluo.recipes.core.common.TableOptimizations

mutate() - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase

N

newDelete(CharSequence, Column) - Static method in class org.apache.fluo.recipes.core.transaction.LogEntry

newDelete(Bytes, Column) - Static method in class org.apache.fluo.recipes.core.transaction.LogEntry

newGet(CharSequence, Column, CharSequence) - Static method in class org.apache.fluo.recipes.core.transaction.LogEntry

newGet(Bytes, Column, Bytes) - Static method in class org.apache.fluo.recipes.core.transaction.LogEntry

newSet(CharSequence, Column, CharSequence) - Static method in class org.apache.fluo.recipes.core.transaction.LogEntry

newSet(Bytes, Column, Bytes) - Static method in class org.apache.fluo.recipes.core.transaction.LogEntry

O

Optimizer() - Constructor for class org.apache.fluo.recipes.core.combine.CombineQueue.Optimizer

Optimizer() - Constructor for class org.apache.fluo.recipes.core.data.RowHasher.Optimizer

Optimizer() - Constructor for class org.apache.fluo.recipes.core.export.ExportQueue.Optimizer

Optimizer() - Constructor for class org.apache.fluo.recipes.core.map.CollisionFreeMap.Optimizer

Deprecated.

Options(String, String, String, String, int) - Constructor for class org.apache.fluo.recipes.core.export.ExportQueue.Options

Deprecated.

Options(String, Class<? extends Exporter<K, V>>, Class<K>, Class<V>, int) - Constructor for class org.apache.fluo.recipes.core.export.ExportQueue.Options

Deprecated.

Options(String, String, String, String, int) - Constructor for class org.apache.fluo.recipes.core.map.CollisionFreeMap.Options

Deprecated.

Options(String, String, String, String, String, int) - Constructor for class org.apache.fluo.recipes.core.map.CollisionFreeMap.Options

Deprecated.

Options(String, Class<? extends Combiner<K, V>>, Class<K>, Class<V>, int) - Constructor for class org.apache.fluo.recipes.core.map.CollisionFreeMap.Options

Deprecated.

Options(String, Class<? extends Combiner<K, V>>, Class<? extends UpdateObserver<K, V>>, Class<K>, Class<V>, int) - Constructor for class org.apache.fluo.recipes.core.map.CollisionFreeMap.Options

Deprecated.

org.apache.fluo.recipes.core.combine - package org.apache.fluo.recipes.core.combine

org.apache.fluo.recipes.core.common - package org.apache.fluo.recipes.core.common

org.apache.fluo.recipes.core.data - package org.apache.fluo.recipes.core.data

org.apache.fluo.recipes.core.export - package org.apache.fluo.recipes.core.export

org.apache.fluo.recipes.core.export.function - package org.apache.fluo.recipes.core.export.function

org.apache.fluo.recipes.core.map - package org.apache.fluo.recipes.core.map

org.apache.fluo.recipes.core.serialization - package org.apache.fluo.recipes.core.serialization

org.apache.fluo.recipes.core.transaction - package org.apache.fluo.recipes.core.transaction

org.apache.fluo.recipes.core.types - package org.apache.fluo.recipes.core.types

P

process(TransactionBase, Iterable<ChangeObserver.Change<K, V>>) - Method in interface org.apache.fluo.recipes.core.combine.ChangeObserver

process(TransactionBase, Bytes, Column) - Method in class org.apache.fluo.recipes.core.export.ExportObserver

Deprecated.

process(TransactionBase, Bytes, Column) - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMapObserver

Deprecated.

process(TransactionBase, Bytes, Column) - Method in class org.apache.fluo.recipes.core.types.TypedObserver

process(TypedTransactionBase, Bytes, Column) - Method in class org.apache.fluo.recipes.core.types.TypedObserver

processExports(Iterator<SequencedExport<K, V>>) - Method in class org.apache.fluo.recipes.core.export.Exporter

Deprecated.

Must be able to handle same key being exported multiple times and key being exported out of order.

Q

qual(String) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.QualifierMethods

qual(int) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.QualifierMethods

qual(long) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.QualifierMethods

qual(byte[]) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.QualifierMethods

qual(ByteBuffer) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.QualifierMethods

qual(Bytes) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.QualifierMethods

R

RecordingTransaction - Class in org.apache.fluo.recipes.core.transaction

An implementation of Transaction that logs all transactions operations (GET, SET, or DELETE) in a TxLog that can be used for exports

RecordingTransactionBase - Class in org.apache.fluo.recipes.core.transaction

An implementation of TransactionBase that logs all transactions operations (GET, SET, or DELETE) in a TxLog that can be used for exports

registerObserver(ObserverProvider.Registry, Combiner<K, V>, ChangeObserver<K, V>) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue

Used to register a Fluo Observer that processes updates to this combine queue.

registerObserver(ObserverProvider.Registry, Exporter<K, V>) - Method in class org.apache.fluo.recipes.core.export.ExportQueue

Registers an observer that will export queued data.

registerOptimization(SimpleConfiguration, String, Class<? extends TableOptimizations.TableOptimizationsFactory>) - Static method in class org.apache.fluo.recipes.core.common.TableOptimizations

This method provides a standard way to register a table optimization for the Fluo table before initialization.

removeHash(Bytes) - Method in class org.apache.fluo.recipes.core.data.RowHasher

row(String) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.RowMethods

row(int) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.RowMethods

row(long) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.RowMethods

row(byte[]) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.RowMethods

row(ByteBuffer) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.RowMethods

row(Bytes) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.RowMethods

RowHasher - Class in org.apache.fluo.recipes.core.data

This recipe provides code to help add a hash of the row as a prefix of the row.

RowHasher(String) - Constructor for class org.apache.fluo.recipes.core.data.RowHasher

RowHasher.Optimizer - Class in org.apache.fluo.recipes.core.data

RowMethods() - Constructor for class org.apache.fluo.recipes.core.types.TypeLayer.RowMethods

RowRange - Class in org.apache.fluo.recipes.core.common

RowRange(Bytes, Bytes) - Constructor for class org.apache.fluo.recipes.core.common.RowRange

rows(Collection<Bytes>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rows(Bytes...) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsByteBuffers(ByteBuffer...) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsByteBuffers(Collection<ByteBuffer>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsBytes(byte[]...) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsBytes(Collection<byte[]>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsInteger(Integer...) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsInteger(Collection<Integer>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsLong(Long...) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsLong(Collection<Long>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsString(String...) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

rowsString(Collection<String>) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.ValueRowMethods

S

save(FluoConfiguration) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.FluentOptions

Adds properties to the Fluo application configuration for this CombineQueue.

save(FluoConfiguration) - Method in interface org.apache.fluo.recipes.core.export.ExportQueue.FluentOptions

Adds properties to the Fluo application configuration for this CombineQueue.

scanner() - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

Logs GETs for Row/Columns returned by iterators.

scanner() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase

SequencedExport<K,V> - Class in org.apache.fluo.recipes.core.export

serialize(T) - Method in interface org.apache.fluo.recipes.core.serialization.SimpleSerializer

set(Bytes, Column, Bytes) - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

set(Bytes) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set(String) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set(int) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set(long) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set(float) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set(double) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set(boolean) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set(byte[]) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set(ByteBuffer) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

set() - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

Set an empty value

set(Bytes, Column, Bytes) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase

set(CharSequence, Column, CharSequence) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase

setBucketsPerTablet(int) - Method in class org.apache.fluo.recipes.core.export.ExportQueue.Options

Deprecated.

Sets the number of buckets per tablet to generate.

setBucketsPerTablet(int) - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMap.Options

Deprecated.

Sets the number of buckets per tablet to generate.

setBufferSize(long) - Method in class org.apache.fluo.recipes.core.export.ExportQueue.Options

Deprecated.

Sets a limit on the amount of serialized updates to read into memory.

setBufferSize(long) - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMap.Options

Deprecated.

Sets a limit on the amount of serialized updates to read into memory.

setExporterConfiguration(SimpleConfiguration) - Method in class org.apache.fluo.recipes.core.export.ExportQueue.Options

Deprecated.

setSerializer(FluoConfiguration, Class<? extends SimpleSerializer>) - Static method in interface org.apache.fluo.recipes.core.serialization.SimpleSerializer

setSerializer(FluoConfiguration, String) - Static method in interface org.apache.fluo.recipes.core.serialization.SimpleSerializer

setSplits(List<Bytes>) - Method in class org.apache.fluo.recipes.core.common.TableOptimizations

setTabletGroupingRegex(String) - Method in class org.apache.fluo.recipes.core.common.TableOptimizations

setWeakNotification(Bytes, Column) - Method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

setWeakNotification(Bytes, Column) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase

setWeakNotification(CharSequence, Column) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase

SimpleSerializer - Interface in org.apache.fluo.recipes.core.serialization

stream() - Method in interface org.apache.fluo.recipes.core.combine.Combiner.Input

StringEncoder - Class in org.apache.fluo.recipes.core.types

Transforms Java primitives to and from bytes using a String encoding

StringEncoder() - Constructor for class org.apache.fluo.recipes.core.types.StringEncoder

SummingCombiner<K> - Class in org.apache.fluo.recipes.core.combine

Sums long values and returns Optional.empty() when the sum is zero.

SummingCombiner() - Constructor for class org.apache.fluo.recipes.core.combine.SummingCombiner

T

TableOptimizations - Class in org.apache.fluo.recipes.core.common

Post initialization recommended table optimizations.

TableOptimizations() - Constructor for class org.apache.fluo.recipes.core.common.TableOptimizations

TableOptimizations.TableOptimizationsFactory - Interface in org.apache.fluo.recipes.core.common

toBoolean() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toBoolean(boolean) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toByteBuffer() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toByteBuffer(ByteBuffer) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toBytes() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toBytes(byte[]) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toBytesMap() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.MapConverter

toDouble() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toDouble(double) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toFloat() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toFloat(float) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toInteger() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toInteger(int) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toIntegerMap() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.MapConverter

toLong() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toLong(long) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toLongMap() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.MapConverter

toString() - Method in class org.apache.fluo.recipes.core.common.RowRange

toString() - Method in class org.apache.fluo.recipes.core.transaction.LogEntry

toString() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toString(String) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.Value

toStringMap() - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.MapConverter

TransientRegistry - Class in org.apache.fluo.recipes.core.common

This class offers a standard way to register transient ranges.

TransientRegistry(SimpleConfiguration) - Constructor for class org.apache.fluo.recipes.core.common.TransientRegistry

TxLog - Class in org.apache.fluo.recipes.core.transaction

Contains list of operations (GET, SET, DELETE) performed during a RecordingTransaction

TxLog() - Constructor for class org.apache.fluo.recipes.core.transaction.TxLog

TypedLoader - Class in org.apache.fluo.recipes.core.types

A Loader that uses a TypeLayer

TypedLoader() - Constructor for class org.apache.fluo.recipes.core.types.TypedLoader

TypedLoader(TypeLayer) - Constructor for class org.apache.fluo.recipes.core.types.TypedLoader

TypedObserver - Class in org.apache.fluo.recipes.core.types

An Observer that uses a TypeLayer

TypedObserver() - Constructor for class org.apache.fluo.recipes.core.types.TypedObserver

TypedObserver(TypeLayer) - Constructor for class org.apache.fluo.recipes.core.types.TypedObserver

TypedSnapshot - Class in org.apache.fluo.recipes.core.types

A Snapshot that uses a TypeLayer

TypedSnapshotBase - Class in org.apache.fluo.recipes.core.types

A SnapshotBase that uses a TypeLayer

TypedSnapshotBase.ColumnsMethods - Class in org.apache.fluo.recipes.core.types

TypedSnapshotBase.MapConverter - Class in org.apache.fluo.recipes.core.types

TypedSnapshotBase.Value - Class in org.apache.fluo.recipes.core.types

TypedSnapshotBase.ValueFamilyMethods - Class in org.apache.fluo.recipes.core.types

TypedSnapshotBase.ValueQualifierBuilder - Class in org.apache.fluo.recipes.core.types

TypedSnapshotBase.ValueRowMethods - Class in org.apache.fluo.recipes.core.types

TypedSnapshotBase.VisibilityMethods - Class in org.apache.fluo.recipes.core.types

TypedTransaction - Class in org.apache.fluo.recipes.core.types

A Transaction that uses a TypeLayer

TypedTransaction(Transaction, Encoder, TypeLayer) - Constructor for class org.apache.fluo.recipes.core.types.TypedTransaction

TypedTransactionBase - Class in org.apache.fluo.recipes.core.types

A TransactionBase that uses a TypeLayer

TypedTransactionBase(TransactionBase, Encoder, TypeLayer) - Constructor for class org.apache.fluo.recipes.core.types.TypedTransactionBase

TypedTransactionBase.Mutator - Class in org.apache.fluo.recipes.core.types

TypedTransactionBase.MutatorFamilyMethods - Class in org.apache.fluo.recipes.core.types

TypedTransactionBase.MutatorQualifierMethods - Class in org.apache.fluo.recipes.core.types

TypedTransactionBase.MutatorRowMethods - Class in org.apache.fluo.recipes.core.types

TypedTransactionBase.VisibilityMutator - Class in org.apache.fluo.recipes.core.types

TypeLayer - Class in org.apache.fluo.recipes.core.types

A simple convenience layer for Fluo.

TypeLayer(Encoder) - Constructor for class org.apache.fluo.recipes.core.types.TypeLayer

TypeLayer.CFB - Class in org.apache.fluo.recipes.core.types

TypeLayer.CQB - Class in org.apache.fluo.recipes.core.types

TypeLayer.FamilyMethods<R1,R2> - Class in org.apache.fluo.recipes.core.types

TypeLayer.QualifierMethods<R> - Class in org.apache.fluo.recipes.core.types

TypeLayer.RowMethods<R> - Class in org.apache.fluo.recipes.core.types

TypeLayer.SimpleFamilyMethods<R1> - Class in org.apache.fluo.recipes.core.types

TypeLayer.VisibilityMethods - Class in org.apache.fluo.recipes.core.types

U

update(TransactionBase, Map<K, V>) - Method in class org.apache.fluo.recipes.core.map.CollisionFreeMap

Deprecated.

Queues updates for a collision free map.

Update<K,V> - Class in org.apache.fluo.recipes.core.map

Deprecated.

since 1.1.0

UpdateObserver<K,V> - Class in org.apache.fluo.recipes.core.map

Deprecated.

since 1.1.0 use ChangeObserver and CombineQueue

UpdateObserver() - Constructor for class org.apache.fluo.recipes.core.map.UpdateObserver

Deprecated.

updatingValues(TransactionBase, Iterator<Update<K, V>>) - Method in class org.apache.fluo.recipes.core.map.UpdateObserver

Deprecated.

V

valueOf(String) - Static method in enum org.apache.fluo.recipes.core.transaction.LogEntry.Operation

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

values() - Static method in enum org.apache.fluo.recipes.core.transaction.LogEntry.Operation

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

valueType(String) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.FluentArg2

valueType(Class<?>) - Method in interface org.apache.fluo.recipes.core.combine.CombineQueue.FluentArg2

valueType(String) - Method in interface org.apache.fluo.recipes.core.export.ExportQueue.FluentArg2

valueType(Class<?>) - Method in interface org.apache.fluo.recipes.core.export.ExportQueue.FluentArg2

vis(Bytes) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.VisibilityMethods

vis(byte[]) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.VisibilityMethods

vis(ByteBuffer) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.VisibilityMethods

vis(String) - Method in class org.apache.fluo.recipes.core.types.TypedSnapshotBase.VisibilityMethods

vis(String) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.VisibilityMutator

vis(Bytes) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.VisibilityMutator

vis(byte[]) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.VisibilityMutator

vis(ByteBuffer) - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.VisibilityMutator

vis() - Method in class org.apache.fluo.recipes.core.types.TypeLayer.VisibilityMethods

vis(String) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.VisibilityMethods

vis(Bytes) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.VisibilityMethods

vis(ByteBuffer) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.VisibilityMethods

vis(byte[]) - Method in class org.apache.fluo.recipes.core.types.TypeLayer.VisibilityMethods

W

weaklyNotify() - Method in class org.apache.fluo.recipes.core.types.TypedTransactionBase.Mutator

wrap(Transaction) - Static method in class org.apache.fluo.recipes.core.transaction.RecordingTransaction

Creates a RecordingTransaction by wrapping an existing Transaction

wrap(Transaction, Predicate<LogEntry>) - Static method in class org.apache.fluo.recipes.core.transaction.RecordingTransaction

Creates a RecordingTransaction using the provided LogEntry filter and existing Transaction

wrap(TransactionBase) - Static method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

Creates a RecordingTransactionBase by wrapping an existing TransactionBase

wrap(TransactionBase, Predicate<LogEntry>) - Static method in class org.apache.fluo.recipes.core.transaction.RecordingTransactionBase

Creates a RecordingTransactionBase using the provided LogEntry filter function and existing TransactionBase

wrap(Snapshot) - Method in class org.apache.fluo.recipes.core.types.TypeLayer

wrap(TransactionBase) - Method in class org.apache.fluo.recipes.core.types.TypeLayer

wrap(Transaction) - Method in class org.apache.fluo.recipes.core.types.TypeLayer

A B C D E F G H I K L M N O P Q R S T U V W