Java BatchDeleter类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.accumulo.core.client.BatchDeleter类的典型用法代码示例。如果您正苦于以下问题：Java BatchDeleter类的具体用法？Java BatchDeleter怎么用？Java BatchDeleter使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

BatchDeleter类属于org.apache.accumulo.core.client包，在下文中一共展示了BatchDeleter类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: removeElementFromIndex

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
/**
 * Remove the given element's properties from the index.
 * @param element
 */
public void removeElementFromIndex(Element element) {
  BatchDeleter deleter = null;

  try {
    deleter = getDeleter();
    deleter.setRanges(Collections.singleton(new Range()));

    IteratorSetting is = new IteratorSetting(10, "getEdgeFilter", RegExFilter.class);
    RegExFilter.setRegexs(is, null, null,
        "^"+Pattern.quote(element.getId().toString())+"$", null, false);
    deleter.addScanIterator(is);
    deleter.delete();
    deleter.close();
  } catch (Exception e) {
    throw new AccumuloGraphException(e);
  } finally {
    if (deleter != null) {
      deleter.close();
    }
  }
}

开发者ID:JHUAPL，项目名称:AccumuloGraph，代码行数:26，代码来源:BaseIndexValuesTableWrapper.java

示例2: deleteVertex

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
/**
 * Remove the given vertex.
 * Note: This uses a BatchDeleter rather than {@link Mutator}
 * because it is more efficient.
 * @param vertex
 */
public void deleteVertex(Vertex vertex) {
  BatchDeleter deleter = null;

  try {
    deleter = getDeleter();
    deleter.setRanges(Arrays.asList(Range.exact((String) vertex.getId())));
    deleter.delete();

  } catch (Exception e) {
    throw new AccumuloGraphException(e);
  } finally {
    if (deleter != null) {
      deleter.close();
    }
  }
}

开发者ID:JHUAPL，项目名称:AccumuloGraph，代码行数:23，代码来源:VertexTableWrapper.java

示例3: createBatchDeleter

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
public BatchDeleter createBatchDeleter(
		final String tableName,
		final String... additionalAuthorizations )
		throws TableNotFoundException {
	return connector.createBatchDeleter(
			getQualifiedTableName(tableName),
			new Authorizations(
					getAuthorizations(additionalAuthorizations)),
			numThreads,
			new BatchWriterConfig().setMaxWriteThreads(
					numThreads).setMaxMemory(
					byteBufferSize).setTimeout(
					timeoutMillis,
					TimeUnit.MILLISECONDS));
}

开发者ID:locationtech，项目名称:geowave，代码行数:17，代码来源:BasicAccumuloOperations.java

示例4: addToBatch

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
protected void addToBatch(
		final Closeable deleter,
		final List<ByteArrayId> ids )
		throws Exception {
	final List<Range> rowRanges = new ArrayList<Range>();
	for (final ByteArrayId id : ids) {
		rowRanges.add(Range.exact(new Text(
				id.getBytes())));
	}
	if (deleter instanceof ClosableBatchDeleter) {
		final BatchDeleter batchDeleter = ((ClosableBatchDeleter) deleter).getDeleter();
		batchDeleter.setRanges(rowRanges);
		batchDeleter.delete();
	}
	else {
		LOGGER.error("Deleter incompatible with data store type");
	}
}

开发者ID:locationtech，项目名称:geowave，代码行数:20，代码来源:AccumuloDataStore.java

示例5: clearTable

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
public static void clearTable(Connector connector, String table) throws AccumuloException, TableNotFoundException, AccumuloSecurityException {

        Authorizations userAuths = connector.securityOperations().getUserAuthorizations(connector.whoami());

        BatchDeleter batchDelete = connector.createBatchDeleter(table, userAuths, 1, new BatchWriterConfig());
        batchDelete.setRanges(Collections.singleton(new Range()));
        batchDelete.delete();
        batchDelete.close();

        batchDelete = connector.createBatchDeleter(table, userAuths, 1, new BatchWriterConfig());
        batchDelete.setRanges(Collections.singleton(new Range()));
        batchDelete.delete();
        batchDelete.close();

        connector.tableOperations().compact(table, new Text("\u0000"), new Text("\uffff"), true, true);
    }

开发者ID:calrissian，项目名称:accumulo-recipes，代码行数:17，代码来源:AccumuloTestUtils.java

