org.apache.ignite.internal.processors.platform.datastreamer

Class PlatformDataStreamer

java.lang.Object

org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

org.apache.ignite.internal.processors.platform.datastreamer.PlatformDataStreamer

All Implemented Interfaces:

PlatformTarget

public class PlatformDataStreamer
extends PlatformAbstractTarget

Interop data streamer wrapper.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

FALSE, log, platformCtx, TRUE

Constructor Summary

Constructors

Constructor and Description
PlatformDataStreamer(PlatformContext platformCtx, String cacheName, DataStreamerImpl ldr, boolean keepBinary) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	allowOverwrite()
void	allowOverwrite(boolean val)
void	listenTopology(long ptr) Listen topology changes.
int	perNodeBufferSize()
void	perNodeBufferSize(int val)
int	perNodeParallelOperations()
void	perNodeParallelOperations(int val)
protected long	processInStreamOutLong(int type, BinaryRawReaderEx reader) Process IN operation.
boolean	skipStore()
void	skipStore(boolean skipStore)

Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

convertException, currentFuture, futureWriter, inObjectStreamOutStream, inStreamOutLong, inStreamOutObject, inStreamOutStream, listenFuture, listenFutureAndGet, listenFutureForOperation, listenFutureForOperationAndGet, outLong, outObject, outStream, platformContext, processInObjectStreamOutStream, processInStreamOutObject, processInStreamOutStream, processOutLong, processOutObject, processOutStream, throwUnsupported

Methods inherited from class java.lang.Object

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

Constructor Detail

PlatformDataStreamer

public PlatformDataStreamer(PlatformContext platformCtx,
                    String cacheName,
                    DataStreamerImpl ldr,
                    boolean keepBinary)

Constructor.

Parameters:

platformCtx - Context.

ldr - Data streamer.

Method Detail

processInStreamOutLong

protected long processInStreamOutLong(int type,
                          BinaryRawReaderEx reader)
                               throws IgniteCheckedException

Process IN operation.

Overrides:

processInStreamOutLong in class PlatformAbstractTarget

Parameters:

type - Type.

reader - Binary reader.

Returns:

Result.

Throws:

IgniteCheckedException - In case of exception.

listenTopology

public void listenTopology(long ptr)

Listen topology changes.

Parameters:

ptr - Pointer.

allowOverwrite

public boolean allowOverwrite()

Returns:

Allow-overwrite flag.

allowOverwrite

public void allowOverwrite(boolean val)

Parameters:

val - Allow-overwrite flag.

skipStore

public boolean skipStore()

Returns:

Skip store flag.

skipStore

public void skipStore(boolean skipStore)

Parameters:

skipStore - Skip store flag.

perNodeBufferSize

public int perNodeBufferSize()

Returns:

Per-node buffer size.

perNodeBufferSize

public void perNodeBufferSize(int val)

Parameters:

val - Per-node buffer size.

perNodeParallelOperations

public int perNodeParallelOperations()

Returns:

Per-node parallel load operations.

perNodeParallelOperations

public void perNodeParallelOperations(int val)

Parameters:

val - Per-node parallel load operations.