Package org.apache.ignite.internal.processors.query.schema

Class SchemaOperationManager

java.lang.Object

org.apache.ignite.internal.processors.query.schema.SchemaOperationManager

public class SchemaOperationManager
extends Object

Schema operation manager.

Constructor Summary

Constructors

Constructor	Description
SchemaOperationManager(GridKernalContext ctx, GridQueryProcessor qryProc, SchemaOperationWorker worker, @Nullable ClusterNode crd)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	onNodeFinished(UUID nodeId, @Nullable SchemaOperationException err, boolean nop)	Handle node finish.
void	onNodeLeave(UUID nodeId, ClusterNode curCrd)	Handle node leave event.
void	start()	Map operation handling.
SchemaOperationWorker	worker()

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaOperationManager

public SchemaOperationManager(GridKernalContext ctx,
                              GridQueryProcessor qryProc,
                              SchemaOperationWorker worker,
                              @Nullable
                              @Nullable ClusterNode crd)

Constructor.

Parameters:

ctx - Context.

qryProc - Query processor.

worker - Operation handler.

crd - Coordinator node.

Method Detail

start

public void start()

Map operation handling.

onNodeFinished

public void onNodeFinished(UUID nodeId,
                           @Nullable
                           @Nullable SchemaOperationException err,
                           boolean nop)

Handle node finish.

Parameters:

nodeId - Node ID.

err - Error.

onNodeLeave

public void onNodeLeave(UUID nodeId,
                        ClusterNode curCrd)

Handle node leave event.

Parameters:

nodeId - ID of the node that has left the grid.

curCrd - Current coordinator node.

worker

public SchemaOperationWorker worker()

Returns:

Worker.