com.bigdata.service

Class AbstractDistributedFederation<T>

java.lang.Object

com.bigdata.service.AbstractFederation<T>

com.bigdata.service.AbstractScaleOutFederation<T>

com.bigdata.service.AbstractDistributedFederation<T>

Type Parameters:

T - The generic type of the client or service.

All Implemented Interfaces:

ICounterSetAccess, IGISTManager, IIndexManager, IIndexStore, IBigdataFederation<T>, IFederationDelegate<T>

public abstract class AbstractDistributedFederation<T>
extends AbstractScaleOutFederation<T>

Abstract base class for IBigdataFederation implementations where the services are distributed using RMI and are running, at least in principle, across more than one host/JVM.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.service.AbstractScaleOutFederation

AbstractScaleOutFederation.ForceOverflowTask, AbstractScaleOutFederation.PurgeResourcesTask

Nested classes/interfaces inherited from class com.bigdata.service.AbstractFederation

AbstractFederation.ReportTask, AbstractFederation.StartDeferredTasksTask

Field Summary

Fields inherited from class com.bigdata.service.AbstractScaleOutFederation

metadataIndexCachePolicy

Fields inherited from class com.bigdata.service.AbstractFederation

log

Constructor Summary

Constructors

Constructor and Description
AbstractDistributedFederation(IBigdataClient<T> client)

Method Summary

Methods

Modifier and Type	Method and Description
abstract <E> E	getProxy(E obj, boolean enableDGC) Return a proxy for an object.
abstract <E> Future<E>	getProxy(Future<E> future) Return a proxy object for a Future suitable for use in an RMI environment.
abstract <E> IAsynchronousIterator<E>	getProxy(IAsynchronousIterator<E> src, IStreamSerializer<E> serializer, int capacity) Return a proxy object for an IAsynchronousIterator suiteable for use in an RMI environment.
abstract <E> IBuffer<E>	getProxy(IBuffer<E> buffer) Return a proxy object for an IBuffer suitable for use in an RMI environment.
boolean	isDistributed() Return true iff the federation is distributed (uses RMI and is running, at least in principle, across more than one host/JVM).
boolean	isJiniFederation() Convenience method to remove linkage for bigdata-jini BLZG-1370
boolean	isStable() Assumes that the federation is stable through failover services if nothing else.

Methods inherited from class com.bigdata.service.AbstractScaleOutFederation

awaitServices, forceOverflow, getIndex, getIndexCache, getMetadataIndex, getMetadataIndexCache, isScaleOut, locatorScan, shutdown, shutdownNow

Methods inherited from class com.bigdata.service.AbstractFederation

addScheduledTask, assertOpen, destroy, didStart, dropIndex, getClient, getCollectPlatformStatistics, getCollectQueueStatistics, getCounters, getDataServices, getExecutorService, getGangliaService, getGlobalFileSystem, getGlobalRowStore, getGlobalRowStore, getHostCounterSet, getHttpdPort, getHttpdURL, getIndexCounters, getResourceLocator, getScheduledExecutorService, getService, getServiceCounterPathPrefix, getServiceCounterPathPrefix, getServiceCounterSet, getServiceIface, getServiceName, getServiceUUID, getTaskCounters, getTempStore, indexNameScan, isGroupCommit, isOpen, isServiceReady, newHttpd, reattachDynamicCounters, registerIndex, registerIndex, registerIndex, reportCounters, sendEvent, serviceJoin, serviceLeave

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.bigdata.service.IBigdataFederation

getAnyDataService, getDataService, getDataServiceByName, getDataServiceUUIDs, getLastCommitTime, getLoadBalancerService, getMetadataService, getTransactionService

Methods inherited from interface com.bigdata.journal.IIndexStore

getResourceLockService

Constructor Detail

AbstractDistributedFederation

public AbstractDistributedFederation(IBigdataClient<T> client)

Method Detail

isDistributed

public final boolean isDistributed()

Description copied from interface: IBigdataFederation

Return true iff the federation is distributed (uses RMI and is running, at least in principle, across more than one host/JVM).

isJiniFederation

public boolean isJiniFederation()

Convenience method to remove linkage for bigdata-jini BLZG-1370

Returns:

isStable

public boolean isStable()

Assumes that the federation is stable through failover services if nothing else.

getProxy

public abstract <E> IAsynchronousIterator<E> getProxy(IAsynchronousIterator<E> src,
                                    IStreamSerializer<E> serializer,
                                    int capacity)

Return a proxy object for an IAsynchronousIterator suiteable for use in an RMI environment.

Parameters:

src - The source iterator. Note that the iterator normally visits elements of some array type (chunks).

serializer - The object responsible for (de-)serializing a chunk of elements visited by the iterator.

capacity - The capacity for the internal buffer that is used to asynchronously transfer elements (chunks) from the remote iterator to the client iterator.

Returns:

Either a thick iterator (when the results would fit within a single chunk) or a thin iterator that uses RMI to fetch chunks from the remote IAsynchronousIterator.

Throws:

IllegalArgumentException - if the iterator is null.

getProxy

public abstract <E> Future<E> getProxy(Future<E> future)

Return a proxy object for a Future suitable for use in an RMI environment.

Parameters:

future - The future.

Returns:

The proxy for that future.

getProxy

public abstract <E> IBuffer<E> getProxy(IBuffer<E> buffer)

Return a proxy object for an IBuffer suitable for use in an RMI environment.

Parameters:

buffer - The future.

Returns:

A proxy for that IBuffer that masquerades any RMI exceptions.

getProxy

public abstract <E> E getProxy(E obj,
             boolean enableDGC)

Return a proxy for an object.

Parameters:

obj - The object.

enableDGC - If distributed garbage collection should be used for the object.

Returns:

The proxy.