本文整理汇总了Java中org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment类的典型用法代码示例。如果您正苦于以下问题:Java WALCoprocessorEnvironment类的具体用法?Java WALCoprocessorEnvironment怎么用?Java WALCoprocessorEnvironment使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
WALCoprocessorEnvironment类属于org.apache.hadoop.hbase.coprocessor包,在下文中一共展示了WALCoprocessorEnvironment类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: postWALWrite
import org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment; //导入依赖的package包/类
@Override
public void postWALWrite(ObserverContext<? extends WALCoprocessorEnvironment> ctx,
HRegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException {
// only keep primary region's edits
if (logKey.getTablename().equals(tableName) && info.getReplicaId() == 0) {
entries.add(new Entry(logKey, logEdit));
}
}
开发者ID:fengchen8086,项目名称:ditb,代码行数:9,代码来源:TestRegionReplicaReplicationEndpointNoMaster.java
示例2: preWALWrite
import org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment; //导入依赖的package包/类
@Override
public boolean preWALWrite(ObserverContext<WALCoprocessorEnvironment> ctx, HRegionInfo info,
HLogKey logKey, WALEdit logEdit) throws IOException {
TableName tableName = info.getTable();
if (IndexUtils.isCatalogOrSystemTable(tableName) || IndexUtils.isIndexTable(tableName)) {
return true;
}
List<IndexSpecification> indices = indexManager.getIndicesForTable(tableName.getNameAsString());
if (indices != null && !indices.isEmpty()) {
LOG.trace("Entering preWALWrite for the table " + tableName);
String indexTableName = IndexUtils.getIndexTableName(tableName);
IndexEdits iEdits = IndexRegionObserver.threadLocal.get();
WALEdit indexWALEdit = iEdits.getWALEdit();
// This size will be 0 when none of the Mutations to the user table to be indexed.
// or write to WAL is disabled for the Mutations
if (indexWALEdit.getKeyValues().size() == 0) {
return true;
}
LOG.trace("Adding indexWALEdits into WAL for table " + tableName);
HRegion indexRegion = iEdits.getRegion();
// TS in all KVs within WALEdit will be the same. So considering the 1st one.
Long time = indexWALEdit.getKeyValues().get(0).getTimestamp();
indexRegion.getLog().appendNoSync(indexRegion.getRegionInfo(),
TableName.valueOf(indexTableName), indexWALEdit, logKey.getClusterIds(), time,
indexRegion.getTableDesc(), indexRegion.getSequenceId(), true, HConstants.NO_NONCE,
HConstants.NO_NONCE);
LOG.trace("Exiting preWALWrite for the table " + tableName);
}
return true;
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:31,代码来源:IndexWALObserver.java
示例3: postWALWrite
import org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment; //导入依赖的package包/类
@Override
public void postWALWrite(ObserverContext<? extends WALCoprocessorEnvironment> ctx,
RegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException {
// only keep primary region's edits
if (logKey.getTableName().equals(tableName) && info.getReplicaId() == 0) {
// Presume type is a WALKeyImpl
entries.add(new Entry((WALKeyImpl)logKey, logEdit));
}
}
开发者ID:apache,项目名称:hbase,代码行数:10,代码来源:TestRegionReplicaReplicationEndpointNoMaster.java
示例4: preWALWrite
import org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment; //导入依赖的package包/类
@Override
public boolean preWALWrite(ObserverContext<WALCoprocessorEnvironment> ctx, HRegionInfo info,
HLogKey logKey, WALEdit logEdit) throws IOException {
String r = info.getRegionNameAsString();
LOG.info("preWALWrite triggered for " + r + ". counters: " + counters);
return false;
}
开发者ID:ndimiduk,项目名称:hbase-wal-observer-example,代码行数:8,代码来源:WalCounter.java
示例5: postWALWrite
import org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment; //导入依赖的package包/类
@Override
public void postWALWrite(ObserverContext<WALCoprocessorEnvironment> ctx, HRegionInfo info,
HLogKey logKey, WALEdit logEdit) throws IOException {
String r = info.getRegionNameAsString();
counters.addAndGet(r, 1);
LOG.info("postWALWrite triggered for " + r + ". counters: " + counters);
}
开发者ID:ndimiduk,项目名称:hbase-wal-observer-example,代码行数:8,代码来源:WalCounter.java
示例6: preWALWrite
import org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment; //导入依赖的package包/类
@Override
public boolean preWALWrite(ObserverContext<WALCoprocessorEnvironment> ctx, HRegionInfo info,
HLogKey logKey, WALEdit logEdit) throws IOException {
String tableNameStr = info.getTableNameAsString();
if (IndexUtils.isCatalogTable(info.getTableName()) || IndexUtils.isIndexTable(tableNameStr)) {
return true;
}
List<IndexSpecification> indices = indexManager.getIndicesForTable(tableNameStr);
if (indices != null && !indices.isEmpty()) {
LOG.trace("Entering preWALWrite for the table " + tableNameStr);
String indexTableName = IndexUtils.getIndexTableName(tableNameStr);
IndexEdits iEdits = IndexRegionObserver.threadLocal.get();
WALEdit indexWALEdit = iEdits.getWALEdit();
// This size will be 0 when none of the Mutations to the user table to be indexed.
// or write to WAL is disabled for the Mutations
if (indexWALEdit.getKeyValues().size() == 0) {
return true;
}
LOG.trace("Adding indexWALEdits into WAL for table " + tableNameStr);
HRegion indexRegion = iEdits.getRegion();
// TS in all KVs within WALEdit will be the same. So considering the 1st one.
Long time = indexWALEdit.getKeyValues().get(0).getTimestamp();
ctx.getEnvironment()
.getWAL()
.appendNoSync(indexRegion.getRegionInfo(), Bytes.toBytes(indexTableName), indexWALEdit,
logKey.getClusterId(), time, indexRegion.getTableDesc());
LOG.trace("Exiting preWALWrite for the table " + tableNameStr);
}
return true;
}
开发者ID:Huawei-Hadoop,项目名称:hindex,代码行数:31,代码来源:IndexWALObserver.java
示例7: postWALWrite
import org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment; //导入依赖的package包/类
@Override
public void postWALWrite(ObserverContext<WALCoprocessorEnvironment> ctx, HRegionInfo info,
HLogKey logKey, WALEdit logEdit) throws IOException {
}
开发者ID:tenggyut,项目名称:HIndex,代码行数:5,代码来源:IndexWALObserver.java
注:本文中的org.apache.hadoop.hbase.coprocessor.WALCoprocessorEnvironment类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论