示例6: purge

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
private void purge(final String tableName, final String[] auths) throws TableNotFoundException, MutationsRejectedException {
    if (tableExists(tableName)) {
        logger.info("Purging accumulo table: " + tableName);
        final BatchDeleter batchDeleter = createBatchDeleter(tableName, new Authorizations(auths));
        try {
            batchDeleter.setRanges(Collections.singleton(new Range()));
            batchDeleter.delete();
        } finally {
            batchDeleter.close();
        }
    }
}

开发者ID:apache，项目名称:incubator-rya，代码行数:13，代码来源:AccumuloRyaDAO.java

示例7: createBatchDeleter

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
@Deprecated
public BatchDeleter createBatchDeleter(String tableName, Authorizations authorizations, int numQueryThreads, long maxMemory, long maxLatency,
    int maxWriteThreads) throws TableNotFoundException {
  return createBatchDeleter(tableName, authorizations, numQueryThreads, new BatchWriterConfig().setMaxLatency(maxLatency, TimeUnit.MILLISECONDS)
      .setMaxMemory(maxMemory).setMaxWriteThreads(maxWriteThreads));
}

开发者ID:JHUAPL，项目名称:accumulo-proxy-instance，代码行数:8，代码来源:ProxyConnector.java

示例8: dropKeyIndex

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
public <T extends Element> void dropKeyIndex(String key, Class<T> elementClass) {
  // TODO Move below to somewhere appropriate.
  if (elementClass == null) {
    throw ExceptionFactory.classForElementCannotBeNull();
  }

  globals.getIndexMetadataWrapper().clearKeyMetadataEntry(key, elementClass);

  String table = null;
  if (elementClass.equals(Vertex.class)) {
    table = globals.getConfig().getVertexKeyIndexTableName();
  } else {
    table = globals.getConfig().getEdgeKeyIndexTableName();
  }
  BatchDeleter bd = null;
  try {
    bd = globals.getConfig().getConnector().createBatchDeleter(table, globals.getConfig().getAuthorizations(), globals.getConfig().getMaxWriteThreads(), globals.getConfig().getBatchWriterConfig());
    bd.setRanges(Collections.singleton(new Range()));
    bd.fetchColumnFamily(new Text(key));
    bd.delete();
  } catch (Exception e) {
    throw new AccumuloGraphException(e);
  } finally {
    if (bd != null)
      bd.close();
  }
  globals.checkedFlush();
}

开发者ID:JHUAPL，项目名称:AccumuloGraph，代码行数:30，代码来源:AccumuloGraph.java

示例9: deleteElementRanges

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
public static void deleteElementRanges(BatchDeleter deleter, Element... elements) {
  List<Range> ranges = new LinkedList<Range>();

  for (Element element : elements) {
    ranges.add(new Range(element.getId().toString()));
  }
  deleter.setRanges(ranges);

  try {
    deleter.delete();
  } catch (Exception e) {
    throw new AccumuloGraphException(e);
  }
}

开发者ID:JHUAPL，项目名称:AccumuloGraph，代码行数:15，代码来源:Mutators.java

示例10: getDeleter

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
protected BatchDeleter getDeleter() {
  try {
    return globals.getConfig().getConnector().createBatchDeleter(tableName,
        globals.getConfig().getAuthorizations(), globals.getConfig().getMaxWriteThreads(),
        globals.getConfig().getBatchWriterConfig());
  } catch (Exception e) {
    throw new AccumuloGraphException(e);
  }
}

开发者ID:JHUAPL，项目名称:AccumuloGraph，代码行数:10，代码来源:BaseTableWrapper.java

示例11: deleteAll

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
public boolean deleteAll(
		final String tableName,
		final String columnFamily,
		final String... additionalAuthorizations ) {
	BatchDeleter deleter = null;
	try {
		deleter = createBatchDeleter(
				tableName,
				additionalAuthorizations);
		deleter.setRanges(Arrays.asList(new Range()));
		deleter.fetchColumnFamily(new Text(
				columnFamily));
		deleter.delete();
		return true;
	}
	catch (final TableNotFoundException | MutationsRejectedException e) {
		LOGGER.warn(
				"Unable to delete row from table [" + tableName + "].",
				e);
		return false;
	}
	finally {
		if (deleter != null) {
			deleter.close();
		}
	}

}

开发者ID:locationtech，项目名称:geowave，代码行数:30，代码来源:BasicAccumuloOperations.java

