Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   *
   * Licensed to the Apache Software Foundation (ASF) under one
   * or more contributor license agreements.  See the NOTICE file
   * distributed with this work for additional information
   * regarding copyright ownership.  The ASF licenses this file
   * to you under the Apache License, Version 2.0 (the
   * "License"); you may not use this file except in compliance
   * with the License.  You may obtain a copy of the License at
  *
  *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package org.apache.hadoop.hbase.replication.regionserver;
 
 import java.util.UUID;
 
Interface that defines a replication source
 
 public interface ReplicationSourceInterface {

  
Initializer for the source

Parameters:
conf the configuration to use
fs the file system to use
manager the manager to use
replicationQueues
replicationPeers
stopper the stopper object for this region server
peerClusterZnode
clusterId
Throws:
java.io.IOException
 
   public void init(final Configuration conffinal FileSystem fs,
       final ReplicationSourceManager managerfinal ReplicationQueues replicationQueues,
       final ReplicationPeers replicationPeersfinal Stoppable stopper,
       final String peerClusterZnodefinal UUID clusterIdReplicationEndpoint replicationEndpoint,
       final MetricsSource metricsthrows IOException;

  
Add a log to the list of logs to replicate

Parameters:
log path to the log to replicate
 
   void enqueueLog(Path log);

  
Get the current log that's replicated

Returns:
the current log
 
   Path getCurrentPath();

  
Start the replication
 
   void startup();

  
End the replication

Parameters:
reason why it's terminating
 
   void terminate(String reason);

  
End the replication

Parameters:
reason why it's terminating
cause the error that's causing it
 
   void terminate(String reasonException cause);

  
Get the id that the source is replicating to

Returns:
peer cluster id
 
Get the id that the source is replicating to.

Returns:
peer cluster id
 
Get a string representation of the current statistics for this source

Returns:
printable stats
New to GrepCode? Check out our FAQ X