示例12: deleteAll

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
protected boolean deleteAll(
		final String tableName,
		final String columnFamily,
		final String... additionalAuthorizations ) {
	BatchDeleter deleter = null;
	try {
		deleter = accumuloOperations.createBatchDeleter(
				tableName,
				additionalAuthorizations);

		deleter.setRanges(Arrays.asList(new Range()));
		deleter.fetchColumnFamily(new Text(
				columnFamily));
		deleter.delete();
		return true;
	}
	catch (final TableNotFoundException | MutationsRejectedException e) {
		LOGGER.warn(
				"Unable to delete row from table [" + tableName + "].",
				e);
		return false;
	}
	finally {
		if (deleter != null) {
			deleter.close();
		}
	}

}

开发者ID:locationtech，项目名称:geowave，代码行数:31，代码来源:AccumuloDataStore.java

示例13: initCloseableIterator

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
protected CloseableIterator<T> initCloseableIterator(
		ScannerBase scanner,
		Iterator it ) {
	return new CloseableIteratorWrapper(
			new Closeable() {
				boolean closed = false;

				@Override
				public void close()
						throws IOException {
					if (!closed) {
						if (scanner instanceof BatchDeleter) {
							try {
								((BatchDeleter) scanner).delete();
							}
							catch (MutationsRejectedException | TableNotFoundException e) {
								LOGGER.warn(
										"Unable to delete rows by query constraints",
										e);
							}
						}
						scanner.close();
					}
					closed = true;
				}
			},
			it);
}

开发者ID:locationtech，项目名称:geowave，代码行数:30，代码来源:AccumuloRowPrefixDelete.java

示例14: createScanner

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
protected ScannerBase createScanner(
		AccumuloOperations accumuloOperations,
		String tableName,
		boolean batchScanner,
		String... authorizations )
		throws TableNotFoundException {
	BatchDeleter deleter = accumuloOperations.createBatchDeleter(
			tableName,
			authorizations);
	deleter.removeScanIterator(BatchDeleter.class.getName() + ".NOVALUE");
	return deleter;
}

开发者ID:locationtech，项目名称:geowave，代码行数:14，代码来源:AccumuloRowPrefixDelete.java

示例15: initCloseableIterator

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
protected CloseableIterator<Object> initCloseableIterator(
		ScannerBase scanner,
		Iterator it ) {
	return new CloseableIteratorWrapper(
			new Closeable() {
				boolean closed = false;

				@Override
				public void close()
						throws IOException {
					if (!closed) {
						if (scanner instanceof BatchDeleter) {
							try {
								((BatchDeleter) scanner).delete();
							}
							catch (MutationsRejectedException | TableNotFoundException e) {
								LOGGER.warn(
										"Unable to delete rows by query constraints",
										e);
							}
						}
						scanner.close();
					}
					closed = true;
				}
			},
			it);
}

开发者ID:locationtech，项目名称:geowave，代码行数:30，代码来源:AccumuloRowIdsDelete.java

示例16: remove

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
public static void remove(Store id) throws TableNotFoundException, MutationsRejectedException {
  checkNotNull(id);
  
  BatchDeleter bd = null;
  try {
    bd = id.connector().createBatchDeleter(id.metadataTable(), id.auths(), id.readThreads(), id.writerConfig());
    bd.setRanges(Collections.singleton(Range.exact(id.uuid())));
    bd.delete();
  } finally {
    if (null != bd) {
      bd.close();
    }
  }
}

开发者ID:joshelser，项目名称:cosmos，代码行数:15，代码来源:PersistedStores.java

示例17: dropGraph

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
    public void dropGraph(final AccumuloRdfConfiguration conf, final RyaURI... graphs) throws RyaDAOException {
        BatchDeleter bd_spo = null;
        BatchDeleter bd_po = null;
        BatchDeleter bd_osp = null;

        try {
            bd_spo = createBatchDeleter(tableLayoutStrategy.getSpo(), conf.getAuthorizations());
            bd_po = createBatchDeleter(tableLayoutStrategy.getPo(), conf.getAuthorizations());
            bd_osp = createBatchDeleter(tableLayoutStrategy.getOsp(), conf.getAuthorizations());

            bd_spo.setRanges(Collections.singleton(new Range()));
            bd_po.setRanges(Collections.singleton(new Range()));
            bd_osp.setRanges(Collections.singleton(new Range()));

            for (final RyaURI graph : graphs){
                bd_spo.fetchColumnFamily(new Text(graph.getData()));
                bd_po.fetchColumnFamily(new Text(graph.getData()));
                bd_osp.fetchColumnFamily(new Text(graph.getData()));
            }

            bd_spo.delete();
            bd_po.delete();
            bd_osp.delete();

            //TODO indexers do not support delete-UnsupportedOperation Exception will be thrown
//            for (AccumuloIndex index : secondaryIndexers) {
//                index.dropGraph(graphs);
//            }

        } catch (final Exception e) {
            throw new RyaDAOException(e);
        } finally {
            if (bd_spo != null) {
                bd_spo.close();
            }
            if (bd_po != null) {
                bd_po.close();
            }
            if (bd_osp != null) {
                bd_osp.close();
            }
        }

    }

开发者ID:apache，项目名称:incubator-rya，代码行数:46，代码来源:AccumuloRyaDAO.java

示例18: createBatchDeleter

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
private BatchDeleter createBatchDeleter(final String tableName, final Authorizations authorizations) throws TableNotFoundException {
    return connector.createBatchDeleter(tableName, authorizations, NUM_THREADS, MAX_MEMORY, MAX_TIME, NUM_THREADS);
}

开发者ID:apache，项目名称:incubator-rya，代码行数:4，代码来源:AccumuloRyaDAO.java

示例19: delete

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
@Override
public boolean delete(
		final String tableName,
		final List<ByteArrayId> rowIds,
		final String columnFamily,
		final String columnQualifier,
		final String... authorizations ) {

	boolean success = true;
	BatchDeleter deleter = null;
	try {
		deleter = createBatchDeleter(
				tableName,
				authorizations);
		if ((columnFamily != null) && !columnFamily.isEmpty()) {
			if ((columnQualifier != null) && !columnQualifier.isEmpty()) {
				deleter.fetchColumn(
						new Text(
								columnFamily),
						new Text(
								columnQualifier));
			}
			else {
				deleter.fetchColumnFamily(new Text(
						columnFamily));
			}
		}
		final Set<ByteArrayId> removeSet = new HashSet<ByteArrayId>();
		final List<Range> rowRanges = new ArrayList<Range>();
		for (final ByteArrayId rowId : rowIds) {
			rowRanges.add(Range.exact(new Text(
					rowId.getBytes())));
			removeSet.add(new ByteArrayId(
					rowId.getBytes()));
		}
		deleter.setRanges(rowRanges);

		final Iterator<Map.Entry<Key, Value>> iterator = deleter.iterator();
		while (iterator.hasNext()) {
			final Entry<Key, Value> entry = iterator.next();
			removeSet.remove(new ByteArrayId(
					entry.getKey().getRowData().getBackingArray()));
		}

		if (removeSet.isEmpty()) {
			deleter.delete();
		}

		deleter.close();
	}
	catch (final TableNotFoundException | MutationsRejectedException e) {
		LOGGER.warn(
				"Unable to delete row from table [" + tableName + "].",
				e);
		if (deleter != null) {
			deleter.close();
		}
		success = false;
	}

	return success;
}

开发者ID:locationtech，项目名称:geowave，代码行数:63，代码来源:BasicAccumuloOperations.java

示例20: ClosableBatchDeleter

import org.apache.accumulo.core.client.BatchDeleter; //导入依赖的package包/类
public ClosableBatchDeleter(
		final BatchDeleter deleter ) {
	this.deleter = deleter;
}

开发者ID:locationtech，项目名称:geowave，代码行数:5，代码来源:AccumuloDataStore.java

注：本文中的org.apache.accumulo.core.client.BatchDeleter类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java CredentialRequestResult类代码示例发布时间：2022-05-22

Java IListChangeListener类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19192|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9988|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8327|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8696|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8639|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9657|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8624|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7998|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8656|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7535|2022-11-06

客服电话

电子邮件

Java BatchDeleter类代码示例

示例1: removeElementFromIndex

示例2: deleteVertex

示例3: createBatchDeleter

示例4: addToBatch

示例5: clearTable

示例6: purge

示例7: createBatchDeleter

示例8: dropKeyIndex

示例9: deleteElementRanges

示例10: getDeleter

示例11: deleteAll

示例12: deleteAll

示例13: initCloseableIterator

示例14: createScanner

示例15: initCloseableIterator

示例16: remove

示例17: dropGraph

示例18: createBatchDeleter

示例19: delete

示例20: ClosableBatchDeleter

请发表评论

全部评论

上一篇：

下一篇：

Delphi获取外部程序句柄与发送消息

krishnaik06/Machine-Learning-in-90-days

joaomh/curso-de-matlab

美元符号为什么是“$”

delphi学习笔记的例子

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053